v1alpha1

package
v0.0.0-...-30da7b9 Latest Latest
Warning

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

 Go to latest Published: Dec 16, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Overview

Package v1alpha1 contains API Schema definitions for the hive v1alpha1 API group +kubebuilder:object:generate=true +groupName=hive.kubedoop.dev

Index

Constants

View Source 
const (
	DefaultRepository      = "quay.io/zncdatadev"
	DefaultProductVersion  = "3.1.3"
	DefaultProductName     = "hive"
	DefaultKubedoopVersion = "0.0.0-dev"
)
View Source 
const (
	DefaultWarehouseDir = "/kubedoop/warehouse"
)

Variables

View Source 
var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "hive.kubedoop.dev", 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
)

Functions

func TransformImage 

func TransformImage(imageSpec *ImageSpec) *util.Image

Types

type AuthenticationSpec 

type AuthenticationSpec struct {
	// +kubebuilder:validation:Optional
	Tls *TlsSpec `json:"tls,omitempty"`

	// +kubebuilder:validation:Required
	Kerberos *KerberosSpec `json:"kerberos"`
}

func (*AuthenticationSpec) DeepCopy 

func (in *AuthenticationSpec) DeepCopy() *AuthenticationSpec

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

func (*AuthenticationSpec) DeepCopyInto 

func (in *AuthenticationSpec) DeepCopyInto(out *AuthenticationSpec)

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

type ClusterConfigSpec 

type ClusterConfigSpec struct {

	// +kubebuilder:validation:Optional
	VectorAggregatorConfigMapName string `json:"vectorAggregatorConfigMapName,omitempty"`

	// +kubebuilder:validation:Required
	Database *DatabaseSpec `json:"database"`

	// +kubebuilder:validation:Optional
	S3 *S3Spec `json:"s3,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default:=cluster-internal
	// +kubebuilder:validation:Enum=cluster-internal;external-unstable;external-stable
	ListenerClass constants.ListenerClass `json:"listenerClass,omitempty"`

	// +kubebuilder:validation:Optional
	HDFS *HDFSSpec `json:"hdfs,omitempty"`

	// +kubebuilder:validation:Optional
	Authentication *AuthenticationSpec `json:"authentication,omitempty"`
}

func (*ClusterConfigSpec) DeepCopy 

func (in *ClusterConfigSpec) DeepCopy() *ClusterConfigSpec

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

func (*ClusterConfigSpec) DeepCopyInto 

func (in *ClusterConfigSpec) DeepCopyInto(out *ClusterConfigSpec)

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

type ConfigSpec 

type ConfigSpec struct {
	*commonsv1alpha1.RoleGroupConfigSpec `json:",inline"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default:="/kubedoop/warehouse"
	WarehouseDir string `json:"warehouseDir,omitempty"`
}

func (*ConfigSpec) DeepCopy 

func (in *ConfigSpec) DeepCopy() *ConfigSpec

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

func (*ConfigSpec) DeepCopyInto 

func (in *ConfigSpec) DeepCopyInto(out *ConfigSpec)

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

type DatabaseSpec 

type DatabaseSpec struct {
	// +kubebuilder:validation:Required
	ConnectionString string `json:"connectionString"`

	// +kubebuilder:validation:Required
	// +kubebuilder:default="derby"
	// +kubebuilder:validation:enum=derby;mysql;postgres;oracle
	DatabaseType string `json:"databaseType"`

	// +kubebuilder:validation:Required
	// A reference to a secret to use for the database connection credentials.
	// It must contain the following keys:
	//  - username
	//  - password
	CredentialsSecret string `json:"credentialsSecret"`
}

func (*DatabaseSpec) DeepCopy 

func (in *DatabaseSpec) DeepCopy() *DatabaseSpec

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

func (*DatabaseSpec) DeepCopyInto 

func (in *DatabaseSpec) DeepCopyInto(out *DatabaseSpec)

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

type HDFSSpec 

type HDFSSpec struct {
	// +kubebuilder:validation:Required
	ConfigMap string `json:"configMap"`
}

func (*HDFSSpec) DeepCopy 

func (in *HDFSSpec) DeepCopy() *HDFSSpec

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

func (*HDFSSpec) DeepCopyInto 

func (in *HDFSSpec) DeepCopyInto(out *HDFSSpec)

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

type HiveMetastore 

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

	Spec   HiveMetastoreSpec   `json:"spec,omitempty"`
	Status HiveMetastoreStatus `json:"status,omitempty"`
}

HiveMetastore is the Schema for the hivemetastores API

func (*HiveMetastore) DeepCopy 

func (in *HiveMetastore) DeepCopy() *HiveMetastore

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

func (*HiveMetastore) DeepCopyInto 

func (in *HiveMetastore) DeepCopyInto(out *HiveMetastore)

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

func (*HiveMetastore) DeepCopyObject 

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

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

type HiveMetastoreList 

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

HiveMetastoreList contains a list of HiveMetastore

func (*HiveMetastoreList) DeepCopy 

func (in *HiveMetastoreList) DeepCopy() *HiveMetastoreList

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

func (*HiveMetastoreList) DeepCopyInto 

func (in *HiveMetastoreList) DeepCopyInto(out *HiveMetastoreList)

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

func (*HiveMetastoreList) DeepCopyObject 

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

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

type HiveMetastoreSpec 

type HiveMetastoreSpec struct {
	// +kubebuilder:validation:Optional
	Image *ImageSpec `json:"image,omitempty"`

	// +kubebuilder:validation:Required
	ClusterConfig *ClusterConfigSpec `json:"clusterConfig"`

	// +kubebuilder:validation:Optional
	ClusterOperation *commonsv1alpha1.ClusterOperationSpec `json:"clusterOperation,omitempty"`

	// +kubebuilder:validation:Required
	Metastore *RoleSpec `json:"metastore"`
}

