config

type App struct {
	Logger string `yaml:"logger"`
}

type Component struct {
	Plugin      string                 `yaml:"plugin"`
	Concurrency int                    `yaml:"concurrency"`
	Config      map[string]interface{} `yaml:"config"`
}

type Components struct {
	Inputs     Inputs
	Processors Processors
	Outputs    Outputs
}

type Config struct {
	App        App
	Components Components
	Pipelines  Pipelines
	Logger     zap.SugaredLogger
}

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

type Input struct {
	Component `yaml:",inline" mapstructure:",squash"`
}

type Inputs struct {
	Inputs map[string]*Input `yaml:"inputs"`
}

type Node struct {
	Async bool             `yaml:"async"`
	Next  map[string]*Node `yaml:",inline"`
}

type Output struct {
	Component `yaml:",inline" mapstructure:",squash"`
}

type Outputs struct {
	Outputs map[string]*Output `yaml:"outputs"`
}

type Pipeline struct {
	Concurrency int              `yaml:"concurrency"`
	Pipeline    map[string]*Node `yaml:"pipeline"`
}

type Pipelines struct {
	Pipelines map[string]*Pipeline `yaml:"pipelines"`
	Hash      string
}

type Processor struct {
	Component `yaml:",inline" mapstructure:",squash"`
}

type Processors struct {
	Processors map[string]*Processor `yaml:"processors"`
}

type WithDefaults interface {
	ApplyDefault() error
}