Versions in this module Expand all Collapse all v1 v1.0.1 Aug 5, 2020 Changes in this version + const AccessScopeCluster + const AccessScopeExternal + const AccessScopeVPC + const CleanupActionDeleteCluster + const CleanupActionDeleteTaskManager + const CleanupActionKeepCluster + const ClusterStateCreating + const ClusterStatePartiallyStopped + const ClusterStateReconciling + const ClusterStateRunning + const ClusterStateStopped + const ClusterStateStopping + const ComponentStateDeleted + const ComponentStateNotReady + const ComponentStateReady + const JobRestartPolicyFromSavepointOnFailure + const JobRestartPolicyNever + const JobStateCancelled + const JobStateFailed + const JobStatePending + const JobStateRunning + const JobStateSucceeded + const JobStateUnknown + var AddToScheme = SchemeBuilder.AddToScheme + var GroupVersion = schema.GroupVersion + var SchemeBuilder = &scheme.Builder + type CleanupAction string + type CleanupPolicy struct + AfterJobCancelled CleanupAction + AfterJobFails CleanupAction + AfterJobSucceeds CleanupAction + func (in *CleanupPolicy) DeepCopy() *CleanupPolicy + func (in *CleanupPolicy) DeepCopyInto(out *CleanupPolicy) + type FlinkCluster struct + Spec FlinkClusterSpec + Status FlinkClusterStatus + func (cluster *FlinkCluster) Default() + func (cluster *FlinkCluster) SetupWebhookWithManager(mgr ctrl.Manager) error + func (cluster *FlinkCluster) ValidateCreate() error + func (cluster *FlinkCluster) ValidateDelete() error + func (cluster *FlinkCluster) ValidateUpdate(old runtime.Object) error + func (in *FlinkCluster) DeepCopy() *FlinkCluster + func (in *FlinkCluster) DeepCopyInto(out *FlinkCluster) + func (in *FlinkCluster) DeepCopyObject() runtime.Object + type FlinkClusterComponentState struct + Name string + State string + func (in *FlinkClusterComponentState) DeepCopy() *FlinkClusterComponentState + func (in *FlinkClusterComponentState) DeepCopyInto(out *FlinkClusterComponentState) + type FlinkClusterComponentsStatus struct + ConfigMap FlinkClusterComponentState + Job *JobStatus + JobManagerDeployment FlinkClusterComponentState + JobManagerIngress *JobManagerIngressStatus + JobManagerService FlinkClusterComponentState + TaskManagerDeployment FlinkClusterComponentState + func (in *FlinkClusterComponentsStatus) DeepCopy() *FlinkClusterComponentsStatus + func (in *FlinkClusterComponentsStatus) DeepCopyInto(out *FlinkClusterComponentsStatus) + type FlinkClusterList struct + Items []FlinkCluster + func (in *FlinkClusterList) DeepCopy() *FlinkClusterList + func (in *FlinkClusterList) DeepCopyInto(out *FlinkClusterList) + func (in *FlinkClusterList) DeepCopyObject() runtime.Object + type FlinkClusterSpec struct + EnvVars []corev1.EnvVar + FlinkProperties map[string]string + GCPConfig *GCPConfig + HadoopConfig *HadoopConfig + Image ImageSpec + Job *JobSpec + JobManager JobManagerSpec + TaskManager TaskManagerSpec + func (in *FlinkClusterSpec) DeepCopy() *FlinkClusterSpec + func (in *FlinkClusterSpec) DeepCopyInto(out *FlinkClusterSpec) + type FlinkClusterStatus struct + Components FlinkClusterComponentsStatus + LastUpdateTime string + State string + func (in *FlinkClusterStatus) DeepCopy() *FlinkClusterStatus + func (in *FlinkClusterStatus) DeepCopyInto(out *FlinkClusterStatus) + type GCPConfig struct + ServiceAccount *GCPServiceAccount + func (in *GCPConfig) DeepCopy() *GCPConfig + func (in *GCPConfig) DeepCopyInto(out *GCPConfig) + type GCPServiceAccount struct + KeyFile string + MountPath string + SecretName string + func (in *GCPServiceAccount) DeepCopy() *GCPServiceAccount + func (in *GCPServiceAccount) DeepCopyInto(out *GCPServiceAccount) + type HadoopConfig struct + ConfigMapName string + MountPath string + func (in *HadoopConfig) DeepCopy() *HadoopConfig + func (in *HadoopConfig) DeepCopyInto(out *HadoopConfig) + type ImageSpec struct + Name string + PullPolicy corev1.PullPolicy + PullSecrets []corev1.LocalObjectReference + func (in *ImageSpec) DeepCopy() *ImageSpec + func (in *ImageSpec) DeepCopyInto(out *ImageSpec) + type JobManagerIngressSpec struct + Annotations map[string]string + HostFormat *string + TLSSecretName *string + UseTLS *bool + func (in *JobManagerIngressSpec) DeepCopy() *JobManagerIngressSpec + func (in *JobManagerIngressSpec) DeepCopyInto(out *JobManagerIngressSpec) + type JobManagerIngressStatus struct + Name string + State string + URLs []string + func (in *JobManagerIngressStatus) DeepCopy() *JobManagerIngressStatus + func (in *JobManagerIngressStatus) DeepCopyInto(out *JobManagerIngressStatus) + type JobManagerPorts struct + Blob *int32 + Query *int32 + RPC *int32 + UI *int32 + func (in *JobManagerPorts) DeepCopy() *JobManagerPorts + func (in *JobManagerPorts) DeepCopyInto(out *JobManagerPorts) + type JobManagerSpec struct + AccessScope string + Ingress *JobManagerIngressSpec + MemoryOffHeapMin resource.Quantity + MemoryOffHeapRatio *int32 + NodeSelector map[string]string + Ports JobManagerPorts + Replicas *int32 + Resources corev1.ResourceRequirements + VolumeMounts []corev1.VolumeMount + Volumes []corev1.Volume + func (in *JobManagerSpec) DeepCopy() *JobManagerSpec + func (in *JobManagerSpec) DeepCopyInto(out *JobManagerSpec) + type JobRestartPolicy = string + type JobSpec struct + AllowNonRestoredState *bool + Args []string + AutoSavepointSeconds *int32 + CancelRequested *bool + ClassName *string + CleanupPolicy *CleanupPolicy + FromSavepoint *string + InitContainers []corev1.Container + JarFile string + NoLoggingToStdout *bool + Parallelism *int32 + RestartPolicy *JobRestartPolicy + SavepointGeneration int32 + SavepointsDir *string + VolumeMounts []corev1.VolumeMount + Volumes []corev1.Volume + func (in *JobSpec) DeepCopy() *JobSpec + func (in *JobSpec) DeepCopyInto(out *JobSpec) + type JobStatus struct + FromSavepoint string + ID string + LastSavepointTime string + LastSavepointTriggerID string + Name string + RestartCount int32 + SavepointGeneration int32 + SavepointLocation string + State string + func (in *JobStatus) DeepCopy() *JobStatus + func (in *JobStatus) DeepCopyInto(out *JobStatus) + type TaskManagerPorts struct + Data *int32 + Query *int32 + RPC *int32 + func (in *TaskManagerPorts) DeepCopy() *TaskManagerPorts + func (in *TaskManagerPorts) DeepCopyInto(out *TaskManagerPorts) + type TaskManagerSpec struct + MemoryOffHeapMin resource.Quantity + MemoryOffHeapRatio *int32 + NodeSelector map[string]string + Ports TaskManagerPorts + Replicas int32 + Resources corev1.ResourceRequirements + Sidecars []corev1.Container + VolumeMounts []corev1.VolumeMount + Volumes []corev1.Volume + func (in *TaskManagerSpec) DeepCopy() *TaskManagerSpec + func (in *TaskManagerSpec) DeepCopyInto(out *TaskManagerSpec) + type Validator struct + func (in *Validator) DeepCopy() *Validator + func (in *Validator) DeepCopyInto(out *Validator) + func (v *Validator) ValidateCreate(cluster *FlinkCluster) error + func (v *Validator) ValidateUpdate(old *FlinkCluster, new *FlinkCluster) error