mux

package

v0.33.0 Latest Latest Go to latest Published: Nov 17, 2021 License: BSD-3-Clause Imports: 4 Imported by: 0

Details

A mux proc merges multiple upstream inputs into one output like combine but labels each batch.

This section is empty.

This section is empty.

This section is empty.

type Batch struct {
	zbuf.Batch
	Label int
}

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

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

func (p *Proc) Done()

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

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