filter

type BexprFilter struct {
	Expression string `hcl:"expression"`
	// contains filtered or unexported fields
}

type Filter struct {
	ID         string
	Broker     pubsub.Broker
	Subscriber pubsub.Subscriber

	Kind          string
	Subscriptions []string
	BufferSize    int
	// contains filtered or unexported fields
}

type FilterProcessor interface {
	Process(context.Context, *optimusv1.LogEvent) (*optimusv1.LogEvent, error)
	Setup() error
}

type QuaminaFilter struct {
	Patterns map[string]string `hcl:"patterns"`
	// contains filtered or unexported fields
}