config

type CodecConfig struct {
	CommonConfig
}

type CodecHandler func(ctx context.Context, raw ConfigRaw) (TypeCodecConfig, error)

type CommonConfig struct {
	Type     string `json:"type"`
	Disabled bool   `json:"disabled" yaml:"disabled"` // if set the input/output/filter will be disabled
}

type Config struct {
	InputRaw  []ConfigRaw `json:"input,omitempty" yaml:"input"`
	FilterRaw []ConfigRaw `json:"filter,omitempty" yaml:"filter"`
	OutputRaw []ConfigRaw `json:"output,omitempty" yaml:"output"`

	Event *logevent.Config `json:"event,omitempty" yaml:"event"`

	// channel size: chInFilter, chFilterOut, chOutDebug
	ChannelSize int `json:"chsize,omitempty" yaml:"chsize"`

	// worker number, defaults to 1
	Worker int `json:"worker,omitempty" yaml:"worker"`

	// enable debug channel, used for testing
	DebugChannel bool `json:"debugch,omitempty" yaml:"debugch"`
	// contains filtered or unexported fields
}

type ConfigRaw map[string]any

type Control interface {
	RequestPause(ctx context.Context) error
	RequestResume(ctx context.Context) error
	PauseSignal() <-chan struct{}
	ResumeSignal() <-chan struct{}
}

type DefaultCodec struct {
	CodecConfig
}

type FieldConfig struct {
	Key   string `yaml:"key"`
	Value string `yaml:"value"`
}

type FilterConfig struct {
	CommonConfig
	AddTags      []string      `yaml:"add_tag" json:"add_tag"`
	RemoveTags   []string      `yaml:"remove_tag" json:"remove_tag"`
	AddFields    []FieldConfig `yaml:"add_field" json:"add_field"`
	RemoveFields []string      `yaml:"remove_field" json:"remove_field"`
}

type FilterHandler func(ctx context.Context, raw ConfigRaw, control Control) (TypeFilterConfig, error)

type InputConfig struct {
	CommonConfig
	Codec TypeCodecConfig `json:"-"`
}

type InputHandler func(ctx context.Context, raw ConfigRaw, control Control) (TypeInputConfig, error)

type MsgChan chan logevent.LogEvent

type OutputConfig struct {
	CommonConfig
	Codec TypeCodecConfig `json:"-"` // name of codec to load
}

type OutputHandler func(ctx context.Context, raw ConfigRaw, control Control) (TypeOutputConfig, error)

type TypeCodecConfig interface {
	TypeCommonConfig
	// Decode - The codec’s decode method is where data coming in from an input is transformed into an event.
	//  'ok' returns a boolean indicating if an event was created and sent to a provided 'msgChan' channel
	//  'error' is returned in case of any failure handling input 'data', but 'ok' == false DOES NOT indicate an error
	Decode(ctx context.Context, data any, extra map[string]any, tags []string, msgChan chan<- logevent.LogEvent) (ok bool, err error)
	// DecodeEvent decodes 'data' to 'event' pointer, creating new current timestamp if IsZero
	//  'error' is returned in case of any failure handling input 'data'
	DecodeEvent(data []byte, event *logevent.LogEvent) error
	// Encode - The encode method takes an event and serializes it (encodes) into another format.
	//  'ok' returns a boolean indicating if an event was encoded and sent to a provided 'dataChan' channel
	//  'error' is returned in case of any failure encoding 'event', but 'ok' == false DOES NOT indicate an error
	Encode(ctx context.Context, event logevent.LogEvent, dataChan chan<- []byte) (ok bool, err error)
}

type TypeCommonConfig interface {
	GetType() string
}

type TypeFilterConfig interface {
	TypeCommonConfig
	Event(context.Context, logevent.LogEvent) (logevent.LogEvent, bool)
	CommonFilter(context.Context, logevent.LogEvent) logevent.LogEvent
}

type TypeInputConfig interface {
	TypeCommonConfig
	Start(ctx context.Context, msgChan chan<- logevent.LogEvent) (err error)
}

type TypeOutputConfig interface {
	TypeCommonConfig
	Output(ctx context.Context, event logevent.LogEvent) (err error)
}