core

package

Go to main page

Versions in this module

v0

v0.21.0

Oct 9, 2026

v0.20.3

Oct 8, 2026

Changes in this version

+ type DecoratedExpr struct

+ Inner Expr

+ Modifiers []string

+ Pos Position

+ func (*DecoratedExpr) Node()

+ func (d *DecoratedExpr) Analyze(r CapabilityResolver) error

+ func (d *DecoratedExpr) Build(ctx context.Context, bCtx *BuildContext) (action.AnyAction, error)

+ func (d *DecoratedExpr) Children() []Expr

v0.20.2

Oct 8, 2026

v0.20.1

Oct 8, 2026

v0.20.0

Oct 8, 2026

Changes in this version

type Bundle

+ Hooks []action.AnyHook

v0.19.0

Oct 8, 2026

Changes in this version

+ const VersionUnknown

+ var Version = VersionUnknown

+ func ApplyConstants(lines []string, start int, constants map[string]string)

+ func StripExprComments(raw string) string

type AssertExpr

+ Pos Position

type CompileOption

+ func WithCLIArgs(args []string) CompileOption

type ConditionalExpr

+ Pos Position

type FallbackExpr

+ Pos Position

type LoopExpr

+ Pos Position

type ParallelExpr

+ Pos Position

type Parser

+ func (p *Parser) Position() Position

type PipeExpr

+ Pos Position

type Position

+ func PositionOf(err error) (Position, bool)

+ type Positioned interface

+ Position func() Position

type ProjectionExpr

+ Pos Position

v0.18.0

Oct 7, 2026

v0.17.1

Oct 7, 2026

v0.17.0

Oct 6, 2026

Changes in this version

+ func WithSourceLoader(ctx context.Context, loader SourceLoader) context.Context

type Atom

+ ConfigInject bool

+ type SourceLoader interface

+ Load func(currentFile, target string) (data []byte, resolvedPath string, err error)

v0.16.0

Oct 5, 2026

Changes in this version

type Parser

+ func (p *Parser) Peek(offset int) Token

+ type PostfixExtension interface

+ MatchesPostfix func(p *Parser) bool

+ ParsePostfix func(p *Parser, left Expr) (Expr, error)

+ PostfixToken func() TokenType

type PrimaryExtensionTable

+ func (t *PrimaryExtensionTable) ByPostfix(tok TokenType) (PostfixExtension, bool)

v0.15.0

Oct 5, 2026

Changes in this version

type Bundle

+ Shutdowns []ShutdownFunc

+ type ShutdownFunc func(context.Context) error

v0.14.0

Oct 4, 2026

Changes in this version

+ func IsReservedActionName(name string) bool

+ func ModifierName(raw string) string

+ func ModifierOwnerName(owner ModifierOwner) string

+ func TranslateKeyword(name string) (string, bool)

+ func ValidateModifierValue(kind ModifierKind, value string) error

+ type ArgFieldSpec struct

+ Kind ArgKind

+ Name string

+ Optional bool

+ type ArgKind uint8

+ const ArgAny

+ const ArgBool

+ const ArgCapabilityRef

+ const ArgCapabilityRefList

+ const ArgInt

+ const ArgString

type Atom

+ ModifierSources []ModifierSource

+ Pos Position

type Bundle

+ AcceptedOptions []string

+ ArgSchemas map[string][]ArgFieldSpec

+ type CapabilityRef struct

+ Canonical string

+ Raw string

+ func ParseCapabilityRef(raw string) (CapabilityRef, error)

+ func ParseCapabilityRefList(line string) ([]CapabilityRef, error)

type CompileOption

+ func WithArgSchemas(schemas map[string][]ArgFieldSpec) CompileOption

+ func WithLineModifiers(lookups ...LineLookup) CompileOption

type CompileReq

+ Prepared *PreparedSource

type DirectiveReq

+ Table *DirectiveTable

type DirectiveRes

+ BlankLines []int

+ type KeywordMapping struct

+ Keyword string

+ Target string

+ func KeywordMappings() []KeywordMapping

+ type LineLookup struct

+ Fn func(line int) []string

+ Source ModifierSource

+ func LineModifiersFromOptions(mt *ModifierTable, opts []CompileOption) []LineLookup

+ type MergeablePrimary interface

+ MergeWith func(older PrimaryExtension) PrimaryExtension

type Modifier

+ Inheritable bool

+ Owner ModifierOwner

+ Unique bool

+ ValueKind ModifierKind

+ func WithInheritable(m Modifier) Modifier

+ func WithOwner(m Modifier, owner ModifierOwner) Modifier

