v1alpha1

package
v0.0.0-...-db59c9c Latest Latest
Warning

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

 Go to latest Published: Apr 24, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

View Source 
var (
	MasterEmbedded    int32 = 19200
	MasterRpcPort     int32 = 19998
	MasterWebPort     int32 = 19999
	JobMasterRpcPort  int32 = 20001
	JobMasterWebPort  int32 = 20002
	JobMasterEmbedded int32 = 20003
	WorkerRpcPort     int32 = 29999
	WorkerWebPort     int32 = 30000
	JobWorkerRpcPort  int32 = 30001
	JobWorkerDataPort int32 = 30002
	JobWorkerWebPort  int32 = 30003
)
View Source 
var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "alluxio.zncdata.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

This section is empty.

Types

type AlluxioCluster 

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

	Spec   AlluxioClusterSpec `json:"spec,omitempty"`
	Status status.Status      `json:"status,omitempty"`
}

AlluxioClusterCluster is the Schema for the alluxioclusters API

func (*AlluxioCluster) DeepCopy 

func (in *AlluxioCluster) DeepCopy() *AlluxioCluster

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

func (*AlluxioCluster) DeepCopyInto 

func (in *AlluxioCluster) DeepCopyInto(out *AlluxioCluster)

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

func (*AlluxioCluster) DeepCopyObject 

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

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

func (*AlluxioCluster) GetNameWithSuffix 

func (r *AlluxioCluster) GetNameWithSuffix(suffix string) string

func (*AlluxioCluster) InitStatusConditions 

func (r *AlluxioCluster) InitStatusConditions()

InitStatusConditions initializes the status conditions to the provided conditions.

func (*AlluxioCluster) SetStatusCondition 

func (r *AlluxioCluster) SetStatusCondition(condition metav1.Condition)

SetStatusCondition updates the status condition using the provided arguments. If the condition already exists, it updates the condition; otherwise, it appends the condition. If the condition status has changed, it updates the condition's LastTransitionTime.

type AlluxioClusterList 

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

AlluxioClusterList contains a list of AlluxioCluster

func (*AlluxioClusterList) DeepCopy 

func (in *AlluxioClusterList) DeepCopy() *AlluxioClusterList

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

func (*AlluxioClusterList) DeepCopyInto 

func (in *AlluxioClusterList) DeepCopyInto(out *AlluxioClusterList)

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

func (*AlluxioClusterList) DeepCopyObject 

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

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

type AlluxioClusterSpec 

type AlluxioClusterSpec struct {
	// +kubebuilder:validation:Required
	ClusterConfig *ClusterConfigSpec `json:"clusterConfig,omitempty"`

	// +kubebuilder:validation:Optional
	Image *ImageSpec `json:"image,omitempty"`

	// +kubebuilder:validation:Required
	Master *MasterSpec `json:"master,omitempty"`

	// +kubebuilder:validation:Required
	Worker *WorkerSpec `json:"worker,omitempty"`
}

AlluxioClusterSpec defines the desired state of AlluxioCluster

func (*AlluxioClusterSpec) DeepCopy 

func (in *AlluxioClusterSpec) DeepCopy() *AlluxioClusterSpec

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

func (*AlluxioClusterSpec) DeepCopyInto 

func (in *AlluxioClusterSpec) DeepCopyInto(out *AlluxioClusterSpec)

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

type AlluxioClusterStatus 

type AlluxioClusterStatus struct {
	// +kubebuilder:validation:Optional
	Conditions []metav1.Condition `json:"condition,omitempty"`
	// +kubebuilder:validation:Optional
	URLs []StatusURL `json:"urls,omitempty"`
}

AlluxioClusterStatus defines the observed state of AlluxioCluster

func (*AlluxioClusterStatus) DeepCopy 

func (in *AlluxioClusterStatus) DeepCopy() *AlluxioClusterStatus

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

func (*AlluxioClusterStatus) DeepCopyInto 

func (in *AlluxioClusterStatus) DeepCopyInto(out *AlluxioClusterStatus)

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

type BaseGroupSpec 

