filter

Documentation

Index

• Constants
• Variables
• type BexprFilter
  • func (b *BexprFilter) Process(ctx context.Context, event *optimusv1.LogEvent) (*optimusv1.LogEvent, error)
  • func (b *BexprFilter) Setup() error
• type Filter
  • func New(id, kind string, bufferSize int, subscriptions []string, impl FilterProcessor) (*Filter, error)
  • func (f *Filter) Init() error
  • func (f *Filter) Process(ctx context.Context) error
• type FilterProcessor
  • func HclImpl(kind string, ctx *hcl.EvalContext, body hcl.Body) (FilterProcessor, hcl.Diagnostics)
• type QuaminaFilter
  • func (q *QuaminaFilter) Process(ctx context.Context, event *optimusv1.LogEvent) (*optimusv1.LogEvent, error)
  • func (q *QuaminaFilter) Setup() error

Constants

const (
	KindBexpr   = "bexpr"
	KindQuamina = "quamina"
)

Variables

var (
	ErrInvalidFilter = errors.New("invalid filter")
)

Types

type BexprFilter

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

func (*BexprFilter) Process

func (b *BexprFilter) Process(ctx context.Context, event *optimusv1.LogEvent) (*optimusv1.LogEvent, error)

func (*BexprFilter) Setup

func (b *BexprFilter) Setup() error

type Filter

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

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

func New

func New(id, kind string, bufferSize int, subscriptions []string, impl FilterProcessor) (*Filter, error)

func (*Filter) Init

func (f *Filter) Init() error

func (*Filter) Process

func (f *Filter) Process(ctx context.Context) error

type FilterProcessor

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

func HclImpl

func HclImpl(kind string, ctx *hcl.EvalContext, body hcl.Body) (FilterProcessor, hcl.Diagnostics)

type QuaminaFilter

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

func (*QuaminaFilter) Process

func (q *QuaminaFilter) Process(ctx context.Context, event *optimusv1.LogEvent) (*optimusv1.LogEvent, error)

func (*QuaminaFilter) Setup

func (q *QuaminaFilter) Setup() error