+ func WithUnique(m Modifier) Modifier

+ type ModifierKind uint8

+ const ModifierKindAny

+ const ModifierKindDuration

+ const ModifierKindFlag

+ const ModifierKindFloat64

+ const ModifierKindInt

+ const ModifierKindInt32

+ const ModifierKindInt64

+ const ModifierKindString

+ const ModifierKindStringList

+ func (k ModifierKind) String() string

+ type ModifierOwner uint8

+ const OwnerBundle

+ const OwnerGrammar

+ const OwnerKernel

+ func RequiredModifierOwner(name string) ModifierOwner

+ type ModifierSource struct

+ Kind string

+ Label string

type ModifierSpec

+ ValueKind string

type Parser

+ func (p *Parser) Context() context.Context

+ func (p *Parser) WithLineModifiers(lookups ...LineLookup) *Parser

+ type PreparedSource struct

+ func PrepareSource(ctx context.Context, dt *DirectiveTable, source, name string, ...) (*PreparedSource, error)

+ func (p *PreparedSource) Contributions() PreprocessContributions

+ func (p *PreparedSource) Metadata() map[string]any

type ValueKind

+ const ValueBare

v0.13.1

Oct 2, 2026

v0.13.0

Oct 2, 2026

v0.12.1

Oct 2, 2026

v0.12.0

Oct 2, 2026

v0.11.0

Oct 1, 2026

Changes in this version

type DynamicResolver

+ func (r *DynamicResolver) ActionNames() []string

+ func (r *DynamicResolver) Actions() []action.AnyAction

+ func (r *DynamicResolver) Operators() []action.NamedOperator

+ func (r *DynamicResolver) Streams() []action.AnyStreamAction

v0.10.2

Oct 1, 2026

v0.10.1

Oct 1, 2026

v0.10.0

Oct 1, 2026

Changes in this version

+ func Analyze(resolver CapabilityResolver, expr Expr) error

+ func AtomNames(e Expr) []string

+ func Build(ctx context.Context, resolver CapabilityResolver, modifiers *ModifierTable, ...) (action.AnyAction, error)

+ func BuildEnv(input any) map[string]any

+ func CompileAction(resolver CapabilityResolver, dt *DirectiveTable, mt *ModifierTable, ...) *action.BuiltAction[CompileReq, CompileRes]

+ func CompileAndRun(resolver CapabilityResolver, dt *DirectiveTable, mt *ModifierTable, ...) *action.BuiltAction[CompileAndRunReq, RunRes]

+ func ComposedPipe(left, right action.AnyAction) action.AnyAction

+ func Decode[T any](raw map[string]string) (T, error)

+ func IndexTopLevel(s string, target byte) int

+ func Library(resolver CapabilityResolver, dt *DirectiveTable, mt *ModifierTable, ...) action.Library

+ func ModifiersToMap(modifiers []string) map[string]any

+ func ParseBlockOptions(lines []string, start int) (opts map[string]string, next int, err error)

+ func ParseList(line string) []string

+ func Preprocess(ctx context.Context, dt *DirectiveTable, source, file string) (clean string, meta map[string]any, err error)

+ func PreprocessDots(src string) string

+ func ReadBlock(lines []string, start int) (body []string, next int, err error)

+ func Register(id string, factory BundleFactory)

+ func RegisterBoundary(spec BoundarySpec)

+ func RegisterBundle(id string, factory BundleFactory)

+ func RunAction() *action.BuiltAction[RunReq, RunRes]

+ func SourceError(pos Position, format string, args ...any) error

+ func SplitTopLevel(s string, sep byte) []string

+ func SuggestModifierFix(target action.AnyAction, name string) string

+ func TrimQuotes(s string) string

+ func ValidateBundle(b Bundle) error

+ func WithCompileConfig(ctx context.Context, cfg map[string]string, cliArgs []string) context.Context

+ func WithStrict(ctx context.Context) context.Context

+ type AssertExpr struct

+ Condition string

+ Message string

+ func (*AssertExpr) Analyze(CapabilityResolver) error

+ func (*AssertExpr) Node()

+ func (a *AssertExpr) Build(_ context.Context, _ *BuildContext) (action.AnyAction, error)

+ func (a *AssertExpr) Children() []Expr

+ type Associativity uint8

+ const Left

+ const Right

+ type Atom struct

+ Args map[string]*Value

+ Excludes []string

+ Modifiers []string

+ Name string

+ Params map[string]string

+ Prompt string

+ Targets []string

+ func (*Atom) Analyze(CapabilityResolver) error

+ func (*Atom) Children() []Expr

+ func (*Atom) Node()

