flinkcluster

Documentation

Index

• Constants
• func GenJobId(cluster *v1beta1.FlinkCluster) (string, error)
• func IsApplicationModeCluster(cluster *v1beta1.FlinkCluster) bool
• func ToOwnerReference(flinkCluster *v1beta1.FlinkCluster) metav1.OwnerReference
• type ClusterReconciler
• type ClusterStateObserver
• type ClusterStatusUpdater
• type FlinkClusterHandler
• type FlinkClusterReconciler
  • func NewReconciler(mgr manager.Manager) (*FlinkClusterReconciler, error)
  • func (r *FlinkClusterReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)
  • func (reconciler *FlinkClusterReconciler) SetupWithManager(mgr ctrl.Manager, maxConcurrentReconciles int) error
• type FlinkJob
• type FlinkJobSubmitter
• type JobSubmitState
• type ObservedClusterState
• type Revision
• type Savepoint
• type Status
• type SubmitterLog
• type UpdateState

Constants

const (
	DefaultLog4jConfig = `` /* 481-byte string literal not displayed */

	DefaultLogbackConfig = `` /* 912-byte string literal not displayed */

)

const (
	ControlRetries    = "retries"
	ControlMaxRetries = "3"

	RevisionNameLabel = "flinkoperator.k8s.io/revision-name"
	JobIdLabel        = "flinkoperator.k8s.io/job-id"

	SavepointRetryIntervalSeconds = 10
)

const (
	UpdateStateNoUpdate   UpdateState = "NoUpdate"
	UpdateStatePreparing  UpdateState = "Preparing"
	UpdateStateInProgress UpdateState = "InProgress"
	UpdateStateFinished   UpdateState = "Finished"

	JobDeployStateInProgress = "InProgress"
	JobDeployStateSucceeded  = "Succeeded"
	JobDeployStateFailed     = "Failed"
	JobDeployStateUnknown    = "Unknown"
)

const JobCheckInterval = 10 * time.Second

Functions

func GenJobId

func GenJobId(cluster *v1beta1.FlinkCluster) (string, error)

func IsApplicationModeCluster

func IsApplicationModeCluster(cluster *v1beta1.FlinkCluster) bool

func ToOwnerReference

func ToOwnerReference(
	flinkCluster *v1beta1.FlinkCluster) metav1.OwnerReference

Converts the FlinkCluster as owner reference for its child resources.

Types

type ClusterReconciler

type ClusterReconciler struct {
	// contains filtered or unexported fields
}

ClusterReconciler takes actions to drive the observed state towards the desired state.

type ClusterStateObserver

type ClusterStateObserver struct {
	// contains filtered or unexported fields
}

ClusterStateObserver gets the observed state of the cluster.

type ClusterStatusUpdater

type ClusterStatusUpdater struct {
	// contains filtered or unexported fields
}

ClusterStatusUpdater updates the status of the FlinkCluster CR.

type FlinkClusterHandler

type FlinkClusterHandler struct {
	// contains filtered or unexported fields
}

FlinkClusterHandler holds the context and state for a reconcile request.

type FlinkClusterReconciler

type FlinkClusterReconciler struct {
	Client        client.Client
	Clientset     *kubernetes.Clientset
	EventRecorder record.EventRecorder
}

FlinkClusterReconciler reconciles a FlinkCluster object

func NewReconciler

func NewReconciler(mgr manager.Manager) (*FlinkClusterReconciler, error)

func (*FlinkClusterReconciler) Reconcile

func (r *FlinkClusterReconciler) Reconcile(ctx context.Context,
	request ctrl.Request) (ctrl.Result, error)

Reconcile the observed state towards the desired state for a FlinkCluster custom resource.

func (*FlinkClusterReconciler) SetupWithManager

func (reconciler *FlinkClusterReconciler) SetupWithManager(
	mgr ctrl.Manager,
	maxConcurrentReconciles int) error

SetupWithManager registers this reconciler with the controller manager and starts watching FlinkCluster, Deployment and Service resources.

type FlinkJob

type FlinkJob struct {
	// contains filtered or unexported fields
}

type FlinkJobSubmitter

type FlinkJobSubmitter struct {
	// contains filtered or unexported fields
}

type JobSubmitState

type JobSubmitState string

type ObservedClusterState

type ObservedClusterState struct {
	// contains filtered or unexported fields
}

ObservedClusterState holds observed state of a cluster.

type Revision

type Revision struct {
	// contains filtered or unexported fields
}

type Savepoint

type Savepoint struct {
	// contains filtered or unexported fields
}

type Status

type Status interface {
	String() string
}

type SubmitterLog

type SubmitterLog struct {
	// contains filtered or unexported fields
}

type UpdateState

type UpdateState string