merge

Documentation

Index

• type Proc
  • func New(pctx *proc.Context, parents []proc.Interface) *Proc
  • func (m *Proc) Done()
  • func (p *Proc) Pull() (zbuf.Batch, error)

Types

type Proc

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

A Merge proc merges multiple upstream inputs into one output.

func New

func New(pctx *proc.Context, parents []proc.Interface) *Proc

func (*Proc) Done

func (m *Proc) Done()

func (*Proc) Pull

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

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