combine

package

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

Details

A combine proc merges multiple upstream inputs into one output.

This section is empty.

This section is empty.

This section is empty.

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

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

func (m *Proc) Done()

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

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