Documentation
¶
Index ¶
- func CleanupCinderDecisionsRegularly(ctx context.Context, client client.Client, conf conf.Config)
- type CinderStep
- type DecisionPipelineController
- func (c *DecisionPipelineController) InitPipeline(ctx context.Context, steps []v1alpha1.Step) (lib.Pipeline[api.ExternalSchedulerRequest], error)
- func (c *DecisionPipelineController) ProcessNewDecisionFromAPI(ctx context.Context, decision *v1alpha1.Decision) (*v1alpha1.Decision, error)
- func (c *DecisionPipelineController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
- func (c *DecisionPipelineController) SetupWithManager(mgr manager.Manager) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type CinderStep ¶
type CinderStep = lib.Step[api.ExternalSchedulerRequest]
type DecisionPipelineController ¶
type DecisionPipelineController struct {
// Toolbox shared between all pipeline controllers.
lib.BasePipelineController[lib.Pipeline[api.ExternalSchedulerRequest]]
// Monitor to pass down to all pipelines.
Monitor lib.PipelineMonitor
// Config for the scheduling operator.
Conf conf.Config
// contains filtered or unexported fields
}
The decision pipeline controller takes decision resources containing a placement request spec and runs the scheduling pipeline to make a decision. This decision is then written back to the decision resource status.
Additionally, the controller watches for pipeline and step changes to reconfigure the pipelines as needed.
func (*DecisionPipelineController) InitPipeline ¶
func (c *DecisionPipelineController) InitPipeline( ctx context.Context, steps []v1alpha1.Step, ) (lib.Pipeline[api.ExternalSchedulerRequest], error)
The base controller will delegate the pipeline creation down to this method.
func (*DecisionPipelineController) ProcessNewDecisionFromAPI ¶
func (c *DecisionPipelineController) ProcessNewDecisionFromAPI(ctx context.Context, decision *v1alpha1.Decision) (*v1alpha1.Decision, error)
Process the decision from the API. Should create and return the updated decision.
func (*DecisionPipelineController) SetupWithManager ¶
func (c *DecisionPipelineController) SetupWithManager(mgr manager.Manager) error
Source Files
Click to show internal directories.
Click to hide internal directories.