syntax

Documentation

Overview

Package syntax ships the four binary operators every .nflow file relies on: ->, |, &, ||, plus the structured parallel and race forms.

The package is a native bundle — always mounted by native.Bundles() and never requires @require. It lives under extensions/ rather than compiler/ so the compiler remains a pure mechanism: the parser knows how to call an operator, not what a pipe means.

Index

• Constants
• func Bundle(_ map[string]string) compiler.Bundle
• type NamedParallelExpr
  • func (e *NamedParallelExpr) Analyze(resolver compiler.CapabilityResolver) error
  • func (e *NamedParallelExpr) Build(ctx context.Context, bCtx *compiler.BuildContext) (action.AnyAction, error)
  • func (e *NamedParallelExpr) Children() []compiler.Expr
  • func (e *NamedParallelExpr) DescribeActionGraph() compiler.ActionGraphDescription
  • func (*NamedParallelExpr) Node()
• type RaceExpr
  • func (e *RaceExpr) Analyze(resolver compiler.CapabilityResolver) error
  • func (e *RaceExpr) Build(ctx context.Context, bCtx *compiler.BuildContext) (action.AnyAction, error)
  • func (e *RaceExpr) Children() []compiler.Expr
  • func (e *RaceExpr) DescribeActionGraph() compiler.ActionGraphDescription
  • func (*RaceExpr) Node()

Constants

const ID = "syntax"

Functions

func Bundle

func Bundle(_ map[string]string) compiler.Bundle

Types

type NamedParallelExpr

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

NamedParallelExpr runs expressions concurrently and returns results keyed by the explicit labels in its source block.

func (*NamedParallelExpr) Analyze

func (e *NamedParallelExpr) Analyze(resolver compiler.CapabilityResolver) error

func (*NamedParallelExpr) Build

func (e *NamedParallelExpr) Build(ctx context.Context, bCtx *compiler.BuildContext) (action.AnyAction, error)

func (*NamedParallelExpr) Children

func (e *NamedParallelExpr) Children() []compiler.Expr

func (*NamedParallelExpr) DescribeActionGraph

func (e *NamedParallelExpr) DescribeActionGraph() compiler.ActionGraphDescription

func (*NamedParallelExpr) Node

func (*NamedParallelExpr) Node()

type RaceExpr

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

RaceExpr runs its candidates concurrently and returns Kernel's first successful result. Kernel cancels the remaining candidates on success and joins all launched work before returning.

func (*RaceExpr) Analyze

func (e *RaceExpr) Analyze(resolver compiler.CapabilityResolver) error

func (*RaceExpr) Build

func (e *RaceExpr) Build(ctx context.Context, bCtx *compiler.BuildContext) (action.AnyAction, error)

func (*RaceExpr) Children

func (e *RaceExpr) Children() []compiler.Expr

func (*RaceExpr) DescribeActionGraph

func (e *RaceExpr) DescribeActionGraph() compiler.ActionGraphDescription

func (*RaceExpr) Node

func (*RaceExpr) Node()