type BaseGroupSpec struct {
	// +kubebuilder:validation:Optional
	// +kubebuilder:default:=1
	Replicas int32 `json:"replicas,omitempty"`
	// +kubebuilder:validation:Optional
	CommandArgsOverrides []string `json:"commandArgsOverrides,omitempty"`
	// +kubebuilder:validation:Optional
	ConfigOverrides *ConfigOverridesSpec `json:"configOverrides,omitempty"`
	// +kubebuilder:validation:Optional
	EnvOverrides map[string]string `json:"envOverrides,omitempty"`
}

func (*BaseGroupSpec) DeepCopy 

func (in *BaseGroupSpec) DeepCopy() *BaseGroupSpec

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

func (*BaseGroupSpec) DeepCopyInto 

func (in *BaseGroupSpec) DeepCopyInto(out *BaseGroupSpec)

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

type CPUResource 

type CPUResource struct {
	// +kubebuilder:validation:Optional
	Max *resource.Quantity `json:"max,omitempty"`

	// +kubebuilder:validation:Optional
	Min *resource.Quantity `json:"min,omitempty"`
}

func (*CPUResource) DeepCopy 

func (in *CPUResource) DeepCopy() *CPUResource

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

func (*CPUResource) DeepCopyInto 

func (in *CPUResource) DeepCopyInto(out *CPUResource)

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
	// +kubebuilder:default=false
	HostPID bool `json:"hostPID,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default=false
	HostNetwork bool `json:"hostNetwork,omitempty"`

	// +kubebuilder:validation:Optional
	DnsPolicy corev1.DNSPolicy `json:"dnsPolicy,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default=false
	ShareProcessNamespace bool `json:"shareProcessNamespace,omitempty"`

	// +kubebuilder:validation:Optional
	Labels map[string]string `json:"labels,omitempty"`

	// +kubebuilder:validation:Optional
	TieredStore []*TieredStore `json:"tieredStore,omitempty"`

	// +kubebuilder:validation:Optional
	ShortCircuit *ShortCircuitSpec `json:"shortCircuit,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default={"alluxio.security.stale.channel.purge.interval": "365d"}
	Properties map[string]string `json:"properties,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default={"-XX:+UseContainerSupport"}
	JvmOptions []string `json:"jvmOptions,omitempty"`

	// +kubebuilder:validation:Optional
	Journal *JournalSpec `json:"journal,omitempty"`
	// +kubebuilder:validation:Optional
	Listener *ListenerSpec `json:"listener,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.

func (*ClusterConfigSpec) GetJournal 

func (clusterConfig *ClusterConfigSpec) GetJournal() JournalSpec

func (*ClusterConfigSpec) GetShortCircuit 

func (clusterConfig *ClusterConfigSpec) GetShortCircuit() ShortCircuitSpec

type ConfigOverridesSpec 

type ConfigOverridesSpec struct {
	OverrideConfig map[string]string `json:"overrideConfig,omitempty"`
}

func (*ConfigOverridesSpec) DeepCopy 

func (in *ConfigOverridesSpec) DeepCopy() *ConfigOverridesSpec

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

func (*ConfigOverridesSpec) DeepCopyInto 

func (in *ConfigOverridesSpec) DeepCopyInto(out *ConfigOverridesSpec)

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

type ContainerLoggingSpec 

type ContainerLoggingSpec struct {
	// +kubebuilder:validation:Optional
	Metastore *LoggingConfigSpec `json:"metastore,omitempty"`
}

func (*ContainerLoggingSpec) DeepCopy 

func (in *ContainerLoggingSpec) DeepCopy() *ContainerLoggingSpec

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

func (*ContainerLoggingSpec) DeepCopyInto 

func (in *ContainerLoggingSpec) DeepCopyInto(out *ContainerLoggingSpec)

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

type DatabaseInlineSpec 

type DatabaseInlineSpec struct {
	// +kubebuilder:validation:Enum=mysql;postgres
	// +kubebuilder:default="postgres"
	Driver string `json:"driver,omitempty"`

	// +kubebuilder:validation=Optional
	// +kubebuilder:default="hive"
	DatabaseName string `json:"databaseName,omitempty"`

	// +kubebuilder:validation=Optional
	// +kubebuilder:default="hive"
	Username string `json:"username,omitempty"`

	// +kubebuilder:validation=Optional
	// +kubebuilder:default="hive"
	Password string `json:"password,omitempty"`

	// +kubebuilder:validation=Required
	Host string `json:"host,omitempty"`

	// +kubebuilder:validation=Optional
	// +kubebuilder:default=5432
	Port int32 `json:"port,omitempty"`
}

DatabaseInlineSpec defines the inline database spec.

func (*DatabaseInlineSpec) DeepCopy 

func (in *DatabaseInlineSpec) DeepCopy() *DatabaseInlineSpec

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

func (*DatabaseInlineSpec) DeepCopyInto 

func (in *DatabaseInlineSpec) DeepCopyInto(out *DatabaseInlineSpec)

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

type DatabaseSpec 

type DatabaseSpec struct {
	// +kubebuilder:validation=Optional
	Reference string `json:"reference"`

	// +kubebuilder:validation=Optional
	Inline *DatabaseInlineSpec `json:"inline,omitempty"`
}

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 ImageSpec 

type ImageSpec struct {

	// +kubebuilder:validation:Optional
	// +kubebuilder:default=alluxio/alluxio
	Repository string `json:"repository"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default=latest
	Tag string `json:"tag"`

	// +kubebuilder:validation:enum=Always;Never;IfNotPresent
	// +kubebuilder:default=IfNotPresent
	PullPolicy corev1.PullPolicy `json:"pullPolicy"`
}

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 JobMasterPortsSpec 

