v1alpha1

package
v0.313.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 9, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Overview

Package v1alpha1 +k8s:deepcopy-gen=package +groupName=metastore.nineinfra.tech

Package v1alpha1 contains API Schema definitions for the metastore v1alpha1 API group +kubebuilder:object:generate=true +groupName=metastore.nineinfra.tech

Index

Constants

View Source 
const (
	// available
	StateAvailable = "Available"
	// failed
	StateFailed = "Failed"
)

Definitions to manage status conditions

View Source 
const ClusterNameSuffix = "-metastore"
View Source 
const ClusterSign = "metastore"

Variables

View Source 
var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "metastore.nineinfra.tech", Version: "v1alpha1"}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion}

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)
View Source 
var SchemeGroupVersion = GroupVersion

SchemeGroupVersion is group version used to register these objects.

Functions

func Resource 

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

Types

type ClusterRef 

type ClusterRef struct {
	// Name is the name of the referenced cluster
	Name string `json:"name"`
	// +kubebuilder:validation:Enum={database,minio,hdfs}
	Type ClusterType `json:"type"`
	// ClusterInfo is the detail info of the cluster of the clustertype
	// +optional
	// Database cluster infos referenced by the Metastore cluster
	Database DatabaseCluster `json:"database"`
	// +optional
	// Minio cluster infos referenced by the Metastore cluster
	Minio MinioCluster `json:"minio"`
	// +optional
	// HDFS cluster infos referenced by the Metastore cluster
	Hdfs HdfsCluster `json:"hdfs"`
}

func (*ClusterRef) DeepCopy 

func (in *ClusterRef) DeepCopy() *ClusterRef

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterRef.

func (*ClusterRef) DeepCopyInto 

func (in *ClusterRef) DeepCopyInto(out *ClusterRef)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterType 

type ClusterType string
const (
	DatabaseClusterType ClusterType = "database"
	MinioClusterType    ClusterType = "minio"
	HdfsClusterType     ClusterType = "hdfs"
)

Different types of clusters.

type DatabaseCluster 

type DatabaseCluster struct {
	// connection Url of the database.such as jdbc:mysql://mysql:3306/metastore
	ConnectionUrl string `json:"connectionUrl"`
	//Db type.Specified the driver name.Support mysql,postgres
	DbType string `json:"dbType"`
	// Username of the database.
	UserName string `json:"userName"`
	// password
	Password string `json:"password"`
}

func (*DatabaseCluster) DeepCopy 

func (in *DatabaseCluster) DeepCopy() *DatabaseCluster

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DatabaseCluster.

func (*DatabaseCluster) DeepCopyInto 

func (in *DatabaseCluster) DeepCopyInto(out *DatabaseCluster)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ExposedInfo 

type ExposedInfo struct {
	//Exposed name.
	Name string `json:"name"`
	//Exposed type. Support REST and THRIFT_BINARY
	ExposedType ExposedType `json:"exposedType"`
	//Exposed service name
	ServiceName string `json:"serviceName"`
	//Exposed service port info
	ServicePort corev1.ServicePort `json:"servicePort"`
}

func (*ExposedInfo) DeepCopy 

func (in *ExposedInfo) DeepCopy() *ExposedInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ExposedInfo.

func (*ExposedInfo) DeepCopyInto 

func (in *ExposedInfo) DeepCopyInto(out *ExposedInfo)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ExposedType 

type ExposedType string
const (
	ExposedRest       ExposedType = "rest"
	ExposedThriftHttp ExposedType = "thrift-http"
)

type HdfsCluster 

type HdfsCluster struct {
	// +optional
	// HDFS core-site.xml.The type of the value must be string
	CoreSite map[string]string `json:"coreSite,omitempty"`
	// +optional
	// HDFS hdfs-site.xml.The type of the value must be string
	HdfsSite map[string]string `json:"hdfsSite,omitempty"`
}

func (*HdfsCluster) DeepCopy 

func (in *HdfsCluster) DeepCopy() *HdfsCluster

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new HdfsCluster.

func (*HdfsCluster) DeepCopyInto 

func (in *HdfsCluster) DeepCopyInto(out *HdfsCluster)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ImageConfig 

type ImageConfig struct {
	Repository string `json:"repository"`
	// Image tag. Usually the vesion of the kyuubi, default: `latest`.
	// +optional
	Tag string `json:"tag,omitempty"`
	// Image pull policy. One of `Always, Never, IfNotPresent`, default: `Always`.
	// +kubebuilder:default:=Always
	// +kubebuilder:validation:Enum=Always;Never;IfNotPresent
	// +optional
	PullPolicy string `json:"pullPolicy,omitempty"`
	// Secrets for image pull.
	// +optional
	PullSecrets string `json:"pullSecret,omitempty"`
}

func (*ImageConfig) DeepCopy 

func (in *ImageConfig) DeepCopy() *ImageConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ImageConfig.

func (*ImageConfig) DeepCopyInto 

func (in *ImageConfig) DeepCopyInto(out *ImageConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type MetastoreCluster 

type MetastoreCluster struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   MetastoreClusterSpec   `json:"spec,omitempty"`
	Status MetastoreClusterStatus `json:"status,omitempty"`
}

