controllers

Documentation

Index

• func IndexVolumeSnapshots(ctx context.Context, mgr ctrl.Manager) error
• type CosmosFullNodeReconciler
  • func NewFullNode(client client.Client, recorder record.EventRecorder, ...) *CosmosFullNodeReconciler
  • func (r *CosmosFullNodeReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *CosmosFullNodeReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager) error
• type ScheduledVolumeSnapshotReconciler
  • func NewScheduledVolumeSnapshotReconciler(client client.Client, recorder record.EventRecorder, ...) *ScheduledVolumeSnapshotReconciler
  • func (r *ScheduledVolumeSnapshotReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ScheduledVolumeSnapshotReconciler) SetupWithManager(_ context.Context, mgr ctrl.Manager) error
• type SelfHealingReconciler
  • func NewSelfHealing(client client.Client, recorder record.EventRecorder, ...) *SelfHealingReconciler
  • func (r *SelfHealingReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *SelfHealingReconciler) SetupWithManager(_ context.Context, mgr ctrl.Manager) error
• type StatefulJobReconciler
  • func NewStatefulJob(client client.Client, recorder record.EventRecorder, missingVolSnapCRD bool) *StatefulJobReconciler
  • func (r *StatefulJobReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *StatefulJobReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager) error

Functions

func IndexVolumeSnapshots

func IndexVolumeSnapshots(ctx context.Context, mgr ctrl.Manager) error

IndexVolumeSnapshots indexes all VolumeSnapshots by name. Exposed as a separate method so caller can test for presence of VolumeSnapshot CRDs in the cluster.

Types

type CosmosFullNodeReconciler

type CosmosFullNodeReconciler struct {
	client.Client
	// contains filtered or unexported fields
}

CosmosFullNodeReconciler reconciles a CosmosFullNode object

func NewFullNode

func NewFullNode(
	client client.Client,
	recorder record.EventRecorder,
	statusClient *fullnode.StatusClient,
	cacheController *cosmos.CacheController,
) *CosmosFullNodeReconciler

NewFullNode returns a valid CosmosFullNode controller.

func (*CosmosFullNodeReconciler) Reconcile

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

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.12.1/pkg/reconcile

func (*CosmosFullNodeReconciler) SetupWithManager

func (r *CosmosFullNodeReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type ScheduledVolumeSnapshotReconciler

type ScheduledVolumeSnapshotReconciler struct {
	client.Client
	// contains filtered or unexported fields
}

ScheduledVolumeSnapshotReconciler reconciles a ScheduledVolumeSnapshot object

func NewScheduledVolumeSnapshotReconciler

func NewScheduledVolumeSnapshotReconciler(
	client client.Client,
	recorder record.EventRecorder,
	statusClient *fullnode.StatusClient,
	cache *cosmos.CacheController,
	missingVolSnapCRD bool,
) *ScheduledVolumeSnapshotReconciler

func (*ScheduledVolumeSnapshotReconciler) Reconcile

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

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

func (*ScheduledVolumeSnapshotReconciler) SetupWithManager

func (r *ScheduledVolumeSnapshotReconciler) SetupWithManager(_ context.Context, mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type SelfHealingReconciler

type SelfHealingReconciler struct {
	client.Client
	// contains filtered or unexported fields
}

SelfHealingReconciler reconciles the self healing portion of a CosmosFullNode object

func NewSelfHealing

func NewSelfHealing(
	client client.Client,
	recorder record.EventRecorder,
	statusClient *fullnode.StatusClient,
	httpClient *http.Client,
	cacheController *cosmos.CacheController,
) *SelfHealingReconciler

func (*SelfHealingReconciler) Reconcile

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

Reconcile reconciles only the self-healing spec in CosmosFullNode. If changes needed, this controller updates a CosmosFullNode status subresource thus triggering another reconcile loop. The CosmosFullNode uses the status object to reconcile its state.

func (*SelfHealingReconciler) SetupWithManager

func (r *SelfHealingReconciler) SetupWithManager(_ context.Context, mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type StatefulJobReconciler

type StatefulJobReconciler struct {
	client.Client
	// contains filtered or unexported fields
}

StatefulJobReconciler reconciles a StatefulJob object.

func NewStatefulJob

func NewStatefulJob(client client.Client, recorder record.EventRecorder, missingVolSnapCRD bool) *StatefulJobReconciler

NewStatefulJob returns a valid controller. If missingVolSnapCRD is true, the controller errors on every reconcile loop and will not function.

func (*StatefulJobReconciler) Reconcile

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

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.13.0/pkg/reconcile

func (*StatefulJobReconciler) SetupWithManager

func (r *StatefulJobReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager. IndexVolumeSnapshots should be called first.