config

Documentation

Index

• func ApplyConfig(cfg *PipeConfig, builder *graph.Builder)
• type Connections
• type PipeConfig
  • func ReadConfig(in io.Reader) (PipeConfig, error)

Functions

func ApplyConfig

func ApplyConfig(cfg *PipeConfig, builder *graph.Builder)

Types

type Connections

type Connections map[string][]string

Connections key: name of the source node. Value: array of destination nodes.

type PipeConfig

type PipeConfig struct {
	Http    []stage.Http     `hcl:"http,block"`
	StdOut  []stage.Stdout   `hcl:"stdout,block"`
	Deleter []stage.Deleter  `hcl:"deleter,block"`
	SysMon  []system.Monitor `hcl:"sysmon,block"`
	Connect Connections      `hcl:"connect"`
}

func ReadConfig

func ReadConfig(in io.Reader) (PipeConfig, error)