Struct ConfigInput

config.go:37–44

The configuration for the topology is parsed from TOML format. Each of Input, Filter, Output have a separate section (table) in the file containing a key called "Name" that specifies which component will be used in the pipeline, plus a couple of other generic keys. Then, there are sub-tables called

// ConfigInput specifies the configuration for the input component.
type ConfigInput struct {
	Name          string
	ChanSize      int // ChanSize represents the size of the channel to send records from the input to the filters, the default value is 1024
	DecodedConfig interface{}

	Config *toml.Primitive
	desc   *InputDesc
}

// ConfigFilterChain specifies the configuration for the whole fitler chain.
type ConfigFilterChain struct {