controllers

Documentation

Index

• type ClusterReconciler
• type ClusterStateObserver
• type ClusterStatusUpdater
• type DesiredClusterState
• type FlinkClusterHandler
• type FlinkClusterReconciler
  • func (reconciler *FlinkClusterReconciler) Reconcile(request ctrl.Request) (ctrl.Result, error)
  • func (reconciler *FlinkClusterReconciler) SetupWithManager(mgr ctrl.Manager) error
• type ObservedClusterState
• type TimeConverter
  • func (tc *TimeConverter) FromString(timeStr string) time.Time
  • func (tc *TimeConverter) ToString(timestamp time.Time) string

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 DesiredClusterState

type DesiredClusterState struct {
	JmDeployment            *appsv1.Deployment
	JmService               *corev1.Service
	JmIngress               *extensionsv1beta1.Ingress
	TmDeployment            *appsv1.Deployment
	ConfigMap               *corev1.ConfigMap
	Job                     *batchv1.Job
	NativeClusterSessionJob *batchv1.Job
	NativeJobClusterJob     *batchv1.Job
}

DesiredClusterState holds desired state of a cluster.

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 (*FlinkClusterReconciler) Reconcile

func (reconciler *FlinkClusterReconciler) Reconcile(
	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) error

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

type ObservedClusterState

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

ObservedClusterState holds observed state of a cluster.

type TimeConverter

type TimeConverter struct{}

TimeConverter converts between time.Time and string.

func (*TimeConverter) FromString

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

FromString converts string to time.Time.

func (*TimeConverter) ToString

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

ToString converts time.Time to string.