traverse

package

v0.34.0-test1 Latest Latest Go to latest Published: Feb 13, 2022 License: BSD-3-Clause Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewEnter(names []string, exprs []expr.Evaluator) *Enter

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

func NewExit(scope *Scope, nvar int) *Exit

func (e *Exit) Pull(done bool) (zbuf.Batch, error)

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

func NewOver(pctx *op.Context, parent zbuf.Puller, exprs []expr.Evaluator) *Over

func (o *Over) AddScope(ctx context.Context, names []string, exprs []expr.Evaluator) *Scope

func (o *Over) Pull(done bool) (zbuf.Batch, error)

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

func (s *Scope) NewExit(subgraph zbuf.Puller) *Exit

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

Pull is called by the scoped subgraph. Parent's batch will already be scoped by Over or Into.