+ func (a *Atom) Build(ctx context.Context, bCtx *BuildContext) (action.AnyAction, error)

+ type AtomAdviseFunc func(atom *Atom, builder *action.Builder[any, any]) error

+ type AtomSpec struct

+ Description string

+ Example json.RawMessage

+ Name string

+ ReqFields []FieldSpec

+ ResFields []FieldSpec

+ Scope string

+ Tags []string

+ type BoundarySpec struct

+ Consume func(stream action.AnyStreamAction) *action.Builder[any, any]

+ Description string

+ Name string

+ func BoundaryByName(name string) (BoundarySpec, bool)

+ func NamedBoundaries() []BoundarySpec

+ type BuildContext struct

+ Advisers []AtomAdviseFunc

+ Modifiers *ModifierTable

+ Resolver CapabilityResolver

+ type Bundle struct

+ Alias string

+ AtomAdvise func(atom *Atom, builder *action.Builder[any, any]) error

+ Directives []Directive

+ Fixtures fs.FS

+ ID string

+ Libraries []action.Library

+ Materialize Materializer

+ Modifiers []Modifier

+ OnPreprocess func(meta map[string]any) PreprocessContributions

+ Operators []Operator

+ Primaries []PrimaryExtension

+ SelfTest func() []SelfTestSection

+ WrapPipeline func(meta map[string]any, inner action.AnyAction) (action.AnyAction, error)

+ func RegisteredBundles() []Bundle

+ func (b Bundle) AllSelfTests() []SelfTestSection

+ type BundleFactory func(opts map[string]string) Bundle

+ func Lookup(id string) (BundleFactory, bool)

+ func LookupBundleForModule(target string) (BundleFactory, bool)

+ type CapabilityContract struct

+ Input TypeDescriptor

+ Name string

+ Output TypeDescriptor

+ type CapabilityResolver interface

+ Action func(name string) (action.AnyAction, bool)

+ Mount func(lib action.Library) error

+ MountWithAlias func(lib action.Library, alias string) error

+ Operator func(name string) (action.NamedOperator, bool)

+ Stream func(name string) (action.AnyStreamAction, bool)

+ type Catalog struct

+ Atoms []AtomSpec

+ Directives []DirectiveSpec

+ Modifiers []ModifierSpec

+ Operators []OperatorSpec

+ Sources []SourceSpec

+ func BuildCatalog(resolver CapabilityResolver, mt *ModifierTable, dt *DirectiveTable, ...) Catalog

+ type CompileAndRunReq struct

+ Payload any

+ Source string

+ type CompileOption func(*compileConfig)

+ func BundleConfig(bundles ...Bundle) []CompileOption

+ func WithAtomAdvisors(fns ...AtomAdviseFunc) CompileOption

+ func WithConfigMap(cfg map[string]string, cliArgs []string) CompileOption

+ func WithOnPreprocess(fns ...OnPreprocessFunc) CompileOption

+ func WithPipelineWrappers(fns ...PipelineWrapFunc) CompileOption

+ type CompileReq struct

+ InheritedPrimaries []PrimaryExtension

+ Line int

+ Name string

+ Source string

+ type CompileRes struct

+ AST Expr

+ Meta map[string]any

+ Program action.AnyAction

+ type ConditionalExpr struct

+ Cond Expr

+ Else Expr

+ Then Expr

+ func (*ConditionalExpr) Node()

+ func (c *ConditionalExpr) Analyze(r CapabilityResolver) error

+ func (c *ConditionalExpr) Build(ctx context.Context, bCtx *BuildContext) (action.AnyAction, error)

+ func (c *ConditionalExpr) Children() []Expr

+ type ContractProvider interface

+ Contract func(name string) (CapabilityContract, bool)

+ type Directive struct

+ Example string

+ Handler func(context.Context, DirectiveReq) (DirectiveRes, error)

+ Name string

+ func (d Directive) Action() *action.BuiltAction[DirectiveReq, DirectiveRes]

+ type DirectiveReq struct

+ BaseDir string

+ Body []string

+ File string

+ I int

+ Lines []string

+ Out map[string]any

+ Recurse func(absPath string) (clean string, meta map[string]any, err error)

+ type DirectiveRes struct

+ Next int

+ type DirectiveSpec struct

+ Example string

+ Name string

+ type DirectiveTable struct

+ func NewDirectiveTable(ds ...Directive) *DirectiveTable

+ func (t *DirectiveTable) Actions() []action.AnyAction

+ func (t *DirectiveTable) All() []Directive

+ func (t *DirectiveTable) ByName(name string) (*action.BuiltAction[DirectiveReq, DirectiveRes], bool)

