Versions in this module Expand all Collapse all v0 v0.0.1 Oct 16, 2022 Changes in this version + func NewModuleInterpreter(interpreter conflow.BlockInterpreter, node parsley.Node) conflow.BlockInterpreter + type Basic struct + func (b *Basic) ID() conflow.ID + type BasicInterpreter struct + func (i BasicInterpreter) CreateBlock(id conflow.ID, blockCtx *conflow.BlockContext) conflow.Block + func (i BasicInterpreter) Param(b conflow.Block, name conflow.ID) interface{} + func (i BasicInterpreter) ParseContext(ctx *conflow.ParseContext) *conflow.ParseContext + func (i BasicInterpreter) Schema() schema.Schema + func (i BasicInterpreter) SetBlock(block conflow.Block, name conflow.ID, key string, value interface{}) error + func (i BasicInterpreter) SetParam(block conflow.Block, name conflow.ID, value interface{}) error + func (i BasicInterpreter) ValueParamName() conflow.ID + type Exec struct + func (e *Exec) ID() conflow.ID + func (e *Exec) ParseContextOverride() conflow.ParseContextOverride + func (e *Exec) Run(ctx context.Context) (conflow.Result, error) + type ExecInterpreter struct + func (i ExecInterpreter) CreateBlock(id conflow.ID, blockCtx *conflow.BlockContext) conflow.Block + func (i ExecInterpreter) Param(b conflow.Block, name conflow.ID) interface{} + func (i ExecInterpreter) ParseContext(ctx *conflow.ParseContext) *conflow.ParseContext + func (i ExecInterpreter) Schema() schema.Schema + func (i ExecInterpreter) SetBlock(block conflow.Block, name conflow.ID, key string, value interface{}) error + func (i ExecInterpreter) SetParam(block conflow.Block, name conflow.ID, value interface{}) error + func (i ExecInterpreter) ValueParamName() conflow.ID + type Fail struct + func (f *Fail) ID() conflow.ID + func (f *Fail) Run(ctx context.Context) (conflow.Result, error) + type FailInterpreter struct + func (i FailInterpreter) CreateBlock(id conflow.ID, blockCtx *conflow.BlockContext) conflow.Block + func (i FailInterpreter) Param(b conflow.Block, name conflow.ID) interface{} + func (i FailInterpreter) ParseContext(ctx *conflow.ParseContext) *conflow.ParseContext + func (i FailInterpreter) Schema() schema.Schema + func (i FailInterpreter) SetBlock(block conflow.Block, name conflow.ID, key string, value interface{}) error + func (i FailInterpreter) SetParam(block conflow.Block, name conflow.ID, value interface{}) error + func (i FailInterpreter) ValueParamName() conflow.ID + type Gunzip struct + func (g *Gunzip) ID() conflow.ID + func (g *Gunzip) ParseContextOverride() conflow.ParseContextOverride + func (g *Gunzip) Run(ctx context.Context) (conflow.Result, error) + type GunzipInterpreter struct + func (i GunzipInterpreter) CreateBlock(id conflow.ID, blockCtx *conflow.BlockContext) conflow.Block + func (i GunzipInterpreter) Param(b conflow.Block, name conflow.ID) interface{} + func (i GunzipInterpreter) ParseContext(ctx *conflow.ParseContext) *conflow.ParseContext + func (i GunzipInterpreter) Schema() schema.Schema + func (i GunzipInterpreter) SetBlock(block conflow.Block, name conflow.ID, key string, value interface{}) error + func (i GunzipInterpreter) SetParam(block conflow.Block, name conflow.ID, value interface{}) error + func (i GunzipInterpreter) ValueParamName() conflow.ID + type Gzip struct + func (g *Gzip) ID() conflow.ID + func (g *Gzip) ParseContextOverride() conflow.ParseContextOverride + func (g *Gzip) Run(ctx context.Context) (conflow.Result, error) + type GzipInterpreter struct + func (i GzipInterpreter) CreateBlock(id conflow.ID, blockCtx *conflow.BlockContext) conflow.Block + func (i GzipInterpreter) Param(b conflow.Block, name conflow.ID) interface{} + func (i GzipInterpreter) ParseContext(ctx *conflow.ParseContext) *conflow.ParseContext + func (i GzipInterpreter) Schema() schema.Schema + func (i GzipInterpreter) SetBlock(block conflow.Block, name conflow.ID, key string, value interface{}) error + func (i GzipInterpreter) SetParam(block conflow.Block, name conflow.ID, value interface{}) error + func (i GzipInterpreter) ValueParamName() conflow.ID + type Import struct + func (i *Import) BlockInterpreters(parseCtx *conflow.ParseContext) (map[conflow.ID]conflow.BlockInterpreter, error) + func (i *Import) EvalStage() conflow.EvalStage + func (i *Import) ID() conflow.ID + type ImportInterpreter struct + func (i ImportInterpreter) CreateBlock(id conflow.ID, blockCtx *conflow.BlockContext) conflow.Block + func (i ImportInterpreter) Param(b conflow.Block, name conflow.ID) interface{} + func (i ImportInterpreter) ParseContext(ctx *conflow.ParseContext) *conflow.ParseContext + func (i ImportInterpreter) Schema() schema.Schema + func (i ImportInterpreter) SetBlock(block conflow.Block, name conflow.ID, key string, value interface{}) error + func (i ImportInterpreter) SetParam(block conflow.Block, name conflow.ID, value interface{}) error + func (i ImportInterpreter) ValueParamName() conflow.ID + type It struct + func (i *It) ID() conflow.ID + type ItInterpreter struct + func (i ItInterpreter) CreateBlock(id conflow.ID, blockCtx *conflow.BlockContext) conflow.Block + func (i ItInterpreter) Param(b conflow.Block, name conflow.ID) interface{} + func (i ItInterpreter) ParseContext(ctx *conflow.ParseContext) *conflow.ParseContext + func (i ItInterpreter) Schema() schema.Schema + func (i ItInterpreter) SetBlock(block conflow.Block, name conflow.ID, key string, value interface{}) error + func (i ItInterpreter) SetParam(block conflow.Block, name conflow.ID, value interface{}) error + func (i ItInterpreter) ValueParamName() conflow.ID + type Iterator struct + func (i *Iterator) ID() conflow.ID + func (i *Iterator) ParseContextOverride() conflow.ParseContextOverride + func (i *Iterator) Run(ctx context.Context) (conflow.Result, error) + type IteratorInterpreter struct + func (i IteratorInterpreter) CreateBlock(id conflow.ID, blockCtx *conflow.BlockContext) conflow.Block + func (i IteratorInterpreter) Param(b conflow.Block, name conflow.ID) interface{} + func (i IteratorInterpreter) ParseContext(ctx *conflow.ParseContext) *conflow.ParseContext + func (i IteratorInterpreter) Schema() schema.Schema + func (i IteratorInterpreter) SetBlock(block conflow.Block, name conflow.ID, key string, value interface{}) error + func (i IteratorInterpreter) SetParam(block conflow.Block, name conflow.ID, value interface{}) error + func (i IteratorInterpreter) ValueParamName() conflow.ID + type Line struct + func (l *Line) ID() conflow.ID + type LineInterpreter struct + func (i LineInterpreter) CreateBlock(id conflow.ID, blockCtx *conflow.BlockContext) conflow.Block + func (i LineInterpreter) Param(b conflow.Block, name conflow.ID) interface{} + func (i LineInterpreter) ParseContext(ctx *conflow.ParseContext) *conflow.ParseContext + func (i LineInterpreter) Schema() schema.Schema + func (i LineInterpreter) SetBlock(block conflow.Block, name conflow.ID, key string, value interface{}) error + func (i LineInterpreter) SetParam(block conflow.Block, name conflow.ID, value interface{}) error + func (i LineInterpreter) ValueParamName() conflow.ID + type LineScanner struct + func (l *LineScanner) ID() conflow.ID + func (l *LineScanner) ParseContextOverride() conflow.ParseContextOverride + func (l *LineScanner) Run(ctx context.Context) (conflow.Result, error) + type LineScannerInterpreter struct + func (i LineScannerInterpreter) CreateBlock(id conflow.ID, blockCtx *conflow.BlockContext) conflow.Block + func (i LineScannerInterpreter) Param(b conflow.Block, name conflow.ID) interface{} + func (i LineScannerInterpreter) ParseContext(ctx *conflow.ParseContext) *conflow.ParseContext + func (i LineScannerInterpreter) Schema() schema.Schema + func (i LineScannerInterpreter) SetBlock(block conflow.Block, name conflow.ID, key string, value interface{}) error + func (i LineScannerInterpreter) SetParam(block conflow.Block, name conflow.ID, value interface{}) error + func (i LineScannerInterpreter) ValueParamName() conflow.ID + type Main struct + func (m *Main) ID() conflow.ID + type MainInterpreter struct + BlockTransformerRegistry parsley.NodeTransformerRegistry + FunctionTransformerRegistry parsley.NodeTransformerRegistry + func (m MainInterpreter) CreateBlock(conflow.ID, *conflow.BlockContext) conflow.Block + func (m MainInterpreter) Param(b conflow.Block, name conflow.ID) interface{} + func (m MainInterpreter) ParseContext(ctx *conflow.ParseContext) *conflow.ParseContext + func (m MainInterpreter) Schema() schema.Schema + func (m MainInterpreter) SetBlock(b conflow.Block, name conflow.ID, key string, value interface{}) error + func (m MainInterpreter) SetParam(b conflow.Block, name conflow.ID, value interface{}) error + func (m MainInterpreter) ValueParamName() conflow.ID + type Print struct + func (p *Print) ID() conflow.ID + func (p *Print) Run(ctx context.Context) (conflow.Result, error) + type PrintInterpreter struct + func (i PrintInterpreter) CreateBlock(id conflow.ID, blockCtx *conflow.BlockContext) conflow.Block + func (i PrintInterpreter) Param(b conflow.Block, name conflow.ID) interface{} + func (i PrintInterpreter) ParseContext(ctx *conflow.ParseContext) *conflow.ParseContext + func (i PrintInterpreter) Schema() schema.Schema + func (i PrintInterpreter) SetBlock(block conflow.Block, name conflow.ID, key string, value interface{}) error + func (i PrintInterpreter) SetParam(block conflow.Block, name conflow.ID, value interface{}) error + func (i PrintInterpreter) ValueParamName() conflow.ID + type Println struct + func (p *Println) ID() conflow.ID + func (p *Println) Run(ctx context.Context) (conflow.Result, error) + type PrintlnInterpreter struct + func (i PrintlnInterpreter) CreateBlock(id conflow.ID, blockCtx *conflow.BlockContext) conflow.Block + func (i PrintlnInterpreter) Param(b conflow.Block, name conflow.ID) interface{} + func (i PrintlnInterpreter) ParseContext(ctx *conflow.ParseContext) *conflow.ParseContext + func (i PrintlnInterpreter) Schema() schema.Schema + func (i PrintlnInterpreter) SetBlock(block conflow.Block, name conflow.ID, key string, value interface{}) error + func (i PrintlnInterpreter) SetParam(block conflow.Block, name conflow.ID, value interface{}) error + func (i PrintlnInterpreter) ValueParamName() conflow.ID + type Sleep struct + func (s *Sleep) ID() conflow.ID + func (s *Sleep) Run(ctx context.Context) (conflow.Result, error) + type SleepInterpreter struct + func (i SleepInterpreter) CreateBlock(id conflow.ID, blockCtx *conflow.BlockContext) conflow.Block + func (i SleepInterpreter) Param(b conflow.Block, name conflow.ID) interface{} + func (i SleepInterpreter) ParseContext(ctx *conflow.ParseContext) *conflow.ParseContext + func (i SleepInterpreter) Schema() schema.Schema + func (i SleepInterpreter) SetBlock(block conflow.Block, name conflow.ID, key string, value interface{}) error + func (i SleepInterpreter) SetParam(block conflow.Block, name conflow.ID, value interface{}) error + func (i SleepInterpreter) ValueParamName() conflow.ID + type Stream struct + Stream io.ReadCloser + func NewStream(id conflow.ID, stream io.ReadCloser) *Stream + func (s Stream) ID() conflow.ID + type StreamInterpreter struct + func (i StreamInterpreter) CreateBlock(id conflow.ID, blockCtx *conflow.BlockContext) conflow.Block + func (i StreamInterpreter) Param(b conflow.Block, name conflow.ID) interface{} + func (i StreamInterpreter) ParseContext(ctx *conflow.ParseContext) *conflow.ParseContext + func (i StreamInterpreter) Schema() schema.Schema + func (i StreamInterpreter) SetBlock(block conflow.Block, name conflow.ID, key string, value interface{}) error + func (i StreamInterpreter) SetParam(block conflow.Block, name conflow.ID, value interface{}) error + func (i StreamInterpreter) ValueParamName() conflow.ID + type Tick struct + func (t *Tick) ID() conflow.ID + type TickInterpreter struct + func (i TickInterpreter) CreateBlock(id conflow.ID, blockCtx *conflow.BlockContext) conflow.Block + func (i TickInterpreter) Param(b conflow.Block, name conflow.ID) interface{} + func (i TickInterpreter) ParseContext(ctx *conflow.ParseContext) *conflow.ParseContext + func (i TickInterpreter) Schema() schema.Schema + func (i TickInterpreter) SetBlock(block conflow.Block, name conflow.ID, key string, value interface{}) error + func (i TickInterpreter) SetParam(block conflow.Block, name conflow.ID, value interface{}) error + func (i TickInterpreter) ValueParamName() conflow.ID + type Ticker struct + func (t *Ticker) ID() conflow.ID + func (t *Ticker) ParseContextOverride() conflow.ParseContextOverride + func (t *Ticker) Run(ctx context.Context) (conflow.Result, error) + type TickerInterpreter struct + func (i TickerInterpreter) CreateBlock(id conflow.ID, blockCtx *conflow.BlockContext) conflow.Block + func (i TickerInterpreter) Param(b conflow.Block, name conflow.ID) interface{} + func (i TickerInterpreter) ParseContext(ctx *conflow.ParseContext) *conflow.ParseContext + func (i TickerInterpreter) Schema() schema.Schema + func (i TickerInterpreter) SetBlock(block conflow.Block, name conflow.ID, key string, value interface{}) error + func (i TickerInterpreter) SetParam(block conflow.Block, name conflow.ID, value interface{}) error + func (i TickerInterpreter) ValueParamName() conflow.ID
Go to main page