type JobMasterPortsSpec struct {
	// +kubebuilder:validation:Optional
	// +kubebuilder:default=20001
	Rpc int32 `json:"rpc,omitempty"`
	// +kubebuilder:validation:Optional
	// +kubebuilder:default=20002
	Web int32 `json:"web,omitempty"`
	// +kubebuilder:validation:Optional
	// +kubebuilder:default=20003
	Embedded int32 `json:"embedded,omitempty"`
}

func (*JobMasterPortsSpec) DeepCopy 

func (in *JobMasterPortsSpec) DeepCopy() *JobMasterPortsSpec

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

func (*JobMasterPortsSpec) DeepCopyInto 

func (in *JobMasterPortsSpec) DeepCopyInto(out *JobMasterPortsSpec)

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

type JobMasterSpec 

type JobMasterSpec struct {
	// +kubebuilder:validation:Optional
	// +kubebuilder:default={"job-master"}
	Args []string `json:"args,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default={}
	Properties map[string]string `json:"properties,omitempty"`

	// +kubebuilder:validation:Optional
	Resources *ResourcesSpec `json:"resources,omitempty"`

	// +kubebuilder:validation:Optional
	Logging *ContainerLoggingSpec `json:"logging,omitempty"`

	// +kubebuilder:validation:Optional
	Ports *JobMasterPortsSpec `json:"ports,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default={}
	JvmOptions []string `json:"jvmOptions,omitempty"`
}

func (*JobMasterSpec) DeepCopy 

func (in *JobMasterSpec) DeepCopy() *JobMasterSpec

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

func (*JobMasterSpec) DeepCopyInto 

func (in *JobMasterSpec) DeepCopyInto(out *JobMasterSpec)

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

type JobWorkerPortsSpec 

type JobWorkerPortsSpec struct {
	// +kubebuilder:validation:Optional
	// +kubebuilder:default=30001
	Rpc int32 `json:"rpc,omitempty"`
	// +kubebuilder:validation:Optional
	// +kubebuilder:default=30002
	Data int32 `json:"data,omitempty"`
	// +kubebuilder:validation:Optional
	// +kubebuilder:default=30003
	Web int32 `json:"web,omitempty"`
}

func (*JobWorkerPortsSpec) DeepCopy 

func (in *JobWorkerPortsSpec) DeepCopy() *JobWorkerPortsSpec

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

func (*JobWorkerPortsSpec) DeepCopyInto 

func (in *JobWorkerPortsSpec) DeepCopyInto(out *JobWorkerPortsSpec)

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

type JobWorkerSpec 

