inputs

type BaseInput struct {
}

type Initializer func() Input

type Input interface {
	// Start initializes the input and starts it.
	Start(context.Context, string, map[string]any, ...Option) error
	// Validate validates the input configuration.
	Validate(map[string]any) error
	// Update updates the input configuration in place for
	// a running input.
	Update(map[string]any) error
	// UpdateProcessor updates the named processor configuration
	// for a running input.
	// if the processor is not used by the Input, it will be ignored.
	UpdateProcessor(string, map[string]any) error
	// Close stops the input.
	Close() error
}

type InputOptions struct {
	Logger   *log.Logger
	Outputs  map[string]outputs.Output
	Name     string
	Store    store.Store[any]
	Pipeline chan *pipeline.Msg
}

type Option func(*InputOptions) error

type PipeMessage interface {
	Proto() proto.Message
	Meta() outputs.Meta
	Events() []*formatters.EventMsg
	Outputs() map[string]struct{}
}