Documentation
¶
Index ¶
Constants ¶
View Source
const (
TopicFinished = "cortex/scheduler/nova/pipeline/finished"
)
Variables ¶
This section is empty.
Functions ¶
func NewPipeline ¶
func NewPipeline( config conf.NovaSchedulerPipelineConfig, db db.DB, monitor scheduler.PipelineMonitor, mqttClient mqtt.Client, ) scheduler.Pipeline[api.ExternalSchedulerRequest]
Create a new Nova scheduler pipeline.
Types ¶
type StepScoper ¶
type StepScoper struct {
// The wrapped step to scope.
Step scheduler.Step[api.ExternalSchedulerRequest]
// The scope for this step.
Scope conf.NovaSchedulerStepScope
// The database to use for querying host capabilities.
DB db.DB
}
func (*StepScoper) GetAlias ¶
func (s *StepScoper) GetAlias() string
Get the alias of the wrapped step.
func (*StepScoper) GetName ¶
func (s *StepScoper) GetName() string
Get the name of the wrapped step.
func (*StepScoper) Run ¶
func (s *StepScoper) Run(traceLog *slog.Logger, request api.ExternalSchedulerRequest) (*scheduler.StepResult, error)
Run the step and sRun(traceLog *slog.Logger, request api.ExternalSchedulerRequest) (*scheduler.StepResult, error)
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.