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 lib.PipelineMonitor, mqttClient mqtt.Client, ) lib.Pipeline[api.PipelineRequest]
Create a new Cinder scheduler pipeline.
Types ¶
type CinderStep ¶
type CinderStep = lib.Step[api.PipelineRequest]
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.