Documentation
¶
Index ¶
Constants ¶
View Source
const (
TopicFinished = "cortex/scheduler/nova/pipeline/finished"
)
Variables ¶
This section is empty.
Functions ¶
func NewNovaPipelineConsumer ¶
func NewNovaPipelineConsumer() *novaPipelineConsumer
func NewPipeline ¶
func NewPipeline( config conf.NovaSchedulerPipelineConfig, db db.DB, monitor scheduling.PipelineMonitor, mqttClient mqtt.Client, ) scheduling.Pipeline[api.PipelineRequest]
Create a new Nova scheduler pipeline.
Types ¶
type NovaStep ¶
type NovaStep = scheduling.Step[api.PipelineRequest]
type StepScoper ¶
type StepScoper struct {
// The wrapped step to scope.
Step scheduling.Step[api.PipelineRequest]
// 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.PipelineRequest) (*scheduling.StepResult, error)
Run the step and sRun(traceLog *slog.Logger, request api.ExternalSchedulerRequest) (*scheduling.StepResult, error)
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.