top

Documentation

Index

• type TopOp
  • func New(attrs []plan.ScopeAttribute, order *plan.Order, proc *process.Process, ...) *TopOp
  • func (o *TopOp) AddCtrlConsumer(_ ...int32)
  • func (o *TopOp) AddMessageConsumer(_ ...int32)
  • func (o *TopOp) Exec(msg *pipeline.Message) ([]*pipeline.Message, int, error)
  • func (o *TopOp) Free() error
  • func (o *TopOp) GetExecFunc() func(*pipeline.Message) ([]*pipeline.Message, int, error)
  • func (o *TopOp) Len() int
  • func (o *TopOp) Less(i, j int) bool
  • func (o *TopOp) Pop() interface{}
  • func (o *TopOp) Push(x interface{})
  • func (o *TopOp) Specialize() error
  • func (op *TopOp) String() string
  • func (o *TopOp) Swap(i, j int)

Types

type TopOp

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

func New

func New(attrs []plan.ScopeAttribute,
	order *plan.Order, proc *process.Process, producerNum int) *TopOp

func (*TopOp) AddCtrlConsumer

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

func (*TopOp) AddMessageConsumer

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

func (*TopOp) Exec

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

func (*TopOp) Free

func (o *TopOp) Free() error

func (*TopOp) GetExecFunc

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

func (*TopOp) Len

func (o *TopOp) Len() int

maximum heap

func (*TopOp) Less

func (o *TopOp) Less(i, j int) bool

func (*TopOp) Pop

func (o *TopOp) Pop() interface{}

func (*TopOp) Push

func (o *TopOp) Push(x interface{})

func (*TopOp) Specialize

func (o *TopOp) Specialize() error

func (*TopOp) String

func (op *TopOp) String() string

func (*TopOp) Swap

func (o *TopOp) Swap(i, j int)