type JobWorkerSpec struct {
	// +kubebuilder:validation:Optional
	// +kubebuilder:default={"job-worker"}
	Args []string `json:"args,omitempty"`

	// +kubebuilder:validation:Optional
	Properties map[string]string `json:"properties,omitempty"`

	// +kubebuilder:validation:Optional
	Logging *ContainerLoggingSpec `json:"logging,omitempty"`

	// +kubebuilder:validation:Optional
	Resources *ResourcesSpec `json:"resources,omitempty"`

	// +kubebuilder:validation:Optional
	Ports *JobWorkerPortsSpec `json:"ports,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default={}
	JvmOptions []string `json:"jvmOptions,omitempty"`
}

func (*JobWorkerSpec) DeepCopy 

func (in *JobWorkerSpec) DeepCopy() *JobWorkerSpec

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

func (*JobWorkerSpec) DeepCopyInto 

func (in *JobWorkerSpec) DeepCopyInto(out *JobWorkerSpec)

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

type JournalSpec 

type JournalSpec struct {
	// +kubebuilder:validation:Optional
	// +kubebuilder:default="UFS"
	Type string `json:"type,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default="/journal"
	Folder string `json:"folder,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default="local"
	UfsType string `json:"ufsType,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default="persistentVolumeClaim"
	VolumeType string `json:"volumeType,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default="1Gi"
	Size string `json:"size,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default="standard"
	StorageClass string `json:"storageClass,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default="ReadWriteOnce"
	AccessMode string `json:"accessMode,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default=""
	Medium string `json:"medium,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default=false
	RunFormat bool `json:"runFormat,omitempty"`
}

func (*JournalSpec) DeepCopy 

func (in *JournalSpec) DeepCopy() *JournalSpec

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

func (*JournalSpec) DeepCopyInto 

func (in *JournalSpec) DeepCopyInto(out *JournalSpec)

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

type ListenerSpec 

type ListenerSpec struct {
	// +kubebuilder:validation:Optional
	Annotations map[string]string `json:"annotations,omitempty"`

	// +kubebuilder:validation:enum=ClusterIP;NodePort;LoadBalancer;ExternalName
	// +kubebuilder:default=ClusterIP
	Type corev1.ServiceType `json:"type,omitempty"`

	// +kubebuilder:validation:Minimum=1
	// +kubebuilder:validation:Maximum=65535
	// +kubebuilder:default=9083
	Port int32 `json:"port,omitempty"`
}

func (*ListenerSpec) DeepCopy 

func (in *ListenerSpec) DeepCopy() *ListenerSpec

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

func (*ListenerSpec) DeepCopyInto 

func (in *ListenerSpec) DeepCopyInto(out *ListenerSpec)

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

type LogLevelSpec 

type LogLevelSpec struct {
	// +kubebuilder:validation:Optional
	// +kubebuilder:default:="INFO"
	// +kubebuilder:validation:Enum=FATAL;ERROR;WARN;INFO;DEBUG;TRACE
	Level string `json:"level,omitempty"`
}

LogLevelSpec level mapping example |---------------------|-----------------| | superset log level | zds log level | |---------------------|-----------------| | CRITICAL | FATAL | | ERROR | ERROR | | WARNING | WARN | | INFO | INFO | | DEBUG | DEBUG | | DEBUG | TRACE | |---------------------|-----------------|

func (*LogLevelSpec) DeepCopy 

func (in *LogLevelSpec) DeepCopy() *LogLevelSpec

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

func (*LogLevelSpec) DeepCopyInto 

func (in *LogLevelSpec) DeepCopyInto(out *LogLevelSpec)

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

type LoggingConfigSpec 

type LoggingConfigSpec struct {
	// +kubebuilder:validation:Optional
	Loggers map[string]*LogLevelSpec `json:"loggers,omitempty"`

	// +kubebuilder:validation:Optional
	//if Console is set, the console appender will be added to the log4j.properties
	//file appender is the default appender, so we don't need to specify it
	Console *LogLevelSpec `json:"console,omitempty"`
}

func (*LoggingConfigSpec) DeepCopy 

func (in *LoggingConfigSpec) DeepCopy() *LoggingConfigSpec

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

func (*LoggingConfigSpec) DeepCopyInto 

func (in *LoggingConfigSpec) DeepCopyInto(out *LoggingConfigSpec)

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

type MasterConfigSpec 

type MasterConfigSpec struct {
	// +kubebuilder:validation:Optional
	Resources *ResourcesSpec `json:"resources,omitempty"`
	// +kubebuilder:validation:Optional
	MatchLabels map[string]string `json:"matchLabels,omitempty"`
	// +kubebuilder:validation:Optional
	SecurityContext *corev1.PodSecurityContext `json:"securityContext"`

	PodDisruptionBudget *PodDisruptionBudgetSpec `json:"podDisruptionBudget,omitempty"`
	// +kubebuilder:validation:Optional
	Affinity *corev1.Affinity `json:"affinity"`

	// +kubebuilder:validation:Optional
	NodeSelector map[string]string `json:"nodeSelector,omitempty"`

	// +kubebuilder:validation:Optional
	Tolerations []corev1.Toleration `json:"tolerations"`

	// +kubebuilder:validation:Optional
	Logging *ContainerLoggingSpec `json:"logging,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default={}
	EnvVars map[string]string `json:"envVars,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default={}
	Args []string `json:"args,omitempty"`

	// +kubebuilder:validation:Optional
	ExtraContainers []corev1.Container `json:"extraContainers,omitempty"`

	// +kubebuilder:validation:Optional
	ExtraVolumes []corev1.Volume `json:"extraVolumes,omitempty"`

	// +kubebuilder:validation:Optional
	ExtraVolumeMounts []corev1.VolumeMount `json:"extraVolumeMounts,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default={}
	JvmOptions []string `json:"jvmOptions,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default=false
	HostPID *bool `json:"hostPID,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default=false
	HostNetwork *bool `json:"hostNetwork,omitempty"`

	// +kubebuilder:validation:Optional
	DnsPolicy corev1.DNSPolicy `json:"dnsPolicy,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default=false
	ShareProcessNamespace *bool `json:"shareProcessNamespace,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default={}
	Properties map[string]string `json:"properties,omitempty"`
	// +kubebuilder:validation:Optional
	Ports *MasterPortsSpec `json:"ports,omitempty"`
	// +kubebuilder:validation:Optional
	JobMaster *JobMasterSpec `json:"jobMaster,omitempty"`
}

