controllers

Documentation

Index

• type DestinationReconciler
  • func (r *DestinationReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *DestinationReconciler) SetupWithManager(mgr ctrl.Manager) error
• type PromiseFetcher
• type PromiseReconciler
  • func (r *PromiseReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *PromiseReconciler) SetupWithManager(mgr ctrl.Manager) error
• type PromiseReleaseReconciler
  • func (r *PromiseReleaseReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *PromiseReleaseReconciler) SetupWithManager(mgr ctrl.Manager) error
• type Scheduler
  • func (s *Scheduler) ReconcileDestination() error
  • func (s *Scheduler) ReconcileWork(work *platformv1alpha1.Work) ([]string, error)
  • func (s *Scheduler) UpdateWorkPlacement(workloadGroup platformv1alpha1.WorkloadGroup, work *platformv1alpha1.Work, ...) (bool, error)
• type StateStore
• type WorkPlacementReconciler
  • func (r *WorkPlacementReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *WorkPlacementReconciler) SetupWithManager(mgr ctrl.Manager) error
• type WorkReconciler
  • func (r *WorkReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *WorkReconciler) SetupWithManager(mgr ctrl.Manager) error

Types

type DestinationReconciler

type DestinationReconciler struct {
	Client    client.Client
	Log       logr.Logger
	Scheduler *Scheduler
}

DestinationReconciler reconciles a Destination object

func (*DestinationReconciler) Reconcile

func (r *DestinationReconciler) 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 destination closer to the desired state. For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.11.0/pkg/reconcile

func (*DestinationReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type PromiseFetcher

type PromiseFetcher interface {
	FromURL(string) (*v1alpha1.Promise, error)
}

type PromiseReconciler

type PromiseReconciler struct {
	Client                    client.Client
	ApiextensionsClient       *clientset.Clientset
	Log                       logr.Logger
	Manager                   ctrl.Manager
	StartedDynamicControllers map[string]*dynamicResourceRequestController
	RestartManager            func()
}

PromiseReconciler reconciles a Promise object

func (*PromiseReconciler) Reconcile

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

func (*PromiseReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type PromiseReleaseReconciler

type PromiseReleaseReconciler struct {
	client.Client
	Scheme         *runtime.Scheme
	Log            logr.Logger
	PromiseFetcher PromiseFetcher
}

PromiseReleaseReconciler reconciles a PromiseRelease object

func (*PromiseReleaseReconciler) Reconcile

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

func (*PromiseReleaseReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type Scheduler

type Scheduler struct {
	Client client.Client
	Log    logr.Logger
}

func (*Scheduler) ReconcileDestination

func (s *Scheduler) ReconcileDestination() error

Only reconciles Works that are from a Promise Dependency

func (*Scheduler) ReconcileWork

func (s *Scheduler) ReconcileWork(work *platformv1alpha1.Work) ([]string, error)

func (*Scheduler) UpdateWorkPlacement

func (s *Scheduler) UpdateWorkPlacement(workloadGroup platformv1alpha1.WorkloadGroup, work *platformv1alpha1.Work, workPlacement *platformv1alpha1.WorkPlacement) (bool, error)

type StateStore

type StateStore interface {
	client.Object
	GetSecretRef() *v1.SecretReference
}

type WorkPlacementReconciler

type WorkPlacementReconciler struct {
	Client client.Client
	Log    logr.Logger
}

WorkPlacementReconciler reconciles a WorkPlacement object

func (*WorkPlacementReconciler) Reconcile

func (r *WorkPlacementReconciler) 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 destination closer to the desired state. For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.11.0/pkg/reconcile

func (*WorkPlacementReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type WorkReconciler

type WorkReconciler struct {
	Client    client.Client
	Log       logr.Logger
	Scheduler *Scheduler
	Disabled  bool
}

WorkReconciler reconciles a Work object

func (*WorkReconciler) Reconcile

func (r *WorkReconciler) 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. TODO(user): Modify the Reconcile function to compare the state specified by the Work object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

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

func (*WorkReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.