config

type Config struct {

	// DataDir          string // used to store data about positions.
	MetricsEnabled   bool
	LogLevel         slog.Level
	HttpInputEnabled bool
	ListenAddress    string

	Inputs          []*input.Input
	Filters         []*filter.Filter
	Destinations    []*destination.Destination
	Transformations []*transformation.Transformation
	// contains filtered or unexported fields
}

type ConfigOption func(*Config)

type HclConfig struct {
	DataDir        string `hcl:"data_dir,optional"`
	MetricsEnabled bool   `hcl:"metrics_enabled,optional"`
	LogLevel       string `hcl:"log_level,optional"`
	ListenAddress  string `hcl:"listen_address,optional"`
	// HttpInputEnabled bool
	Inputs          []HclConfigItem                  `hcl:"input,block"`
	Filters         []HclConfigItemWithSubscriptions `hcl:"filter,block"`
	Transformations []HclConfigItemWithSubscriptions `hcl:"transformation,block"`
	Destinations    []HclConfigItemWithSubscriptions `hcl:"destination,block"`
}

type HclConfigItem struct {
	Kind string   `hcl:"kind,label"`
	ID   string   `hcl:"id,label"`
	Body hcl.Body `hcl:",remain"`
}

type HclConfigItemWithSubscriptions struct {
	Kind          string   `hcl:"kind,label"`
	ID            string   `hcl:"id,label"`
	BufferSize    int      `hcl:"buffer_size,optional"`
	Subscriptions []string `hcl:"subscriptions"`
	Body          hcl.Body `hcl:",remain"`
}