emit

Documentation

Index

• type EmitOp
  • func New(emit func(*batch.Batch) error) *EmitOp
  • func (o *EmitOp) AddCtrlConsumer(ctrls ...int32)
  • func (o *EmitOp) AddMessageConsumer(_ ...int32)
  • func (o *EmitOp) Exec(msg *pipeline.Message) ([]*pipeline.Message, int, error)
  • func (o *EmitOp) Free() error
  • func (o *EmitOp) GetExecFunc() func(*pipeline.Message) ([]*pipeline.Message, int, error)
  • func (o *EmitOp) Specialize() error
  • func (o *EmitOp) String() string

Types

type EmitOp

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

func New

func New(emit func(*batch.Batch) error) *EmitOp

func (*EmitOp) AddCtrlConsumer

func (o *EmitOp) AddCtrlConsumer(ctrls ...int32)

func (*EmitOp) AddMessageConsumer

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

func (*EmitOp) Exec

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

func (*EmitOp) Free

func (o *EmitOp) Free() error

func (*EmitOp) GetExecFunc

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

func (*EmitOp) Specialize

func (o *EmitOp) Specialize() error

func (*EmitOp) String

func (o *EmitOp) String() string