+ type DynamicResolver struct

+ func NewDynamicResolver(baseLibs ...action.Library) (*DynamicResolver, error)

+ func (r *DynamicResolver) Action(name string) (action.AnyAction, bool)

+ func (r *DynamicResolver) Contract(name string) (CapabilityContract, bool)

+ func (r *DynamicResolver) Mount(lib action.Library) error

+ func (r *DynamicResolver) MountWithAlias(lib action.Library, alias string) error

+ func (r *DynamicResolver) Operator(name string) (action.NamedOperator, bool)

+ func (r *DynamicResolver) Stream(name string) (action.AnyStreamAction, bool)

+ type Expr interface

+ Analyze func(resolver CapabilityResolver) error

+ Build func(ctx context.Context, bCtx *BuildContext) (action.AnyAction, error)

+ Children func() []Expr

+ Node func()

+ type FallbackExpr struct

+ L Expr

+ R Expr

+ func (*FallbackExpr) Node()

+ func (f *FallbackExpr) Analyze(r CapabilityResolver) error

+ func (f *FallbackExpr) Build(ctx context.Context, bCtx *BuildContext) (action.AnyAction, error)

+ func (f *FallbackExpr) Children() []Expr

+ type FieldSpec struct

+ Name string

+ Required bool

+ Type string

+ Usage string

+ type KeywordPrimary interface

+ Keyword func() string

+ type Lexer struct

+ func NewLexer(src string) *Lexer

+ func (l *Lexer) Next() Token

+ type LoopExpr struct

+ Body Expr

+ Until string

+ func (*LoopExpr) Node()

+ func (l *LoopExpr) Analyze(r CapabilityResolver) error

+ func (l *LoopExpr) Build(ctx context.Context, bCtx *BuildContext) (action.AnyAction, error)

+ func (l *LoopExpr) Children() []Expr

+ type MapEntry struct

+ Key string

+ Value *Value

+ type MaterializeReq struct

+ Alias string

+ Compile func(name, source string) (action.AnyAction, error)

+ Ctx context.Context

+ Meta map[string]any

+ Resolver CapabilityResolver

+ type Materializer func(req MaterializeReq) error

+ type Modifier struct

+ Apply func(b *action.Builder[any, any], raw string) error

+ Example string

+ Name string

+ func Duration(name string, ...) Modifier

+ func Flag(name string, apply func(*action.Builder[any, any]) *action.Builder[any, any]) Modifier

+ func Float64(name string, ...) Modifier

+ func Int(name string, ...) Modifier

+ func Int32(name string, ...) Modifier

+ func Int64(name string, ...) Modifier

+ func String(name string, ...) Modifier

+ func StringList(name string, ...) Modifier

+ type ModifierSpec struct

+ Example string

+ Name string

+ type ModifierTable struct

+ func NewModifierTable(modifiers ...Modifier) *ModifierTable

+ func (t *ModifierTable) Actions() []action.AnyAction

+ func (t *ModifierTable) All() []Modifier

+ func (t *ModifierTable) ApplyAll(target action.AnyAction, raws []string) (action.AnyAction, error)

+ func (t *ModifierTable) ByName(name string) (Modifier, bool)

+ type OnPreprocessFunc func(meta map[string]any) PreprocessContributions

+ type Operator struct

+ Handler func(context.Context, OperatorReq) (OperatorRes, error)

+ Meta OperatorMeta

+ func (o Operator) Action() *action.BuiltAction[OperatorReq, OperatorRes]

+ type OperatorMeta struct

+ Associativity Associativity

+ Description string

+ Example string

+ Name string

+ Precedence int

+ Token TokenType

+ type OperatorReq struct

+ Left Expr

+ Meta *OperatorMeta

+ Right Expr

+ type OperatorRes struct

+ Node Expr

+ type OperatorSpec struct

+ Description string

+ Example string

+ Name string

+ Token string

+ type OperatorTable struct

+ func NewOperatorTable(ops ...Operator) *OperatorTable

+ func (t *OperatorTable) Actions() []action.AnyAction

+ func (t *OperatorTable) All() []OperatorMeta

+ func (t *OperatorTable) ByName(name string) (OperatorMeta, *action.BuiltAction[OperatorReq, OperatorRes], bool)

+ func (t *OperatorTable) ByToken(tok TokenType) (OperatorMeta, *action.BuiltAction[OperatorReq, OperatorRes], bool)

+ type ParallelExpr struct

+ Branches []Expr

+ func (*ParallelExpr) Node()

+ func (p *ParallelExpr) Analyze(r CapabilityResolver) error

