Documentation
¶
Index ¶
- func Cleanup(ctx context.Context, client client.Client, conf conf.Config) error
- type DecisionPipelineController
- func (c *DecisionPipelineController) InitPipeline(ctx context.Context, p v1alpha1.Pipeline) (lib.Pipeline[api.ExternalSchedulerRequest], error)
- func (c *DecisionPipelineController) PipelineType() v1alpha1.PipelineType
- func (c *DecisionPipelineController) ProcessNewDecisionFromAPI(ctx context.Context, decision *v1alpha1.Decision) error
- func (c *DecisionPipelineController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
- func (c *DecisionPipelineController) SetupWithManager(mgr manager.Manager, mcl *multicluster.Client) error
- type NovaStep
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
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, p v1alpha1.Pipeline, ) (lib.Pipeline[api.ExternalSchedulerRequest], error)
The base controller will delegate the pipeline creation down to this method.
func (*DecisionPipelineController) PipelineType ¶
func (c *DecisionPipelineController) PipelineType() v1alpha1.PipelineType
The type of pipeline this controller manages.
func (*DecisionPipelineController) ProcessNewDecisionFromAPI ¶
func (c *DecisionPipelineController) ProcessNewDecisionFromAPI(ctx context.Context, decision *v1alpha1.Decision) error
Process the decision from the API. Should create and return the updated decision.
func (*DecisionPipelineController) Reconcile ¶
func (c *DecisionPipelineController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Callback executed when kubernetes asks to reconcile a decision resource.
func (*DecisionPipelineController) SetupWithManager ¶
func (c *DecisionPipelineController) SetupWithManager(mgr manager.Manager, mcl *multicluster.Client) error
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.