control

Documentation

Index

• Variables
• type Controller
  • func NewController() *Controller
  • func (c *Controller) RetryNotRunningPipeline()
  • func (c *Controller) Start(config *PipelineConfig)
  • func (c *Controller) StartPipelines(configs []pipeline.Config)
  • func (c *Controller) StopPipelines(configs []pipeline.Config)
• type FileIgnore
• type PipelineConfig
  • func ReadPipelineConfig(path string, configType string, ignore FileIgnore) (*PipelineConfig, error)
  • func ReadPipelineConfigFromEnv(key string, _ FileIgnore) (*PipelineConfig, error)
  • func ReadPipelineConfigFromFile(path string, ignore FileIgnore) (*PipelineConfig, error)
  • func (c *PipelineConfig) AddPipeline(cfg pipeline.Config)
  • func (c *PipelineConfig) AddPipelines(cfg []pipeline.Config)
  • func (c *PipelineConfig) RemovePipelines(cfg []pipeline.Config)
• type PipelineRawConfig
  • func (pr *PipelineRawConfig) DeepCopy() (dest *PipelineRawConfig, err error)
  • func (pr *PipelineRawConfig) SetDefaults()
  • func (pr *PipelineRawConfig) ToConfig() (*PipelineConfig, error)
  • func (pr *PipelineRawConfig) Validate() error
  • func (pr *PipelineRawConfig) ValidateAndRemove() (*PipelineConfig, error)
  • func (pr *PipelineRawConfig) ValidateUniquePipeName() error

Variables

var (
	ErrPipeNameUniq = errors.New("pipeline name is duplicated")
)

Types

type Controller

type Controller struct {
	CurrentConfig *PipelineConfig
	// contains filtered or unexported fields
}

func NewController

func NewController() *Controller

func (*Controller) RetryNotRunningPipeline

func (c *Controller) RetryNotRunningPipeline()

func (*Controller) Start

func (c *Controller) Start(config *PipelineConfig)

func (*Controller) StartPipelines

func (c *Controller) StartPipelines(configs []pipeline.Config)

func (*Controller) StopPipelines

func (c *Controller) StopPipelines(configs []pipeline.Config)

type FileIgnore

type FileIgnore func(s os.FileInfo) bool

type PipelineConfig

type PipelineConfig struct {
	Pipelines []pipeline.Config `yaml:"pipelines" validate:"dive,required"`
}

func ReadPipelineConfig

func ReadPipelineConfig(path string, configType string, ignore FileIgnore) (*PipelineConfig, error)

func ReadPipelineConfigFromEnv

func ReadPipelineConfigFromEnv(key string, _ FileIgnore) (*PipelineConfig, error)

func ReadPipelineConfigFromFile

func ReadPipelineConfigFromFile(path string, ignore FileIgnore) (*PipelineConfig, error)

func (*PipelineConfig) AddPipeline

func (c *PipelineConfig) AddPipeline(cfg pipeline.Config)

func (*PipelineConfig) AddPipelines

func (c *PipelineConfig) AddPipelines(cfg []pipeline.Config)

func (*PipelineConfig) RemovePipelines

func (c *PipelineConfig) RemovePipelines(cfg []pipeline.Config)

type PipelineRawConfig

type PipelineRawConfig struct {
	Pipelines []pipeline.ConfigRaw `yaml:"pipelines" validate:"dive,required"`
}

func (*PipelineRawConfig) DeepCopy

func (pr *PipelineRawConfig) DeepCopy() (dest *PipelineRawConfig, err error)

func (*PipelineRawConfig) SetDefaults

func (pr *PipelineRawConfig) SetDefaults()

func (*PipelineRawConfig) ToConfig

func (pr *PipelineRawConfig) ToConfig() (*PipelineConfig, error)

func (*PipelineRawConfig) Validate

func (pr *PipelineRawConfig) Validate() error

func (*PipelineRawConfig) ValidateAndRemove

func (pr *PipelineRawConfig) ValidateAndRemove() (*PipelineConfig, error)

func (*PipelineRawConfig) ValidateUniquePipeName

func (pr *PipelineRawConfig) ValidateUniquePipeName() error