Documentation
¶
Index ¶
Constants ¶
View Source
const (
TopicFinished = "cortex/scheduler/cinder/pipeline/finished"
)
Variables ¶
This section is empty.
Functions ¶
func NewPipeline ¶
func NewPipeline( config conf.CinderSchedulerPipelineConfig, db db.DB, monitor scheduler.PipelineMonitor, mqttClient mqtt.Client, ) scheduler.Pipeline[api.ExternalSchedulerRequest]
Create a new Cinder scheduler pipeline.
Types ¶
type CinderStep ¶
type CinderStep = scheduler.Step[api.ExternalSchedulerRequest]
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.