op

type Catcher ¶

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

Catcher wraps an Interface with a Pull method that recovers panics and turns them into errors. It should be wrapped around the output puller of a flowgraph and the top-level puller of any goroutine created inside of a flowgraph.

func NewCatcher(parent zbuf.Puller) *Catcher

func (c *Catcher) Pull(done bool) (b zbuf.Batch, err error)

type EndOfChannel ¶

type EndOfChannel int

EndOfChannel is an empty batch that represents the termination of one of the output paths of a muxed flowgraph and thus will be ignored downstream unless explicitly detected.

func (*EndOfChannel) Ref()

func (*EndOfChannel) Unref()

func (*EndOfChannel) Values() []zed.Value

func (*EndOfChannel) Vars() []zed.Value

type Mux ¶

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

Mux implements the muxing of a set of parallel paths at the output of a flowgraph. It also implements the double-EOS algorithm with proc.Latch to detect the end of each parallel stream. Its output protocol is a single EOS when all of the upstream legs are done at which time it cancels the flowgraoh. Each batch returned by the mux is wrapped in a Batch, which can be unwrappd with Unwrap to extract the integer index of the output (in left-to-right DFS traversal order of the flowgraph). This proc requires more than one parent; use proc.Latcher for a single-output flowgraph.

func NewMux(rctx *runtime.Context, parents []zbuf.Puller) *Mux

func (m *Mux) Pull(bool) (zbuf.Batch, error)

type Result ¶

type Result struct {
	Batch zbuf.Batch
	Err   error
}

Result is a convenient way to bundle the result of Proc.Pull() to send over channels.

type Router ¶

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

func NewRouter(ctx context.Context, parent zbuf.Puller) *Router

func (r *Router) AddRoute() zbuf.Puller

func (r *Router) Link(s Selector)

func (r *Router) Send(p zbuf.Puller, b zbuf.Batch, err error) bool

type Selector ¶

type Selector interface {
	Forward(*Router, zbuf.Batch) bool
}

type Single ¶

type Single struct {
	zbuf.Puller
	// contains filtered or unexported fields
}

func NewSingle(parent zbuf.Puller) *Single

func (s *Single) Pull(bool) (zbuf.Batch, error)