func (*MasterConfigSpec) DeepCopy 

func (in *MasterConfigSpec) DeepCopy() *MasterConfigSpec

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

func (*MasterConfigSpec) DeepCopyInto 

func (in *MasterConfigSpec) DeepCopyInto(out *MasterConfigSpec)

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

type MasterPortsSpec 

type MasterPortsSpec struct {
	// +kubebuilder:validation:Optional
	// +kubebuilder:default=19200
	Embedded int32 `json:"embedded,omitempty"`
	// +kubebuilder:validation:Optional
	// +kubebuilder:default=19998
	Rpc int32 `json:"rpc,omitempty"`
	// +kubebuilder:validation:Optional
	// +kubebuilder:default=19999
	Web int32 `json:"web,omitempty"`
}

func (*MasterPortsSpec) DeepCopy 

func (in *MasterPortsSpec) DeepCopy() *MasterPortsSpec

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

func (*MasterPortsSpec) DeepCopyInto 

func (in *MasterPortsSpec) DeepCopyInto(out *MasterPortsSpec)

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

type MasterRoleGroupSpec 

type MasterRoleGroupSpec struct {
	BaseGroupSpec `json:",inline"`
	Config        *MasterConfigSpec `json:"config,omitempty"`
}

func (*MasterRoleGroupSpec) DeepCopy 

func (in *MasterRoleGroupSpec) DeepCopy() *MasterRoleGroupSpec

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

func (*MasterRoleGroupSpec) DeepCopyInto 

func (in *MasterRoleGroupSpec) DeepCopyInto(out *MasterRoleGroupSpec)

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

type MasterSpec 

