pipeline

package

v0.0.0-...-83adff0 Latest Latest Go to latest Published: Jul 6, 2020 License: GPL-3.0 Imports: 26 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/tsrmtrue/asiotestrobot

Links

Open Source Insights

Documentation ¶

Index ¶

func DecodeInputConfig(name string, md toml.MetaData, primValue toml.Primitive) (c interface{}, err error)
func DecodeOutputConfig(name string, md toml.MetaData, primValue toml.Primitive) (c interface{}, err error)
func DecodeProcessorConfig(name string, md toml.MetaData, primValue toml.Primitive) (c interface{}, err error)
func GetInputConfigDecodeFunc(name string) (f configDecodeFunc, err error)
func GetOutputConfigDecodeFunc(name string) (f configDecodeFunc, err error)
func GetProcessorConfigDecodeFunc(name string) (f configDecodeFunc, err error)
func InitPipelineMng(ctx context.Context) (err error)
func RegisterInputConfigDecodeFunc(name string, f configDecodeFunc)
func RegisterOutputConfigDecodeFunc(name string, f configDecodeFunc)
func RegisterProcessorConfigDecodeFunc(name string, f configDecodeFunc)
func StartOutput(ctx context.Context, md toml.MetaData, config ConfigItem) (o output.Output, err error)
func StartOutputs(ctx context.Context, md toml.MetaData, config map[string]ConfigItem) (err error)
type Config
type ConfigItem
type Pipeline
- func (pipe *Pipeline) Stop()
type PipelineMng

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func DecodeInputConfig ¶

func DecodeInputConfig(name string, md toml.MetaData, primValue toml.Primitive) (c interface{}, err error)

func DecodeOutputConfig ¶

func DecodeOutputConfig(name string, md toml.MetaData, primValue toml.Primitive) (c interface{}, err error)

func DecodeProcessorConfig ¶

func DecodeProcessorConfig(name string, md toml.MetaData, primValue toml.Primitive) (c interface{}, err error)

func GetInputConfigDecodeFunc ¶

func GetInputConfigDecodeFunc(name string) (f configDecodeFunc, err error)

func GetOutputConfigDecodeFunc ¶

func GetOutputConfigDecodeFunc(name string) (f configDecodeFunc, err error)

func GetProcessorConfigDecodeFunc ¶

func GetProcessorConfigDecodeFunc(name string) (f configDecodeFunc, err error)

func InitPipelineMng ¶

func InitPipelineMng(ctx context.Context) (err error)

func RegisterInputConfigDecodeFunc ¶

func RegisterInputConfigDecodeFunc(name string, f configDecodeFunc)

func RegisterOutputConfigDecodeFunc ¶

func RegisterOutputConfigDecodeFunc(name string, f configDecodeFunc)

func RegisterProcessorConfigDecodeFunc ¶

func RegisterProcessorConfigDecodeFunc(name string, f configDecodeFunc)

func StartOutput ¶

func StartOutput(ctx context.Context, md toml.MetaData, config ConfigItem) (o output.Output, err error)

func StartOutputs ¶

func StartOutputs(ctx context.Context, md toml.MetaData, config map[string]ConfigItem) (err error)

Types ¶

type Config ¶

type Config struct {
	Input     ConfigItem            `toml:"input"`
	Processor map[string]ConfigItem `toml:"processor"`
	Output    map[string]ConfigItem `toml:"output"`
}

type ConfigItem ¶

type ConfigItem struct {
	Name   string         `toml:"type"`
	Config toml.Primitive `toml:"config"`
}

type Pipeline ¶

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

func (*Pipeline) Stop ¶

func (pipe *Pipeline) Stop()

type PipelineMng ¶

type PipelineMng struct {
	Pipelines     map[string]*Pipeline
	PipelinesLock sync.RWMutex
	// contains filtered or unexported fields
}

var PipelineManagement *PipelineMng

func (*PipelineMng) GetPipeline ¶

func (m *PipelineMng) GetPipeline(configPath string) *Pipeline

func (*PipelineMng) PipelineExisted ¶

func (m *PipelineMng) PipelineExisted(configPath string) bool

func (*PipelineMng) RegisterHostFileCollector ¶

func (m *PipelineMng) RegisterHostFileCollector(configPath string, p *Pipeline)

func (*PipelineMng) StartDefaultOutput ¶

func (m *PipelineMng) StartDefaultOutput() (err error)

func (*PipelineMng) StartDefaultPipeline ¶

func (m *PipelineMng) StartDefaultPipeline()

func (*PipelineMng) StartPipeline ¶

func (m *PipelineMng) StartPipeline(ctx context.Context, configPath string, config string)

func (*PipelineMng) UnRegisterHostFileCollector ¶

func (m *PipelineMng) UnRegisterHostFileCollector(configPath string)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
dockerlogcollector
hostlogcollector

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