controllers

Documentation

Index

• Constants
• Variables
• type RayClusterReconciler
  • func (r *RayClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *RayClusterReconciler) SetupWithManager(mgr ctrl.Manager) error
• type SparkClusterReconciler
  • func (r *SparkClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *SparkClusterReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const SparkFinalizerName = "distributed-compute.dominodatalab.com/dco-finalizer"

const SparkLastAppliedConfig = "distributed-compute-operator.dominodatalab.com/last-applied"

LastAppliedConfig is the annotation key used to store object state on owned components.

Variables

var (
	// SparkPatchAnnotator applies state annotations to owned components.
	SparkPatchAnnotator = patch.NewAnnotator(SparkLastAppliedConfig)
	// SparkPatchMaker calculates changes to state annotations on owned components.
	SparkPatchMaker = patch.NewPatchMaker(SparkPatchAnnotator)
)

var (
	// DistributedComputeFinalizer is the custom identifier used to mark
	// controller-managed resources that require pre-delete hook logic.
	DistributedComputeFinalizer = path.Join(dcv1alpha1.GroupVersion.Group, "finalizer")

	// PatchAnnotator applies state annotations to owned components.
	PatchAnnotator = patch.NewAnnotator(path.Join(dcv1alpha1.GroupVersion.Group, "last-applied"))
	// PatchMaker calculates changes to state annotations on owned components.
	PatchMaker = patch.NewPatchMaker(PatchAnnotator)
	// PatchCalculateOpts define the exclusion rules used when calculating the
	// difference between two k8s resources.
	PatchCalculateOpts = []patch.CalculateOption{
		patch.IgnoreStatusFields(),
		patch.IgnoreVolumeClaimTemplateTypeMetaAndStatus(),
	}
)

Types

type RayClusterReconciler

type RayClusterReconciler struct {
	client.Client
	Log          logging.ContextLogger
	Scheme       *runtime.Scheme
	IstioEnabled bool
}

RayClusterReconciler reconciles RayCluster objects.

func (*RayClusterReconciler) Reconcile

func (r *RayClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile implements state reconciliation logic for RayCluster objects.

func (*RayClusterReconciler) SetupWithManager

func (r *RayClusterReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager creates and registers this controller with the manager.

type SparkClusterReconciler

type SparkClusterReconciler struct {
	client.Client
	Log          logging.ContextLogger
	Scheme       *runtime.Scheme
	IstioEnabled bool
}

SparkClusterReconciler reconciles SparkCluster objects.

func (*SparkClusterReconciler) Reconcile

func (r *SparkClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile implements state reconciliation logic for SparkCluster objects.

func (*SparkClusterReconciler) SetupWithManager

func (r *SparkClusterReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager creates and registers this controller with the manager.