Versions in this module Expand all Collapse all v0 v0.0.1 Oct 16, 2022 Changes in this version + const TokenBlock + const TokenBlockBody + const TokenDirective + const TokenName + var ContainerGracefulTimeoutSec = 10 + func IsBlockSchema(s schema.Schema) bool + func NewInterpreter(uri string) (conflow.BlockInterpreter, error) + func TransformChildren(parseCtx *conflow.ParseContext, blockID conflow.ID, nodes []parsley.Node, ...) ([]conflow.Node, conflow.Dependencies, parsley.Error) + func TransformMainNode(ctx interface{}, node parsley.Node, id conflow.ID, ...) (parsley.Node, parsley.Error) + func TransformNode(ctx interface{}, node parsley.Node, interpreter conflow.BlockInterpreter) (parsley.Node, parsley.Error) + type Container struct + func NewContainer(evalCtx *conflow.EvalContext, runtimeConfig conflow.RuntimeConfig, ...) *Container + func (c *Container) Cancel() bool + func (c *Container) Close() + func (c *Container) EvalStage() conflow.EvalStage + func (c *Container) JobID() int + func (c *Container) JobName() conflow.ID + func (c *Container) Lightweight() bool + func (c *Container) Node() conflow.Node + func (c *Container) Param(name conflow.ID) interface{} + func (c *Container) Pending() bool + func (c *Container) PublishBlock(block conflow.Block, f func() error) (bool, error) + func (c *Container) Run() + func (c *Container) SetChild(container conflow.Container) + func (c *Container) SetError(err parsley.Error) + func (c *Container) SetJobID(id int) + func (c *Container) Value() (interface{}, parsley.Error) + func (c *Container) WaitGroups() []conflow.WaitGroup + type InterpreterRegistry map[string]conflow.BlockInterpreter + func (i InterpreterRegistry) NodeTransformer(name string) (parsley.NodeTransformer, bool) + func (i InterpreterRegistry) Register(name string, interpreter conflow.BlockInterpreter) InterpreterRegistry + type Node struct + func NewNode(idNode *conflow.IDNode, nameNode *conflow.NameNode, ...) *Node + func (n *Node) BlockType() conflow.ID + func (n *Node) Children() []conflow.Node + func (n *Node) CreateContainer(ctx *conflow.EvalContext, runtimeConfig conflow.RuntimeConfig, ...) conflow.JobContainer + func (n *Node) Dependencies() conflow.Dependencies + func (n *Node) Directives() []conflow.BlockNode + func (n *Node) EvalStage() conflow.EvalStage + func (n *Node) Generates() []conflow.ID + func (n *Node) GetPropertySchema(name conflow.ID) (schema.Schema, bool) + func (n *Node) ID() conflow.ID + func (n *Node) Interpreter() conflow.BlockInterpreter + func (n *Node) Key() *string + func (n *Node) ParameterName() conflow.ID + func (n *Node) Pos() parsley.Pos + func (n *Node) Provides() []conflow.ID + func (n *Node) ReaderPos() parsley.Pos + func (n *Node) Schema() interface{} + func (n *Node) SetReaderPos(f func(parsley.Pos) parsley.Pos) + func (n *Node) SetSchema(s schema.Schema) + func (n *Node) StaticCheck(ctx interface{}) parsley.Error + func (n *Node) String() string + func (n *Node) Token() string + func (n *Node) Value(userCtx interface{}) (interface{}, parsley.Error) + func (n *Node) Walk(f func(n parsley.Node) bool) bool + type StaticContainer struct + func NewStaticContainer(evalCtx *conflow.EvalContext, node conflow.BlockNode) *StaticContainer + func (s *StaticContainer) Cancel() bool + func (s *StaticContainer) Close() + func (s *StaticContainer) EvalStage() conflow.EvalStage + func (s *StaticContainer) JobID() int + func (s *StaticContainer) JobName() conflow.ID + func (s *StaticContainer) Lightweight() bool + func (s *StaticContainer) Node() conflow.Node + func (s *StaticContainer) Pending() bool + func (s *StaticContainer) Run() + func (s *StaticContainer) SetJobID(jobID int) + func (s *StaticContainer) Value() (interface{}, parsley.Error) + func (s *StaticContainer) WaitGroups() []conflow.WaitGroup
Go to main page