controllers

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
	Log    logr.Logger
	Mgr    ctrl.Manager
}

FlinkClusterReconciler reconciles a FlinkCluster object

func (reconciler *FlinkClusterReconciler) Reconcile(
	request ctrl.Request) (ctrl.Result, error)

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

type ObservedClusterState ¶

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

ObservedClusterState holds observed state of a cluster.

type RevisionStatus ¶

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

type TimeConverter ¶

type TimeConverter struct{}

TimeConverter converts between time.Time and string.

func (tc *TimeConverter) FromString(timeStr string) time.Time

func (tc *TimeConverter) ToString(timestamp time.Time) string

type UpdateState ¶

type UpdateState string

const (
	UpdateStateStoppingJob UpdateState = "StoppingJob"
	UpdateStateUpdating    UpdateState = "Updating"
	UpdateStateFinished    UpdateState = "Finished"
)