pipeline

Documentation

Index

• 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
  • func (handler API) Init()
• type PipeModule
  • func (module PipeModule) Name() string
  • func (module PipeModule) Setup(cfg *Config)
  • func (module PipeModule) Start() error
  • func (module PipeModule) Stop() error
• type PipeRunner
  • 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

Functions

func CreatePipelineConfig

func CreatePipelineConfig(cfg *pipeline.PipelineConfig) error

func DeletePipelineConfig

func DeletePipelineConfig(id string) error

func GetPipelineConfig

func GetPipelineConfig(id string) (*pipeline.PipelineConfig, error)

func GetPipelineList

func GetPipelineList(from, size int) (int, []pipeline.PipelineConfig, error)

func UpdatePipelineConfig

func UpdatePipelineConfig(id string, cfg *pipeline.PipelineConfig) error

Types

type API

type API struct {
	api.Handler
}

API namespace

func (API) Init

func (handler API) Init()

type PipeModule

type PipeModule struct {
}

func (PipeModule) Name

func (module PipeModule) Name() string

func (PipeModule) Setup

func (module PipeModule) Setup(cfg *Config)

func (PipeModule) Start

func (module PipeModule) Start() error

func (PipeModule) Stop

func (module PipeModule) Stop() error

type PipeRunner

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

func (*PipeRunner) Pause

func (pipe *PipeRunner) Pause()

func (*PipeRunner) Resume

func (pipe *PipeRunner) Resume()

func (*PipeRunner) Start

func (pipe *PipeRunner) Start(config PipeRunnerConfig)

func (*PipeRunner) Stop

func (pipe *PipeRunner) Stop()

func (*PipeRunner) Update

func (pipe *PipeRunner) Update(config PipeRunnerConfig)

type PipeRunnerConfig

type PipeRunnerConfig struct {
	Name string `json:"name,omitempty" config:"name"`

	Enabled bool `json:"enabled,omitempty" config:"enabled"`

	MaxGoRoutine int `config:"max_go_routine"`

	//Speed Control
	ThresholdInMs int `config:"threshold_in_ms"`

	//Timeout Control
	TimeoutInMs int `config:"timeout_in_ms"`

	PipelineID string `config:"pipeline_id"`

	InputQueue string `config:"input_queue"`

	Schedule string `config:"schedule"`
	// contains filtered or unexported fields
}

PipeRunnerConfig defines module related configs