v1beta1

May 8, 2024

Changes in this version

type FlinkDeploymentSpec

+ PodTemplateSpec corev1.PodTemplateSpec

type FlinkDeploymentStatus

+ Error string

+ JobStatus JobStatusInfo

+ LifecycleState string

+ type JobStatusInfo struct

+ JobId string

+ JobName string

+ StartTime string

+ State string

+ UpdateTime string

+ func (in *JobStatusInfo) DeepCopy() *JobStatusInfo

+ func (in *JobStatusInfo) DeepCopyInto(out *JobStatusInfo)

May 22, 2023

Changes in this version

type FlinkDeploymentSpec

+ LogConfiguration map[string]string

+ RestartNonce int64

type FlinkDeploymentStatus

+ ClusterInfo map[string]string

+ ReconciliationStatus string

+ TaskManager TaskManagerInfo

type FlinkJobStatusSpec

+ StartTime string

+ UpdateTime string

type FlinkSessionJobSpec

+ FlinkConfiguration map[string]string

+ RestartNonce int64

type FlinkSessionJobStatus

+ LifecycleState string

type JobManagerSpec

+ PodTemplate corev1.PodTemplate

type ResourceSpec

+ EphemeralStorage string

+ type TaskManagerInfo struct

+ LabelSelector string

+ Replicas int32

+ func (in *TaskManagerInfo) DeepCopy() *TaskManagerInfo

+ func (in *TaskManagerInfo) DeepCopyInto(out *TaskManagerInfo)

type TaskManagerSpec

+ PodTemplate corev1.PodTemplate

+ Replicas int32

Nov 25, 2022

Changes in this version

type FlinkDeploymentSpec

+ ImagePullPolicy string

Jul 5, 2022

Changes in this version

+ func IsArgsEqual(a []string, b []string) (bool, error)

type FlinkSessionJobSpec

+ func (self FlinkSessionJobSpec) Equals(other FlinkSessionJobSpec) (bool, error)

type JobSpec

+ func (self JobSpec) Equals(other JobSpec) (bool, error)

Jul 4, 2022

Changes in this version

type JobSpec

+ AllowNonRestoredState bool

+ InitialSavepointPath string

+ SavepointTriggerNonce int64

May 30, 2022

Changes in this version

type FlinkDeploymentSpec

+ JobSpec JobSpec

May 16, 2022

Changes in this version

type JobSpec

+ Args []string

May 9, 2022

Changes in this version

type FlinkSessionJobSpec

+ DeploymentName string

type FlinkSessionJobStatus

+ Error string

Apr 19, 2022

Changes in this version

+ const FlinkJobStateRunning

+ const SessionJobStateSuspended

+ type FlinkJobStatusSpec struct

+ JobId string

+ JobName string

+ State string

+ func (in *FlinkJobStatusSpec) DeepCopy() *FlinkJobStatusSpec

+ func (in *FlinkJobStatusSpec) DeepCopyInto(out *FlinkJobStatusSpec)

type FlinkSessionJobStatus

+ FlinkJobStatus FlinkJobStatusSpec

Apr 18, 2022

Changes in this version

+ const JobManagerStatusDeployedNotReady

+ const JobManagerStatusDeploying

+ const JobManagerStatusError

+ const JobManagerStatusMissing

+ const JobManagerStatusReady

+ const SessionJobDesiredStateRunning

+ const SessionJobDesiredStateSuspended

+ const SessionJobStateRunning

+ const UpgradeModeLastState

+ const UpgradeModeSavepoint

+ const UpgradeModeStateless

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var GroupVersion = schema.GroupVersion

+ var SchemeBuilder = &scheme.Builder

+ type FlinkDeployment struct

+ Spec FlinkDeploymentSpec

+ Status FlinkDeploymentStatus

+ func (in *FlinkDeployment) DeepCopy() *FlinkDeployment