MetastoreCluster is the Schema for the metastoreclusters API

func (*MetastoreCluster) DeepCopy 

func (in *MetastoreCluster) DeepCopy() *MetastoreCluster

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MetastoreCluster.

func (*MetastoreCluster) DeepCopyInto 

func (in *MetastoreCluster) DeepCopyInto(out *MetastoreCluster)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*MetastoreCluster) DeepCopyObject 

func (in *MetastoreCluster) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*MetastoreCluster) Default 

func (r *MetastoreCluster) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*MetastoreCluster) SetupWebhookWithManager 

func (r *MetastoreCluster) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*MetastoreCluster) ValidateCreate 

func (r *MetastoreCluster) ValidateCreate() (admission.Warnings, error)

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*MetastoreCluster) ValidateDelete 

func (r *MetastoreCluster) ValidateDelete() (admission.Warnings, error)

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*MetastoreCluster) ValidateUpdate 

func (r *MetastoreCluster) ValidateUpdate(old runtime.Object) (admission.Warnings, error)

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type MetastoreClusterList 

type MetastoreClusterList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []MetastoreCluster `json:"items"`
}

MetastoreClusterList contains a list of MetastoreCluster

func (*MetastoreClusterList) DeepCopy 

func (in *MetastoreClusterList) DeepCopy() *MetastoreClusterList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MetastoreClusterList.

func (*MetastoreClusterList) DeepCopyInto 

func (in *MetastoreClusterList) DeepCopyInto(out *MetastoreClusterList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*MetastoreClusterList) DeepCopyObject 

func (in *MetastoreClusterList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type MetastoreClusterSpec 

type MetastoreClusterSpec struct {
	//Metastore version
	MetastoreVersion string `json:"metastoreVersion"`
	//Metastore image info
	MetastoreImage ImageConfig `json:"metastoreImage"`
	//Metastore resouce configuration
	MetastoreResource ResourceConfig `json:"metastoreResource"`
	//Metastore configurations.These cofigurations will be injected into the hive-site.xml.The type of the value must be string
	MetastoreConf map[string]string `json:"metastoreConf"`
	//Clusters referenced by Metastore
	ClusterRefs []ClusterRef `json:"clusterRefs"`
}

MetastoreClusterSpec defines the desired state of MetastoreCluster

func (*MetastoreClusterSpec) DeepCopy 

func (in *MetastoreClusterSpec) DeepCopy() *MetastoreClusterSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MetastoreClusterSpec.

func (*MetastoreClusterSpec) DeepCopyInto 

func (in *MetastoreClusterSpec) DeepCopyInto(out *MetastoreClusterSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type MetastoreClusterStatus 

type MetastoreClusterStatus struct {
	// Represents the observations of a NineCluster's current state.
	// MetastoreCluster.status.conditions.type are: "Available", "Progressing", and "Degraded"
	// MetastoreCluster.status.conditions.status are one of True, False, Unknown.
	// MetastoreCluster.status.conditions.reason the value should be a CamelCase string and producers of specific
	// condition types may define expected values and meanings for this field, and whether the values
	// are considered a guaranteed API.
	// MetastoreCluster.status.conditions.Message is a human readable message indicating details about the transition.
	// For further information see: https://github.com/kubernetes/community/blob/master/contributors/devel/sig-architecture/api-conventions.md#typical-status-properties
	ExposedInfos []ExposedInfo      `json:"exposedInfos"`
	CreationTime metav1.Time        `json:"creationTime"`
	UpdateTime   metav1.Time        `json:"updateTime"`
	Conditions   []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,1,rep,name=conditions"`
}

MetastoreClusterStatus defines the observed state of MetastoreCluster

func (*MetastoreClusterStatus) DeepCopy 

func (in *MetastoreClusterStatus) DeepCopy() *MetastoreClusterStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MetastoreClusterStatus.

func (*MetastoreClusterStatus) DeepCopyInto 

func (in *MetastoreClusterStatus) DeepCopyInto(out *MetastoreClusterStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type MinioCluster 

type MinioCluster struct {
	// Endpoint of minio.Default is the service called minio.
	Endpoint string `json:"endpoint"`
	// Access Key
	AccessKey string `json:"accessKey"`
	// Secret Key
	SecretKey string `json:"secretKey"`
	// SSL enabled
	SSLEnabled string `json:"sslEnabled"`
	//Path style access
	PathStyleAccess string `json:"pathStyleAccess"`
}

func (*MinioCluster) DeepCopy 

func (in *MinioCluster) DeepCopy() *MinioCluster

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MinioCluster.

func (*MinioCluster) DeepCopyInto 

func (in *MinioCluster) DeepCopyInto(out *MinioCluster)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ResourceConfig 

type ResourceConfig struct {
	// The replicas of the kyuubi cluster workload.
	Replicas int32 `json:"replicas"`
}

func (*ResourceConfig) DeepCopy 

func (in *ResourceConfig) DeepCopy() *ResourceConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceConfig.

func (*ResourceConfig) DeepCopyInto 

func (in *ResourceConfig) DeepCopyInto(out *ResourceConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.