# Constants
AccessScope defines the access scope of JobManager service.
AccessScope defines the access scope of JobManager service.
AccessScope defines the access scope of JobManager service.
AccessScope defines the access scope of JobManager service.
AccessScope defines the access scope of JobManager service.
CleanupActionDeleteCluster - delete the entire cluster.
CleanupActionDeleteTaskManager - delete task manager, keep job manager.
CleanupActionKeepCluster - keep the entire cluster.
ClusterState defines states for a cluster.
ClusterState defines states for a cluster.
ClusterState defines states for a cluster.
ClusterState defines states for a cluster.
ClusterState defines states for a cluster.
ClusterState defines states for a cluster.
ClusterState defines states for a cluster.
ComponentState defines states for a cluster component.
ComponentState defines states for a cluster component.
ComponentState defines states for a cluster component.
ComponentState defines states for a cluster component.
control annotation key.
No description provided by the author
User requested control.
control name.
User requested control.
control state.
User requested control.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
JobRestartPolicyFromSavepointOnFailure - restart the job from the latest savepoint if available, otherwise do not restart.
JobRestartPolicyNever - never restarts a failed job.
JobState defines states for a Flink job deployment.
JobState defines states for a Flink job deployment.
JobState defines states for a Flink job deployment.
JobState defines states for a Flink job deployment.
JobState defines states for a Flink job deployment.
JobState defines states for a Flink job deployment.
JobState defines states for a Flink job deployment.
JobState defines states for a Flink job deployment.
JobState defines states for a Flink job deployment.
Savepoint status.
Savepoint status.
Savepoint status.
Savepoint status.
Savepoint status.
Savepoint status.
Savepoint status.
The first triggered savepoint has slightly different flow.
Savepoint status.
Savepoint status.
No description provided by the author
# Variables
AddToScheme adds the types in this group-version to the given scheme.
GroupVersion is group version used to register these objects.
SchemeBuilder is used to add go types to the GroupVersionKind scheme.
# Structs
CleanupPolicy defines the action to take after job finishes.
FlinkCluster is the Schema for the flinkclusters API.
FlinkClusterComponentsStatus defines the observed status of the components of a FlinkCluster.
FlinkClusterComponentState defines the observed state of a component of a FlinkCluster.
Control state.
FlinkClusterList contains a list of FlinkCluster.
FlinkClusterSpec defines the desired state of FlinkCluster.
FlinkClusterStatus defines the observed state of FlinkCluster.
GCPConfig defines configs for GCP.
GCPServiceAccount defines the config about GCP service account.
HadoopConfig defines configs for Hadoop.
ImageSpec defines Flink image of JobManager and TaskManager containers.
JobManagerIngressSpec defines ingress of JobManager.
JobManagerIngressStatus defines the status of a JobManager ingress.
JobManagerPorts defines ports of JobManager.
JobManagerServiceStatus defines the observed state of FlinkCluster.
JobManagerSpec defines properties of JobManager.
JobSpec defines properties of a Flink job.
JobStatus defines the status of a job.
NamedPort defines the container port properties.
SavepointStatus defines the status of savepoint progress.
TaskManagerPorts defines ports of TaskManager.
TaskManagerSpec defines properties of TaskManager.
Validator validates CUD requests for the CR.
# Type aliases
CleanupAction defines the action to take after job finishes.
JobRestartPolicy defines the restart policy when a job fails.