controllers

Documentation

Index

• type ClusterReconciler
• type ClusterStateInspector
• type ClusterStatusUpdater
• type DesiredClusterState
• type InspectedClusterState
• type PrestoClusterController
• type PrestoClusterReconciler
  • func (r *PrestoClusterReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *PrestoClusterReconciler) SetupWithManager(mgr ctrl.Manager, maxConcurrentReconciles int) error

Types

type ClusterReconciler

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

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

type ClusterStateInspector

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

ClusterStateInspector gets the Inspected state of the cluster.

type ClusterStatusUpdater

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

ClusterStatusUpdater updates the status of the PrestoCluster CR.

type DesiredClusterState

type DesiredClusterState struct {
	CoordinatorDeployment *appsv1.Deployment
	WorkerDeployment      *appsv1.Deployment
	CoordinatorService    *corev1.Service
	PrestoConfigMap       *corev1.ConfigMap
	CatalogConfigMap      *corev1.ConfigMap
	Job                   *batchv1.Job
}

DesiredClusterState holds desired state of a cluster.

type InspectedClusterState

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

InspectedClusterState holds Inspected state of a cluster.

type PrestoClusterController

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

PrestoClusterController the context, inspected state and desired state for the reconcile request.

type PrestoClusterReconciler

type PrestoClusterReconciler struct {
	client.Client
	Log      logr.Logger
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder
}

PrestoClusterReconciler reconciles a PrestoCluster object

func (*PrestoClusterReconciler) Reconcile

func (r *PrestoClusterReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

Reconcile implements the Reconciler interface in the controller-runime.

func (*PrestoClusterReconciler) SetupWithManager

func (r *PrestoClusterReconciler) SetupWithManager(mgr ctrl.Manager, maxConcurrentReconciles int) error

SetupWithManager defines the type of Object being *reconciled*, and configures the ControllerManagedBy to respond to create / delete /update events by *reconciling the object*.