type MasterSpec struct {
	// +kubebuilder:validation:Optional
	Config *MasterConfigSpec `json:"config,omitempty"`

	RoleGroups map[string]*MasterRoleGroupSpec `json:"roleGroups,omitempty"`

	PodDisruptionBudget *PodDisruptionBudgetSpec `json:"podDisruptionBudget,omitempty"`
	// +kubebuilder:validation:Optional
	CommandArgsOverrides []string `json:"commandArgsOverrides,omitempty"`

	// +kubebuilder:validation:Optional
	ConfigOverrides *ConfigOverridesSpec `json:"configOverrides,omitempty"`

	// +kubebuilder:validation:Optional
	EnvOverrides map[string]string `json:"envOverrides,omitempty"`
}

func (*MasterSpec) DeepCopy 

func (in *MasterSpec) DeepCopy() *MasterSpec

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

func (*MasterSpec) DeepCopyInto 

func (in *MasterSpec) DeepCopyInto(out *MasterSpec)

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

type MemoryResource 

type MemoryResource struct {
	// +kubebuilder:validation:Optional
	Limit *resource.Quantity `json:"limit,omitempty"`
}

func (*MemoryResource) DeepCopy 

func (in *MemoryResource) DeepCopy() *MemoryResource

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

func (*MemoryResource) DeepCopyInto 

func (in *MemoryResource) DeepCopyInto(out *MemoryResource)

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

type PodDisruptionBudgetSpec 

type PodDisruptionBudgetSpec struct {
	// +kubebuilder:validation:Optional
	MinAvailable int32 `json:"minAvailable,omitempty"`

	// +kubebuilder:validation:Optional
	MaxUnavailable int32 `json:"maxUnavailable,omitempty"`
}

func (*PodDisruptionBudgetSpec) DeepCopy 

func (in *PodDisruptionBudgetSpec) DeepCopy() *PodDisruptionBudgetSpec

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

func (*PodDisruptionBudgetSpec) DeepCopyInto 

func (in *PodDisruptionBudgetSpec) DeepCopyInto(out *PodDisruptionBudgetSpec)

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

type ResourcesSpec 

type ResourcesSpec struct {
	// +kubebuilder:validation:Optional
	CPU *CPUResource `json:"cpu,omitempty"`

	// +kubebuilder:validation:Optional
	Memory *MemoryResource `json:"memory,omitempty"`

	// +kubebuilder:validation:Optional
	Storage *StorageResource `json:"storage,omitempty"`
}

func (*ResourcesSpec) DeepCopy 

func (in *ResourcesSpec) DeepCopy() *ResourcesSpec

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

func (*ResourcesSpec) DeepCopyInto 

func (in *ResourcesSpec) DeepCopyInto(out *ResourcesSpec)

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

type S3BucketInlineSpec 

