outputs

type BaseOutput struct {
}

type Initializer func() Output

type Meta map[string]string

type Option func(*OutputOptions) error

type Output interface {
	// initialize the output
	Init(context.Context, string, map[string]any, ...Option) error
	// validate the config
	Validate(map[string]any) error
	// update the config
	Update(context.Context, map[string]any) error
	// update a processor
	UpdateProcessor(string, map[string]any) error
	// write a protobuf message to the output
	Write(context.Context, proto.Message, Meta)
	// write an event message to the output
	WriteEvent(context.Context, *formatters.EventMsg)
	// close the output
	Close() error
	// return a string representation of the output
	String() string
}

type OutputOptions struct {
	Name        string
	ClusterName string
	Logger      *log.Logger
	Registry    *prometheus.Registry
	Store       store.Store[any]
}

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