HiveMetastoreSpec defines the desired state of HiveMetastore

func (*HiveMetastoreSpec) DeepCopy 

func (in *HiveMetastoreSpec) DeepCopy() *HiveMetastoreSpec

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

func (*HiveMetastoreSpec) DeepCopyInto 

func (in *HiveMetastoreSpec) DeepCopyInto(out *HiveMetastoreSpec)

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

type HiveMetastoreStatus 

type HiveMetastoreStatus struct {
	// +kubebuilder:validation:Optional
	Conditions []metav1.Condition `json:"condition,omitempty"`

	// +kubebuilder:validation:Optional
	Replicas int32 `json:"replicas,omitempty"`
}

HiveMetastoreStatus defines the observed state of HiveMetastore

func (*HiveMetastoreStatus) DeepCopy 

func (in *HiveMetastoreStatus) DeepCopy() *HiveMetastoreStatus

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

func (*HiveMetastoreStatus) DeepCopyInto 

func (in *HiveMetastoreStatus) DeepCopyInto(out *HiveMetastoreStatus)

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

type ImageSpec 

type ImageSpec struct {
	// +kubebuilder:validation:Optional
	Custom string `json:"custom,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default=quay.io/zncdatadev
	Repo string `json:"repo,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default="0.0.0-dev"
	KubedoopVersion string `json:"kubedoopVersion,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default="3.1.3"
	ProductVersion string `json:"productVersion,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default=IfNotPresent
	// +kubebuilder:validation:Enum=Always;Never;IfNotPresent
	PullPolicy corev1.PullPolicy `json:"pullPolicy,omitempty"`

	// +kubebuilder:validation:Optional
	PullSecretName string `json:"pullSecretName,omitempty"`
}

func (*ImageSpec) DeepCopy 

func (in *ImageSpec) DeepCopy() *ImageSpec

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

func (*ImageSpec) DeepCopyInto 

func (in *ImageSpec) DeepCopyInto(out *ImageSpec)

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

type KerberosSpec 

type KerberosSpec struct {
	// +kubebuilder:validation:Required
	// +kubebuilder:minLength=1
	SecretClass string `json:"secretClass"`
}

func (*KerberosSpec) DeepCopy 

func (in *KerberosSpec) DeepCopy() *KerberosSpec

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

func (*KerberosSpec) DeepCopyInto 

func (in *KerberosSpec) DeepCopyInto(out *KerberosSpec)

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

type LoggingSpec 

type LoggingSpec struct {
	// +kubebuilder:validation:Optional
	// +kubebuilder:default=false
	EnableVectorAgent bool `json:"enableVectorAgent,omitempty"`

	// +kubebuilder:validation:Optional
	Containers map[string]commonsv1alpha1.LoggingConfigSpec `json:"metastore,omitempty"`
}

func (*LoggingSpec) DeepCopy 

func (in *LoggingSpec) DeepCopy() *LoggingSpec

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

func (*LoggingSpec) DeepCopyInto 

func (in *LoggingSpec) DeepCopyInto(out *LoggingSpec)

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

type RoleGroupSpec 

type RoleGroupSpec struct {
	// +kubebuilder:validation:Optional
	// +kubebuilder:default:=1
	Replicas int32 `json:"replicas,omitempty"`

	// +kubebuilder:validation:Optional
	Config *ConfigSpec `json:"config,omitempty"`

	*commonsv1alpha1.OverridesSpec `json:",inline"`
}

func (*RoleGroupSpec) DeepCopy 

func (in *RoleGroupSpec) DeepCopy() *RoleGroupSpec

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

func (*RoleGroupSpec) DeepCopyInto 

func (in *RoleGroupSpec) DeepCopyInto(out *RoleGroupSpec)

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

type RoleSpec 

type RoleSpec struct {

	// +kubebuilder:validation:Optional
	Config *ConfigSpec `json:"config,omitempty"`

	// +kubebuilder:validation:Required
	RoleGroups map[string]*RoleGroupSpec `json:"roleGroups"`

	// +kubebuilder:validation:Optional
	RoleConfig *commonsv1alpha1.RoleConfigSpec `json:"roleConfig,omitempty"`

	*commonsv1alpha1.OverridesSpec `json:",inline"`
}

func (*RoleSpec) DeepCopy 

func (in *RoleSpec) DeepCopy() *RoleSpec

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

func (*RoleSpec) DeepCopyInto 

func (in *RoleSpec) DeepCopyInto(out *RoleSpec)

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

type S3Spec 

type S3Spec struct {
	// +kubebuilder:validation:Optional
	Inline *s3v1alpha1.S3ConnectionSpec `json:"inline,omitempty"`

	// S3 connection reference
	// +kubebuilder:validation:Optional
	Reference string `json:"reference,omitempty"`
}

func (*S3Spec) DeepCopy 

func (in *S3Spec) DeepCopy() *S3Spec

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

func (*S3Spec) DeepCopyInto 

func (in *S3Spec) DeepCopyInto(out *S3Spec)

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

type TlsSpec 

type TlsSpec struct {
	// +kubebuilder:validation:Optional
	// +kubebuilder:default:="tls"
	// +kubebuilder:minLength=1
	SecretClass string `json:"secretClass,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default:="changeit"
	JksPassword string `json:"jksPassword,omitempty"`
}

func (*TlsSpec) DeepCopy 

func (in *TlsSpec) DeepCopy() *TlsSpec

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

func (*TlsSpec) DeepCopyInto 

func (in *TlsSpec) DeepCopyInto(out *TlsSpec)

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.