+ func (p *ParallelExpr) Build(ctx context.Context, bCtx *BuildContext) (action.AnyAction, error)

+ func (p *ParallelExpr) Children() []Expr

+ type Parser struct

+ func NewParser(ctx context.Context, ops *OperatorTable, src string) *Parser

+ func NewParserWithFile(ctx context.Context, ops *OperatorTable, primaries *PrimaryExtensionTable, ...) *Parser

+ func NewParserWithFileOffset(ctx context.Context, ops *OperatorTable, primaries *PrimaryExtensionTable, ...) *Parser

+ func NewParserWithPrimaries(ctx context.Context, ops *OperatorTable, primaries *PrimaryExtensionTable, ...) *Parser

+ func (p *Parser) Advance()

+ func (p *Parser) Cur() Token

+ func (p *Parser) Current() Token

+ func (p *Parser) Fail(line int, format string, args ...any) error

+ func (p *Parser) File() string

+ func (p *Parser) Next()

+ func (p *Parser) Parse() (Expr, error)

+ func (p *Parser) ParseExpr(minPrec int) (Expr, error)

+ func (p *Parser) Src() string

+ func (p *Parser) SubParse(src string) (Expr, error)

+ type PipeExpr struct

+ L Expr

+ R Expr

+ func (*PipeExpr) Node()

+ func (p *PipeExpr) Analyze(r CapabilityResolver) error

+ func (p *PipeExpr) Build(ctx context.Context, bCtx *BuildContext) (action.AnyAction, error)

+ func (p *PipeExpr) Children() []Expr

+ type PipelineWrapFunc func(meta map[string]any, inner action.AnyAction) (action.AnyAction, error)

+ type Position struct

+ Col int

+ File string

+ Line int

+ func (p Position) String() string

+ type PreprocessContributions struct

+ CompileOpts []CompileOption

+ Primaries []PrimaryExtension

+ func PreprocessContributionsFromMeta(meta map[string]any, opts ...CompileOption) PreprocessContributions

+ type PrimaryExtension interface

+ Name func() string

+ Parse func(p *Parser) (Expr, error)

+ type PrimaryExtensionTable struct

+ func DefaultPrimaryExtensions() *PrimaryExtensionTable

+ func NewPrimaryExtensionTable(exts ...PrimaryExtension) *PrimaryExtensionTable

+ func (t *PrimaryExtensionTable) All() []PrimaryExtension

+ func (t *PrimaryExtensionTable) ByKeyword(kw string) (PrimaryExtension, bool)

+ func (t *PrimaryExtensionTable) ByToken(tt TokenType) (PrimaryExtension, bool)

+ type ProjectionExpr struct

+ Raw string

+ func (*ProjectionExpr) Analyze(CapabilityResolver) error

+ func (*ProjectionExpr) Node()

+ func (p *ProjectionExpr) Build(ctx context.Context, bCtx *BuildContext) (action.AnyAction, error)

+ func (p *ProjectionExpr) Children() []Expr

+ type RunReq struct

+ Payload any

+ Program action.AnyAction

+ type RunRes struct

+ Output any

+ type SelfTestFeature struct

+ DSL string

+ Files map[string]string

+ Name string

+ Skip string

+ Source string

+ type SelfTestSection struct

+ Features []SelfTestFeature

+ Name string

+ type SourceSpec struct

+ Description string

+ Name string

+ ReqFields []FieldSpec

+ Tags []string

+ type Token struct

+ Line int

+ Lit string

+ Offset int

+ Type TokenType

+ type TokenPrimary interface

+ TokenType func() TokenType

+ type TokenType uint8

+ const TokAmpersand

+ const TokArrow

+ const TokAtBrace

+ const TokAtPrompt

+ const TokColon

+ const TokComma

+ const TokEOF

+ const TokEquals

+ const TokHash

+ const TokIdent

+ const TokLBrace

+ const TokLParen

+ const TokNumber

+ const TokOrOr

+ const TokPipe

+ const TokQuestion

+ const TokRBrace

+ const TokRParen

+ const TokString

+ const TokTilde

+ func (t TokenType) String() string

+ type TypeDescriptor struct

+ Stream bool

+ Type reflect.Type

+ type Value struct

+ Bool bool

+ Kind ValueKind

+ Map []MapEntry

+ Num float64

+ Ref string

+ Slice []*Value

+ Str string

+ func (v *Value) IsWholeStateRef() bool

+ type ValueKind uint8

+ const ValueBool

+ const ValueMap

+ const ValueNull

+ const ValueNumber

+ const ValueRef

+ const ValueSlice

+ const ValueString

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL