pipe

type ConfigFileStruct struct {
	LogLevel   string       `yaml:"log-level,omitempty" json:"log-level,omitempty"`
	Parameters []StageParam `yaml:"parameters,omitempty" json:"parameters,omitempty"`
	Profile    *Profile     `yaml:"profile,omitempty" json:"profile,omitempty"`
	Health     *Health      `yaml:"health,omitempty" json:"health,omitempty"`
}

type Health struct {
	Port int `yaml:"port,omitempty" json:"port,omitempty"`
}

type Ingest struct {
	Type  string              `yaml:"type" json:"type"`
	Kafka *ingest.KafkaConfig `yaml:"kafka,omitempty" json:"kafka,omitempty"`
}

type Profile struct {
	Port int
}

type StageParam struct {
	Name      string     `yaml:"name" json:"name"`
	Ingest    *Ingest    `yaml:"ingest,omitempty" json:"ingest,omitempty"`
	Transform *Transform `yaml:"transform,omitempty" json:"transform,omitempty"`
	Write     *Write     `yaml:"write,omitempty" json:"write,omitempty"`
}

type Transform struct {
	Type    string                   `yaml:"type" json:"type"`
	Network *transform.NetworkConfig `yaml:"network,omitempty" json:"network,omitempty"`
}

type Write struct {
	Type string            `yaml:"type" json:"type"`
	Loki *write.LokiConfig `yaml:"loki,omitempty" json:"loki,omitempty"`
}