config

Documentation

Index

• func AddCache(cType string, conf *config.Type) error
• func AddCondition(cType string, conf *config.Type) error
• func AddInput(cType string, conf *config.Type) error
• func AddOutput(cType string, conf *config.Type) error
• func AddProcessor(cType string, conf *config.Type) error
• func AddRatelimit(cType string, conf *config.Type) error
• func Marshal(conf config.Type) ([]byte, error)
• func New() config.Type
• func Unmarshal(confStr string) (config.Type, error)

Functions

func AddCache

func AddCache(cType string, conf *config.Type) error

AddCache inserts a default cache of a type to an existing config.

func AddCondition

func AddCondition(cType string, conf *config.Type) error

AddCondition inserts a filter_parts processor with a default condition of a type to an existing config.

func AddInput

func AddInput(cType string, conf *config.Type) error

AddInput inserts a default input of a type to an existing config.

func AddOutput

func AddOutput(cType string, conf *config.Type) error

AddOutput inserts a default output of a type to an existing config.

func AddProcessor

func AddProcessor(cType string, conf *config.Type) error

AddProcessor inserts a default processor of a type to an existing config.

func AddRatelimit

func AddRatelimit(cType string, conf *config.Type) error

AddRatelimit inserts a default rate limit of a type to an existing config.

func Marshal

func Marshal(conf config.Type) ([]byte, error)

Marshal a config struct into a subset of fields relevant to the lab environment.

func New

func New() config.Type

New creates a fresh Benthos config with defaults that suit the lab environment.

func Unmarshal

func Unmarshal(confStr string) (config.Type, error)

Unmarshal a config string into a config struct with defaults that suit the lab environment.