+ func (in *FlinkDeployment) DeepCopyInto(out *FlinkDeployment)

+ func (in *FlinkDeployment) DeepCopyObject() runtime.Object

+ type FlinkDeploymentList struct

+ Items []FlinkDeployment

+ func (in *FlinkDeploymentList) DeepCopy() *FlinkDeploymentList

+ func (in *FlinkDeploymentList) DeepCopyInto(out *FlinkDeploymentList)

+ func (in *FlinkDeploymentList) DeepCopyObject() runtime.Object

+ type FlinkDeploymentSpec struct

+ FlinkConfiguration map[string]string

+ FlinkVersion string

+ Image string

+ JobManager JobManagerSpec

+ PodTemplate corev1.PodTemplate

+ ServiceAccount string

+ TaskManager TaskManagerSpec

+ func (in *FlinkDeploymentSpec) DeepCopy() *FlinkDeploymentSpec

+ func (in *FlinkDeploymentSpec) DeepCopyInto(out *FlinkDeploymentSpec)

+ type FlinkDeploymentStatus struct

+ JobManagerStatus string

+ func (in *FlinkDeploymentStatus) DeepCopy() *FlinkDeploymentStatus

+ func (in *FlinkDeploymentStatus) DeepCopyInto(out *FlinkDeploymentStatus)

+ type FlinkSessionJob struct

+ Spec FlinkSessionJobSpec

+ Status FlinkSessionJobStatus

+ func (in *FlinkSessionJob) DeepCopy() *FlinkSessionJob

+ func (in *FlinkSessionJob) DeepCopyInto(out *FlinkSessionJob)

+ func (in *FlinkSessionJob) DeepCopyObject() runtime.Object

+ type FlinkSessionJobList struct

+ Items []FlinkSessionJob

+ func (in *FlinkSessionJobList) DeepCopy() *FlinkSessionJobList

+ func (in *FlinkSessionJobList) DeepCopyInto(out *FlinkSessionJobList)

+ func (in *FlinkSessionJobList) DeepCopyObject() runtime.Object

+ type FlinkSessionJobSpec struct

+ ClusterId string

+ Job JobSpec

+ func (in *FlinkSessionJobSpec) DeepCopy() *FlinkSessionJobSpec

+ func (in *FlinkSessionJobSpec) DeepCopyInto(out *FlinkSessionJobSpec)

+ type FlinkSessionJobStatus struct

+ JobStatus JobStatusSpec

+ func (in *FlinkSessionJobStatus) DeepCopy() *FlinkSessionJobStatus

+ func (in *FlinkSessionJobStatus) DeepCopyInto(out *FlinkSessionJobStatus)

+ type JobManagerSpec struct

+ Replicas int32

+ Resource ResourceSpec

+ func (in *JobManagerSpec) DeepCopy() *JobManagerSpec

+ func (in *JobManagerSpec) DeepCopyInto(out *JobManagerSpec)

+ type JobSpec struct

+ EntryClass string

+ JarURI string

+ Parallelism int32

+ State string

+ UpgradeMode string

+ func (in *JobSpec) DeepCopy() *JobSpec

+ func (in *JobSpec) DeepCopyInto(out *JobSpec)

+ type JobStatusSpec struct

+ JobId string

+ JobName string

+ State string

+ func (in *JobStatusSpec) DeepCopy() *JobStatusSpec

+ func (in *JobStatusSpec) DeepCopyInto(out *JobStatusSpec)

+ type ResourceSpec struct

+ CPU float32

+ Memory string

+ func (in *ResourceSpec) DeepCopy() *ResourceSpec

+ func (in *ResourceSpec) DeepCopyInto(out *ResourceSpec)

+ type TaskManagerSpec struct

+ Resource ResourceSpec

+ func (in *TaskManagerSpec) DeepCopy() *TaskManagerSpec

+ func (in *TaskManagerSpec) DeepCopyInto(out *TaskManagerSpec)