Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

v1beta1

package

Go to main page

Versions in this module

v0

v0.9.9

Jul 13, 2023

v0.9.9-ci-test

Jul 13, 2023

v0.9.8

Jul 21, 2022

v0.9.7

Jun 7, 2022

v0.9.6-1

Apr 4, 2022

v0.9.5

Feb 14, 2022

v0.9.5-4

Jan 27, 2022

v0.9.5-3

Jan 26, 2022

v0.9.5-2

Jan 21, 2022

v0.9.4

Jan 21, 2022

v0.9.4-2

Jan 21, 2022

v0.9.4-1

Jan 20, 2022

v0.9.3

Jan 19, 2022

v0.9.2

Jan 17, 2022

v0.9.1

Jan 14, 2022

Changes in this version

+ const AccessScopeCluster

+ const AccessScopeExternal

+ const AccessScopeHeadless

+ const AccessScopeNodePort

+ const AccessScopeVPC

+ const CleanupActionDeleteCluster

+ const CleanupActionDeleteTaskManager

+ const CleanupActionKeepCluster

+ const ClusterStateCreating

+ const ClusterStatePartiallyStopped

+ const ClusterStateReconciling

+ const ClusterStateRunning

+ const ClusterStateStopped

+ const ClusterStateStopping

+ const ClusterStateUpdating

+ const ComponentStateDeleted

+ const ComponentStateNotReady

+ const ComponentStateReady

+ const ComponentStateUpdating

+ const ControlAnnotation

+ const ControlChangeWarnMsg

+ const ControlNameJobCancel

+ const ControlNameSavepoint

+ const ControlStateFailed

+ const ControlStateProgressing

+ const ControlStateSucceeded

+ const InvalidControlAnnMsg

+ const InvalidJobStateForJobCancelMsg

+ const InvalidJobStateForSavepointMsg

+ const InvalidSavepointDirMsg

+ const JobStateCancelled

+ const JobStateFailed

+ const JobStateLost

+ const JobStatePending

+ const JobStateRunning

+ const JobStateSucceeded

+ const JobStateSuspended

+ const JobStateUnknown

+ const JobStateUpdating

+ const SavepointStateFailed

+ const SavepointStateInProgress

+ const SavepointStateNotTriggered

+ const SavepointStateSucceeded

+ const SavepointStateTriggerFailed

+ const SavepointTriggerReasonJobCancel

+ const SavepointTriggerReasonScheduled

+ const SavepointTriggerReasonScheduledInitial

+ const SavepointTriggerReasonUpdate

+ const SavepointTriggerReasonUserRequested

+ const SessionClusterWarnMsg

+ 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

+ JobManagerIngress *JobManagerIngressStatus

+ JobManagerService JobManagerServiceStatus

+ JobManagerStatefulSet FlinkClusterComponentState

+ TaskManagerStatefulSet FlinkClusterComponentState

+ func (in *FlinkClusterComponentsStatus) DeepCopy() *FlinkClusterComponentsStatus

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

+ type FlinkClusterControlStatus struct

+ Details map[string]string

+ Message string

+ Name string

+ State string

+ UpdateTime string

+ func (in *FlinkClusterControlStatus) DeepCopy() *FlinkClusterControlStatus

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

+ 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

+ BatchSchedulerName *string

+ EnvFrom []corev1.EnvFromSource

+ EnvVars []corev1.EnvVar

+ FlinkProperties map[string]string

+ GCPConfig *GCPConfig

+ HadoopConfig *HadoopConfig

+ Image ImageSpec

+ Job *JobSpec

+ JobManager JobManagerSpec

+ LogConfig map[string]string

+ RecreateOnUpdate *bool

+ RevisionHistoryLimit *int32

+ ServiceAccountName *string

+ TaskManager TaskManagerSpec

+ func (in *FlinkClusterSpec) DeepCopy() *FlinkClusterSpec

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

+ type FlinkClusterStatus struct

+ CollisionCount *int32

+ Components FlinkClusterComponentsStatus

+ Control *FlinkClusterControlStatus

+ CurrentRevision string

+ LastUpdateTime string

+ NextRevision string

+ Savepoint *SavepointStatus

+ 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 JobManagerServiceStatus struct

+ Name string

+ NodePort int32

+ State string

+ func (in *JobManagerServiceStatus) DeepCopy() *JobManagerServiceStatus

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

+ type JobManagerSpec struct

+ AccessScope string

+ ExtraPorts []NamedPort

+ Ingress *JobManagerIngressSpec

+ InitContainers []corev1.Container

+ MemoryOffHeapMin resource.Quantity

+ MemoryOffHeapRatio *int32

+ NodeSelector map[string]string

+ PodAnnotations map[string]string

+ PodLabels map[string]string

+ Ports JobManagerPorts

+ Replicas *int32

+ Resources corev1.ResourceRequirements

+ SecurityContext *corev1.PodSecurityContext

+ Sidecars []corev1.Container

+ Tolerations []corev1.Toleration

+ VolumeClaimTemplates []corev1.PersistentVolumeClaim

+ VolumeMounts []corev1.VolumeMount

+ Volumes []corev1.Volume

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

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

+ type JobRestartPolicy string

+ const JobRestartPolicyFromSavepointOnFailure

+ const JobRestartPolicyNever

+ 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

+ PodAnnotations map[string]string

+ PodLabels map[string]string

+ Resources corev1.ResourceRequirements

+ RestartPolicy *JobRestartPolicy

+ SavepointGeneration int32

+ SavepointsDir *string

+ SecurityContext *corev1.PodSecurityContext

+ TakeSavepointOnUpgrade *bool

+ 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

+ LastSavepointTriggerTime string

+ Name string

+ RestartCount int32

+ SavepointGeneration int32

+ SavepointLocation string

+ State string

+ func (in *JobStatus) DeepCopy() *JobStatus

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

+ type NamedPort struct

+ ContainerPort int32

+ Name string

+ Protocol string

+ func (in *NamedPort) DeepCopy() *NamedPort

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

+ type SavepointStatus struct

+ JobID string

+ Message string

+ RequestTime string

+ State string

+ TriggerID string

+ TriggerReason string

+ TriggerTime string

+ func (in *SavepointStatus) DeepCopy() *SavepointStatus

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

+ type TaskManagerPorts struct

+ Data *int32

+ Query *int32

+ RPC *int32

+ func (in *TaskManagerPorts) DeepCopy() *TaskManagerPorts

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

+ type TaskManagerSpec struct

+ ExtraPorts []NamedPort

+ InitContainers []corev1.Container

+ MemoryOffHeapMin resource.Quantity

+ MemoryOffHeapRatio *int32

+ NodeSelector map[string]string

+ PodAnnotations map[string]string

+ PodLabels map[string]string

+ Ports TaskManagerPorts

+ Replicas int32

+ Resources corev1.ResourceRequirements

+ SecurityContext *corev1.PodSecurityContext

+ Sidecars []corev1.Container

+ Tolerations []corev1.Toleration

+ VolumeClaimTemplates []corev1.PersistentVolumeClaim

+ 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