fluxmonitorv2

Documentation

Index

• func ValidatedFluxMonitorSpec(ts string) (job.SpecDB, error)
• type FluxMonitorDelegate
  • func NewFluxMonitorDelegate(pipelineRunner pipeline.Runner, db *gorm.DB) *FluxMonitorDelegate
  • func (d *FluxMonitorDelegate) JobType() job.Type
  • func (d *FluxMonitorDelegate) ServicesForSpec(spec job.SpecDB) (services []job.Service, err error)

Functions

func ValidatedFluxMonitorSpec

func ValidatedFluxMonitorSpec(ts string) (job.SpecDB, error)

Types

type FluxMonitorDelegate

type FluxMonitorDelegate struct {
	// contains filtered or unexported fields
}

func NewFluxMonitorDelegate

func NewFluxMonitorDelegate(pipelineRunner pipeline.Runner, db *gorm.DB) *FluxMonitorDelegate

func (*FluxMonitorDelegate) JobType

func (d *FluxMonitorDelegate) JobType() job.Type

func (*FluxMonitorDelegate) ServicesForSpec

func (d *FluxMonitorDelegate) ServicesForSpec(spec job.SpecDB) (services []job.Service, err error)