limit

Documentation

Index

• type LimitOp
  • func New(limit uint64, producerNum int) *LimitOp
  • func (o *LimitOp) AddCtrlConsumer(ctrls ...int32)
  • func (o *LimitOp) AddMessageConsumer(consumers ...int32)
  • func (o *LimitOp) Exec(msg *pipeline.Message) ([]*pipeline.Message, int, error)
  • func (o *LimitOp) Free() error
  • func (o *LimitOp) GetExecFunc() func(*pipeline.Message) ([]*pipeline.Message, int, error)
  • func (o *LimitOp) Specialize() error
  • func (o *LimitOp) String() string

Types

type LimitOp

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

func New

func New(limit uint64, producerNum int) *LimitOp

func (*LimitOp) AddCtrlConsumer

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

func (*LimitOp) AddMessageConsumer

func (o *LimitOp) AddMessageConsumer(consumers ...int32)

func (*LimitOp) Exec

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

func (*LimitOp) Free

func (o *LimitOp) Free() error

func (*LimitOp) GetExecFunc

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

func (*LimitOp) Specialize

func (o *LimitOp) Specialize() error

func (*LimitOp) String

func (o *LimitOp) String() string