pipeline

package
v0.0.0-...-ab4a820 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 5, 2020 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL