Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewPipeline ¶
Create a new pipeline with steps contained in the configuration.
Types ¶
type Monitor ¶
type Monitor struct {
// contains filtered or unexported fields
}
Collection of Prometheus metrics to monitor scheduler pipeline
func NewSchedulerMonitor ¶
func NewSchedulerMonitor(registry *monitoring.Registry) Monitor
Create a new scheduler monitor and register the necessary Prometheus metrics.
type StepMonitor ¶
type StepMonitor struct { // The wrapped scheduler step to monitor. Step plugins.Step // contains filtered or unexported fields }
Wraps a scheduler step to monitor its execution.
func (*StepMonitor) GetName ¶
func (s *StepMonitor) GetName() string
Get the name of the wrapped step.
type StepValidator ¶
type StepValidator struct { // The wrapped step to validate. Step plugins.Step // By default, we execute all validations. However, through the config, // we can also disable some validations if necessary. DisabledValidations disabledValidations }
Wrapper for scheduler steps that validates them before/after execution.
func (*StepValidator) GetName ¶
func (s *StepValidator) GetName() string
Get the name of the wrapped step.
Click to show internal directories.
Click to hide internal directories.