filter

Documentation

Index

• type FilterOp
  • func New(expr expr.Expr, proc *process.Process) *FilterOp
  • func (o *FilterOp) AddCtrlConsumer(_ ...int32)
  • func (o *FilterOp) AddMessageConsumer(_ ...int32)
  • func (o *FilterOp) Exec(msg *pipeline.Message) ([]*pipeline.Message, int, error)
  • func (o *FilterOp) Free() error
  • func (o *FilterOp) GetExecFunc() func(*pipeline.Message) ([]*pipeline.Message, int, error)
  • func (o *FilterOp) Specialize() error
  • func (o *FilterOp) String() string

Types

type FilterOp

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

func New

func New(expr expr.Expr, proc *process.Process) *FilterOp

func (*FilterOp) AddCtrlConsumer

func (o *FilterOp) AddCtrlConsumer(_ ...int32)

func (*FilterOp) AddMessageConsumer

func (o *FilterOp) AddMessageConsumer(_ ...int32)

func (*FilterOp) Exec

func (o *FilterOp) Exec(msg *pipeline.Message) ([]*pipeline.Message, int, error)

func (*FilterOp) Free

func (o *FilterOp) Free() error

func (*FilterOp) GetExecFunc

func (o *FilterOp) GetExecFunc() func(*pipeline.Message) ([]*pipeline.Message, int, error)

func (*FilterOp) Specialize

func (o *FilterOp) Specialize() error

func (*FilterOp) String

func (o *FilterOp) String() string