Versions in this module Expand all Collapse all v0 v0.0.3 Feb 4, 2021 v0.0.2 Feb 3, 2021 Changes in this version + func CreatePipelineConfig(cfg *pipeline.PipelineConfig) error + func DeletePipelineConfig(id string) error + func GetPipelineConfig(id string) (*pipeline.PipelineConfig, error) + func GetPipelineList(from, size int) (int, []pipeline.PipelineConfig, error) + func UpdatePipelineConfig(id string, cfg *pipeline.PipelineConfig) error + type API struct + func (handler API) Init() + type PipeModule struct + func (module PipeModule) Name() string + func (module PipeModule) Setup(cfg *Config) + func (module PipeModule) Start() error + func (module PipeModule) Stop() error + type PipeRunner struct + func (pipe *PipeRunner) Pause() + func (pipe *PipeRunner) Resume() + func (pipe *PipeRunner) Start(config PipeRunnerConfig) + func (pipe *PipeRunner) Stop() + func (pipe *PipeRunner) Update(config PipeRunnerConfig) + type PipeRunnerConfig struct + Enabled bool + InputQueue string + MaxGoRoutine int + Name string + PipelineID string + Schedule string + ThresholdInMs int + TimeoutInMs int