from

Documentation

Index

• type Planner
• type Proc
  • func New(pctx *op.Context, planner Planner) *Proc
  • func NewPuller(pctx *op.Context, puller zbuf.Puller) *Proc
  • func (p *Proc) Pull(done bool) (zbuf.Batch, error)

Types

type Planner

type Planner interface {
	PullWork() (zbuf.Puller, error)
	Progress() zbuf.Progress
}

type Proc

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

func New

func New(pctx *op.Context, planner Planner) *Proc

func NewPuller

func NewPuller(pctx *op.Context, puller zbuf.Puller) *Proc

func (*Proc) Pull

func (p *Proc) Pull(done bool) (zbuf.Batch, error)

Pull implements the merge logic for returning data from the upstreams.