type S3BucketInlineSpec struct {

	// +kubeBuilder:validation=Required
	Bucket string `json:"bucket"`

	// +kubebuilder:validation=Optional
	// +kubebuilder:default="us-east-1"
	Region string `json:"region,omitempty"`

	// +kubebuilder:validation=Required
	Endpoints string `json:"endpoints"`

	// +kubebuilder:validation=Optional
	// +kubebuilder:default=false
	SSL bool `json:"ssl,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default:=false
	PathStyle bool `json:"pathStyle,omitempty"`

	// +kubebuilder:validation=Optional
	AccessKey string `json:"accessKey,omitempty"`

	// +kubebuilder:validation=Optional
	SecretKey string `json:"secretKey,omitempty"`
}

func (*S3BucketInlineSpec) DeepCopy 

func (in *S3BucketInlineSpec) DeepCopy() *S3BucketInlineSpec

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

func (*S3BucketInlineSpec) DeepCopyInto 

func (in *S3BucketInlineSpec) DeepCopyInto(out *S3BucketInlineSpec)

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

type S3BucketSpec 

type S3BucketSpec struct {
	// S3 bucket name with S3Bucket
	// +kubebuilder:validation=Optional
	Reference *string `json:"reference"`

	// +kubebuilder:validation=Optional
	Inline *S3BucketInlineSpec `json:"inline,omitempty"`

	// +kubebuilder:validation=Optional
	// +kubebuilder:default=20
	MaxConnect int `json:"maxConnect"`

	// +kubebuilder:validation=Optional
	PathStyleAccess bool `json:"pathStyle_access"`
}

func (*S3BucketSpec) DeepCopy 

func (in *S3BucketSpec) DeepCopy() *S3BucketSpec

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

func (*S3BucketSpec) DeepCopyInto 

func (in *S3BucketSpec) DeepCopyInto(out *S3BucketSpec)

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

type ShortCircuitSpec 

type ShortCircuitSpec struct {
	// +kubebuilder:validation:Optional
	// +kubebuilder:default=true
	Enabled bool `json:"enabled,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default="uuid"
	Policy string `json:"policy,omitempty"`

	// +kubebuilder:validation:hostPath,persistentVolumeClaim
	// +kubebuilder:default="hostPath"
	VolumeType string `json:"volumeType,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default="100Mi"
	Size string `json:"size,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default="alluxio-worker-domain-socket"
	PvcName string `json:"pvcName,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default="standard"
	StorageClass string `json:"storageClass,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default="ReadWriteOnce"
	AccessMode string `json:"accessMode,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default="/tmp/"
	HosePath string `json:"path,omitempty"`
}

func (*ShortCircuitSpec) DeepCopy 

func (in *ShortCircuitSpec) DeepCopy() *ShortCircuitSpec

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

func (*ShortCircuitSpec) DeepCopyInto 

func (in *ShortCircuitSpec) DeepCopyInto(out *ShortCircuitSpec)

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

type StatusURL 

type StatusURL struct {
	Name string `json:"name"`
	URL  string `json:"url"`
}

func (*StatusURL) DeepCopy 

func (in *StatusURL) DeepCopy() *StatusURL

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

func (*StatusURL) DeepCopyInto 

func (in *StatusURL) DeepCopyInto(out *StatusURL)

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

type StorageResource 

type StorageResource struct {
	// +kubebuilder:validation:Optional
	// +kubebuilder:default="10Gi"
	Capacity resource.Quantity `json:"capacity,omitempty"`

	// +kubebuilder:validation:Optional
	StorageClass string `json:"storageClass,omitempty"`
}

func (*StorageResource) DeepCopy 

func (in *StorageResource) DeepCopy() *StorageResource

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

func (*StorageResource) DeepCopyInto 

func (in *StorageResource) DeepCopyInto(out *StorageResource)

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

type StorageResourceSpec 

type StorageResourceSpec struct {
	Data *StorageResource `json:"data"`
}

func (*StorageResourceSpec) DeepCopy 

func (in *StorageResourceSpec) DeepCopy() *StorageResourceSpec

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

func (*StorageResourceSpec) DeepCopyInto 

func (in *StorageResourceSpec) DeepCopyInto(out *StorageResourceSpec)

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

type TieredStore 

type TieredStore struct {
	Level      int32   `json:"level"`
	Alias      string  `json:"alias"`
	MediumType string  `json:"mediumType"`
	Path       string  `json:"path"`
	Type       string  `json:"type"`
	Quota      string  `json:"quota"`
	High       float64 `json:"high"`
	Low        float64 `json:"low"`
}

func (*TieredStore) DeepCopy 

func (in *TieredStore) DeepCopy() *TieredStore

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

func (*TieredStore) DeepCopyInto 

func (in *TieredStore) DeepCopyInto(out *TieredStore)

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

type WorkerConfigSpec 

type WorkerConfigSpec struct {
	// +kubebuilder:validation:Optional
	Resources *ResourcesSpec `json:"resources,omitempty"`
	// +kubebuilder:validation:Optional
	MatchLabels map[string]string `json:"matchLabels,omitempty"`
	// +kubebuilder:validation:Optional
	SecurityContext *corev1.PodSecurityContext `json:"securityContext"`

	PodDisruptionBudget *PodDisruptionBudgetSpec `json:"podDisruptionBudget,omitempty"`
	// +kubebuilder:validation:Optional
	Affinity *corev1.Affinity `json:"affinity"`

	// +kubebuilder:validation:Optional
	NodeSelector map[string]string `json:"nodeSelector,omitempty"`

	// +kubebuilder:validation:Optional
	Tolerations []corev1.Toleration `json:"tolerations"`

	// +kubebuilder:validation:Optional
	Logging *ContainerLoggingSpec `json:"logging,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default={}
	EnvVars map[string]string `json:"envVars,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default={}
	Args []string `json:"args,omitempty"`

	// +kubebuilder:validation:Optional
	ExtraContainers []corev1.Container `json:"extraContainers,omitempty"`

	// +kubebuilder:validation:Optional
	ExtraVolumes []corev1.Volume `json:"extraVolumes,omitempty"`

	// +kubebuilder:validation:Optional
	ExtraVolumeMounts []corev1.VolumeMount `json:"extraVolumeMounts,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default={}
	JvmOptions []string `json:"jvmOptions,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default=false
	HostPID *bool `json:"hostPID,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default=false
	HostNetwork *bool `json:"hostNetwork,omitempty"`

	// +kubebuilder:validation:Optional
	DnsPolicy corev1.DNSPolicy `json:"dnsPolicy,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default=false
	ShareProcessNamespace *bool `json:"shareProcessNamespace,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default={}
	Properties map[string]string `json:"properties,omitempty"`

	Resource ResourcesSpec `json:"resource,omitempty"`

	// +kubebuilder:validation:Optional
	Ports *WorkerPortsSpec `json:"ports,omitempty"`
	// +kubebuilder:validation:Optional
	JobWorker *JobWorkerSpec `json:"jobWorker,omitempty"`
}

