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