control

Documentation

Index

• Constants
• 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) AddPipelines(cfg []pipeline.Config)
  • func (c *PipelineConfig) DeepCopy() *PipelineConfig
  • func (c *PipelineConfig) RemovePipelines(cfg []pipeline.Config)
  • func (c *PipelineConfig) Validate() error
  • func (c *PipelineConfig) ValidateUniquePipeName() error

Constants

const HandleCurrentPipelines = "/api/v1/controller/pipelines"

Variables

var (
	ErrPipeNameUniq  = errors.New("pipeline name is duplicated")
	ErrIgnoreAllFile = errors.New("ignore all the file")
)

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) AddPipelines

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

func (*PipelineConfig) DeepCopy

func (c *PipelineConfig) DeepCopy() *PipelineConfig

func (*PipelineConfig) RemovePipelines

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

func (*PipelineConfig) Validate

func (c *PipelineConfig) Validate() error

func (*PipelineConfig) ValidateUniquePipeName

func (c *PipelineConfig) ValidateUniquePipeName() error