func (*WorkerConfigSpec) DeepCopy 

func (in *WorkerConfigSpec) DeepCopy() *WorkerConfigSpec

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

func (*WorkerConfigSpec) DeepCopyInto 

func (in *WorkerConfigSpec) DeepCopyInto(out *WorkerConfigSpec)

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

type WorkerPortsSpec 

type WorkerPortsSpec struct {
	// +kubebuilder:validation:Optional
	// +kubebuilder:default=29999
	Rpc int32 `json:"rpc,omitempty"`
	// +kubebuilder:validation:Optional
	// +kubebuilder:default=30000
	Web int32 `json:"web,omitempty"`
}

func (*WorkerPortsSpec) DeepCopy 

func (in *WorkerPortsSpec) DeepCopy() *WorkerPortsSpec

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

func (*WorkerPortsSpec) DeepCopyInto 

func (in *WorkerPortsSpec) DeepCopyInto(out *WorkerPortsSpec)

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

type WorkerRoleGroupSpec 

type WorkerRoleGroupSpec struct {
	BaseGroupSpec `json:",inline"`
	Config        *WorkerConfigSpec `json:"config,omitempty"`
}

func (*WorkerRoleGroupSpec) DeepCopy 

func (in *WorkerRoleGroupSpec) DeepCopy() *WorkerRoleGroupSpec

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

func (*WorkerRoleGroupSpec) DeepCopyInto 

func (in *WorkerRoleGroupSpec) DeepCopyInto(out *WorkerRoleGroupSpec)

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

type WorkerSpec 

type WorkerSpec struct {
	// +kubebuilder:validation:Optional
	Config *WorkerConfigSpec `json:"config,omitempty"`

	RoleGroups map[string]*WorkerRoleGroupSpec `json:"roleGroups,omitempty"`

	PodDisruptionBudget *PodDisruptionBudgetSpec `json:"podDisruptionBudget,omitempty"`
	// +kubebuilder:validation:Optional
	CommandArgsOverrides []string `json:"commandArgsOverrides,omitempty"`

	// +kubebuilder:validation:Optional
	ConfigOverrides *ConfigOverridesSpec `json:"configOverrides,omitempty"`

	// +kubebuilder:validation:Optional
	EnvOverrides map[string]string `json:"envOverrides,omitempty"`
}

func (*WorkerSpec) DeepCopy 

func (in *WorkerSpec) DeepCopy() *WorkerSpec

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

func (*WorkerSpec) DeepCopyInto 

func (in *WorkerSpec) DeepCopyInto(out *WorkerSpec)

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.