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 DynamicResourceRequestController
  • func (r *DynamicResourceRequestController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
• type Manager
• 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) ReconcileAllDependencyWorks() error
  • func (s *Scheduler) ReconcileWork(work *v1alpha1.Work) ([]string, 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
• type WorkScheduler

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 DynamicResourceRequestController

type DynamicResourceRequestController struct {
	//use same naming conventions as other controllers
	Client                      client.Client
	GVK                         *schema.GroupVersionKind
	Scheme                      *runtime.Scheme
	PromiseIdentifier           string
	ConfigurePipelines          []v1alpha1.Pipeline
	DeletePipelines             []v1alpha1.Pipeline
	Log                         logr.Logger
	UID                         string
	Enabled                     *bool
	CRD                         *apiextensionsv1.CustomResourceDefinition
	PromiseDestinationSelectors []v1alpha1.PromiseScheduling
	PromiseWorkflowSelectors    *v1alpha1.WorkloadGroupScheduling
	CanCreateResources          *bool
}

func (*DynamicResourceRequestController) Reconcile

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

type Manager

type Manager interface {
	manager.Manager
}

type PromiseReconciler

type PromiseReconciler struct {
	Scheme                    *runtime.Scheme
	Client                    client.Client
	ApiextensionsClient       apiextensionsv1cs.CustomResourceDefinitionsGetter
	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 v1alpha1.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) ReconcileAllDependencyWorks

func (s *Scheduler) ReconcileAllDependencyWorks() error

Reconciles all Works by scheduling each Work's WorkloadGroups to appropriate Destinations. Only reconciles Works that are from a Promise Dependency.

func (*Scheduler) ReconcileWork

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

Reconciles all WorkloadGroups in a Work by scheduling them to Destinations via Workplacements.

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 WorkScheduler
	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.

type WorkScheduler

type WorkScheduler interface {
	ReconcileWork(work *v1alpha1.Work) ([]string, error)
}