Versions in this module Expand all Collapse all v0 v0.0.1 Apr 9, 2019 Changes in this version + const BitflowLexerCLOSE + const BitflowLexerCLOSE_HINTS + const BitflowLexerCLOSE_PARAMS + const BitflowLexerCOMMENT + const BitflowLexerEOP + const BitflowLexerEQ + const BitflowLexerIDENTIFIER + const BitflowLexerNEWLINE + const BitflowLexerNEXT + const BitflowLexerOPEN + const BitflowLexerOPEN_HINTS + const BitflowLexerOPEN_PARAMS + const BitflowLexerSEP + const BitflowLexerSTRING + const BitflowLexerTAB + const BitflowLexerWHITESPACE + const BitflowLexerWINDOW + const BitflowParserCLOSE + const BitflowParserCLOSE_HINTS + const BitflowParserCLOSE_PARAMS + const BitflowParserCOMMENT + const BitflowParserEOF + const BitflowParserEOP + const BitflowParserEQ + const BitflowParserIDENTIFIER + const BitflowParserNEWLINE + const BitflowParserNEXT + const BitflowParserOPEN + const BitflowParserOPEN_HINTS + const BitflowParserOPEN_PARAMS + const BitflowParserRULE_dataInput + const BitflowParserRULE_dataOutput + const BitflowParserRULE_fork + const BitflowParserRULE_multiplexFork + const BitflowParserRULE_name + const BitflowParserRULE_namedSubPipeline + const BitflowParserRULE_parameter + const BitflowParserRULE_parameterList + const BitflowParserRULE_parameters + const BitflowParserRULE_pipeline + const BitflowParserRULE_pipelineElement + const BitflowParserRULE_pipelineTailElement + const BitflowParserRULE_pipelines + const BitflowParserRULE_processingStep + const BitflowParserRULE_schedulingHints + const BitflowParserRULE_script + const BitflowParserRULE_subPipeline + const BitflowParserRULE_window + const BitflowParserSEP + const BitflowParserSTRING + const BitflowParserTAB + const BitflowParserWHITESPACE + const BitflowParserWINDOW + type BaseBitflowListener struct + func (s *BaseBitflowListener) EnterDataInput(ctx *DataInputContext) + func (s *BaseBitflowListener) EnterDataOutput(ctx *DataOutputContext) + func (s *BaseBitflowListener) EnterEveryRule(ctx antlr.ParserRuleContext) + func (s *BaseBitflowListener) EnterFork(ctx *ForkContext) + func (s *BaseBitflowListener) EnterMultiplexFork(ctx *MultiplexForkContext) + func (s *BaseBitflowListener) EnterName(ctx *NameContext) + func (s *BaseBitflowListener) EnterNamedSubPipeline(ctx *NamedSubPipelineContext) + func (s *BaseBitflowListener) EnterParameter(ctx *ParameterContext) + func (s *BaseBitflowListener) EnterParameterList(ctx *ParameterListContext) + func (s *BaseBitflowListener) EnterParameters(ctx *ParametersContext) + func (s *BaseBitflowListener) EnterPipeline(ctx *PipelineContext) + func (s *BaseBitflowListener) EnterPipelineElement(ctx *PipelineElementContext) + func (s *BaseBitflowListener) EnterPipelineTailElement(ctx *PipelineTailElementContext) + func (s *BaseBitflowListener) EnterPipelines(ctx *PipelinesContext) + func (s *BaseBitflowListener) EnterProcessingStep(ctx *ProcessingStepContext) + func (s *BaseBitflowListener) EnterSchedulingHints(ctx *SchedulingHintsContext) + func (s *BaseBitflowListener) EnterScript(ctx *ScriptContext) + func (s *BaseBitflowListener) EnterSubPipeline(ctx *SubPipelineContext) + func (s *BaseBitflowListener) EnterWindow(ctx *WindowContext) + func (s *BaseBitflowListener) ExitDataInput(ctx *DataInputContext) + func (s *BaseBitflowListener) ExitDataOutput(ctx *DataOutputContext) + func (s *BaseBitflowListener) ExitEveryRule(ctx antlr.ParserRuleContext) + func (s *BaseBitflowListener) ExitFork(ctx *ForkContext) + func (s *BaseBitflowListener) ExitMultiplexFork(ctx *MultiplexForkContext) + func (s *BaseBitflowListener) ExitName(ctx *NameContext) + func (s *BaseBitflowListener) ExitNamedSubPipeline(ctx *NamedSubPipelineContext) + func (s *BaseBitflowListener) ExitParameter(ctx *ParameterContext) + func (s *BaseBitflowListener) ExitParameterList(ctx *ParameterListContext) + func (s *BaseBitflowListener) ExitParameters(ctx *ParametersContext) + func (s *BaseBitflowListener) ExitPipeline(ctx *PipelineContext) + func (s *BaseBitflowListener) ExitPipelineElement(ctx *PipelineElementContext) + func (s *BaseBitflowListener) ExitPipelineTailElement(ctx *PipelineTailElementContext) + func (s *BaseBitflowListener) ExitPipelines(ctx *PipelinesContext) + func (s *BaseBitflowListener) ExitProcessingStep(ctx *ProcessingStepContext) + func (s *BaseBitflowListener) ExitSchedulingHints(ctx *SchedulingHintsContext) + func (s *BaseBitflowListener) ExitScript(ctx *ScriptContext) + func (s *BaseBitflowListener) ExitSubPipeline(ctx *SubPipelineContext) + func (s *BaseBitflowListener) ExitWindow(ctx *WindowContext) + func (s *BaseBitflowListener) VisitErrorNode(node antlr.ErrorNode) + func (s *BaseBitflowListener) VisitTerminal(node antlr.TerminalNode) + type BaseBitflowVisitor struct + func (v *BaseBitflowVisitor) VisitDataInput(ctx *DataInputContext) interface{} + func (v *BaseBitflowVisitor) VisitDataOutput(ctx *DataOutputContext) interface{} + func (v *BaseBitflowVisitor) VisitFork(ctx *ForkContext) interface{} + func (v *BaseBitflowVisitor) VisitMultiplexFork(ctx *MultiplexForkContext) interface{} + func (v *BaseBitflowVisitor) VisitName(ctx *NameContext) interface{} + func (v *BaseBitflowVisitor) VisitNamedSubPipeline(ctx *NamedSubPipelineContext) interface{} + func (v *BaseBitflowVisitor) VisitParameter(ctx *ParameterContext) interface{} + func (v *BaseBitflowVisitor) VisitParameterList(ctx *ParameterListContext) interface{} + func (v *BaseBitflowVisitor) VisitParameters(ctx *ParametersContext) interface{} + func (v *BaseBitflowVisitor) VisitPipeline(ctx *PipelineContext) interface{} + func (v *BaseBitflowVisitor) VisitPipelineElement(ctx *PipelineElementContext) interface{} + func (v *BaseBitflowVisitor) VisitPipelineTailElement(ctx *PipelineTailElementContext) interface{} + func (v *BaseBitflowVisitor) VisitPipelines(ctx *PipelinesContext) interface{} + func (v *BaseBitflowVisitor) VisitProcessingStep(ctx *ProcessingStepContext) interface{} + func (v *BaseBitflowVisitor) VisitSchedulingHints(ctx *SchedulingHintsContext) interface{} + func (v *BaseBitflowVisitor) VisitScript(ctx *ScriptContext) interface{} + func (v *BaseBitflowVisitor) VisitSubPipeline(ctx *SubPipelineContext) interface{} + func (v *BaseBitflowVisitor) VisitWindow(ctx *WindowContext) interface{} + type BitflowLexer struct + func NewBitflowLexer(input antlr.CharStream) *BitflowLexer + type BitflowListener interface + EnterDataInput func(c *DataInputContext) + EnterDataOutput func(c *DataOutputContext) + EnterFork func(c *ForkContext) + EnterMultiplexFork func(c *MultiplexForkContext) + EnterName func(c *NameContext) + EnterNamedSubPipeline func(c *NamedSubPipelineContext) + EnterParameter func(c *ParameterContext) + EnterParameterList func(c *ParameterListContext) + EnterParameters func(c *ParametersContext) + EnterPipeline func(c *PipelineContext) + EnterPipelineElement func(c *PipelineElementContext) + EnterPipelineTailElement func(c *PipelineTailElementContext) + EnterPipelines func(c *PipelinesContext) + EnterProcessingStep func(c *ProcessingStepContext) + EnterSchedulingHints func(c *SchedulingHintsContext) + EnterScript func(c *ScriptContext) + EnterSubPipeline func(c *SubPipelineContext) + EnterWindow func(c *WindowContext) + ExitDataInput func(c *DataInputContext) + ExitDataOutput func(c *DataOutputContext) + ExitFork func(c *ForkContext) + ExitMultiplexFork func(c *MultiplexForkContext) + ExitName func(c *NameContext) + ExitNamedSubPipeline func(c *NamedSubPipelineContext) + ExitParameter func(c *ParameterContext) + ExitParameterList func(c *ParameterListContext) + ExitParameters func(c *ParametersContext) + ExitPipeline func(c *PipelineContext) + ExitPipelineElement func(c *PipelineElementContext) + ExitPipelineTailElement func(c *PipelineTailElementContext) + ExitPipelines func(c *PipelinesContext) + ExitProcessingStep func(c *ProcessingStepContext) + ExitSchedulingHints func(c *SchedulingHintsContext) + ExitScript func(c *ScriptContext) + ExitSubPipeline func(c *SubPipelineContext) + ExitWindow func(c *WindowContext) + type BitflowParser struct + func NewBitflowParser(input antlr.TokenStream) *BitflowParser + func (p *BitflowParser) DataInput() (localctx IDataInputContext) + func (p *BitflowParser) DataOutput() (localctx IDataOutputContext) + func (p *BitflowParser) Fork() (localctx IForkContext) + func (p *BitflowParser) MultiplexFork() (localctx IMultiplexForkContext) + func (p *BitflowParser) Name() (localctx INameContext) + func (p *BitflowParser) NamedSubPipeline() (localctx INamedSubPipelineContext) + func (p *BitflowParser) Parameter() (localctx IParameterContext) + func (p *BitflowParser) ParameterList() (localctx IParameterListContext) + func (p *BitflowParser) Parameters() (localctx IParametersContext) + func (p *BitflowParser) Pipeline() (localctx IPipelineContext) + func (p *BitflowParser) PipelineElement() (localctx IPipelineElementContext) + func (p *BitflowParser) PipelineTailElement() (localctx IPipelineTailElementContext) + func (p *BitflowParser) Pipelines() (localctx IPipelinesContext) + func (p *BitflowParser) ProcessingStep() (localctx IProcessingStepContext) + func (p *BitflowParser) SchedulingHints() (localctx ISchedulingHintsContext) + func (p *BitflowParser) Script() (localctx IScriptContext) + func (p *BitflowParser) SubPipeline() (localctx ISubPipelineContext) + func (p *BitflowParser) Window() (localctx IWindowContext) + type BitflowVisitor interface + VisitDataInput func(ctx *DataInputContext) interface{} + VisitDataOutput func(ctx *DataOutputContext) interface{} + VisitFork func(ctx *ForkContext) interface{} + VisitMultiplexFork func(ctx *MultiplexForkContext) interface{} + VisitName func(ctx *NameContext) interface{} + VisitNamedSubPipeline func(ctx *NamedSubPipelineContext) interface{} + VisitParameter func(ctx *ParameterContext) interface{} + VisitParameterList func(ctx *ParameterListContext) interface{} + VisitParameters func(ctx *ParametersContext) interface{} + VisitPipeline func(ctx *PipelineContext) interface{} + VisitPipelineElement func(ctx *PipelineElementContext) interface{} + VisitPipelineTailElement func(ctx *PipelineTailElementContext) interface{} + VisitPipelines func(ctx *PipelinesContext) interface{} + VisitProcessingStep func(ctx *ProcessingStepContext) interface{} + VisitSchedulingHints func(ctx *SchedulingHintsContext) interface{} + VisitScript func(ctx *ScriptContext) interface{} + VisitSubPipeline func(ctx *SubPipelineContext) interface{} + VisitWindow func(ctx *WindowContext) interface{} + type DataInputContext struct + func NewDataInputContext(parser antlr.Parser, parent antlr.ParserRuleContext, invokingState int) *DataInputContext + func NewEmptyDataInputContext() *DataInputContext + func (*DataInputContext) IsDataInputContext() + func (s *DataInputContext) Accept(visitor antlr.ParseTreeVisitor) interface{} + func (s *DataInputContext) AllName() []INameContext + func (s *DataInputContext) EnterRule(listener antlr.ParseTreeListener) + func (s *DataInputContext) ExitRule(listener antlr.ParseTreeListener) + func (s *DataInputContext) GetParser() antlr.Parser + func (s *DataInputContext) GetRuleContext() antlr.RuleContext + func (s *DataInputContext) Name(i int) INameContext + func (s *DataInputContext) SchedulingHints() ISchedulingHintsContext + func (s *DataInputContext) ToStringTree(ruleNames []string, recog antlr.Recognizer) string + type DataOutputContext struct + func NewDataOutputContext(parser antlr.Parser, parent antlr.ParserRuleContext, invokingState int) *DataOutputContext + func NewEmptyDataOutputContext() *DataOutputContext + func (*DataOutputContext) IsDataOutputContext() + func (s *DataOutputContext) Accept(visitor antlr.ParseTreeVisitor) interface{} + func (s *DataOutputContext) EnterRule(listener antlr.ParseTreeListener) + func (s *DataOutputContext) ExitRule(listener antlr.ParseTreeListener) + func (s *DataOutputContext) GetParser() antlr.Parser + func (s *DataOutputContext) GetRuleContext() antlr.RuleContext + func (s *DataOutputContext) Name() INameContext + func (s *DataOutputContext) SchedulingHints() ISchedulingHintsContext + func (s *DataOutputContext) ToStringTree(ruleNames []string, recog antlr.Recognizer) string + type ForkContext struct + func NewEmptyForkContext() *ForkContext + func NewForkContext(parser antlr.Parser, parent antlr.ParserRuleContext, invokingState int) *ForkContext + func (*ForkContext) IsForkContext() + func (s *ForkContext) Accept(visitor antlr.ParseTreeVisitor) interface{} + func (s *ForkContext) AllEOP() []antlr.TerminalNode + func (s *ForkContext) AllNamedSubPipeline() []INamedSubPipelineContext + func (s *ForkContext) CLOSE() antlr.TerminalNode + func (s *ForkContext) EOP(i int) antlr.TerminalNode + func (s *ForkContext) EnterRule(listener antlr.ParseTreeListener) + func (s *ForkContext) ExitRule(listener antlr.ParseTreeListener) + func (s *ForkContext) GetParser() antlr.Parser + func (s *ForkContext) GetRuleContext() antlr.RuleContext + func (s *ForkContext) Name() INameContext + func (s *ForkContext) NamedSubPipeline(i int) INamedSubPipelineContext + func (s *ForkContext) OPEN() antlr.TerminalNode + func (s *ForkContext) Parameters() IParametersContext + func (s *ForkContext) SchedulingHints() ISchedulingHintsContext + func (s *ForkContext) ToStringTree(ruleNames []string, recog antlr.Recognizer) string + type IDataInputContext interface + GetParser func() antlr.Parser + IsDataInputContext func() + type IDataOutputContext interface + GetParser func() antlr.Parser + IsDataOutputContext func() + type IForkContext interface + GetParser func() antlr.Parser + IsForkContext func() + type IMultiplexForkContext interface + GetParser func() antlr.Parser + IsMultiplexForkContext func() + type INameContext interface + GetParser func() antlr.Parser + IsNameContext func() + type INamedSubPipelineContext interface + GetParser func() antlr.Parser + IsNamedSubPipelineContext func() + type IParameterContext interface + GetParser func() antlr.Parser + IsParameterContext func() + type IParameterListContext interface + GetParser func() antlr.Parser + IsParameterListContext func() + type IParametersContext interface + GetParser func() antlr.Parser + IsParametersContext func() + type IPipelineContext interface + GetParser func() antlr.Parser + IsPipelineContext func() + type IPipelineElementContext interface + GetParser func() antlr.Parser + IsPipelineElementContext func() + type IPipelineTailElementContext interface + GetParser func() antlr.Parser + IsPipelineTailElementContext func() + type IPipelinesContext interface + GetParser func() antlr.Parser + IsPipelinesContext func() + type IProcessingStepContext interface + GetParser func() antlr.Parser + IsProcessingStepContext func() + type ISchedulingHintsContext interface + GetParser func() antlr.Parser + IsSchedulingHintsContext func() + type IScriptContext interface + GetParser func() antlr.Parser + IsScriptContext func() + type ISubPipelineContext interface + GetParser func() antlr.Parser + IsSubPipelineContext func() + type IWindowContext interface + GetParser func() antlr.Parser + IsWindowContext func() + type MultiplexForkContext struct + func NewEmptyMultiplexForkContext() *MultiplexForkContext + func NewMultiplexForkContext(parser antlr.Parser, parent antlr.ParserRuleContext, invokingState int) *MultiplexForkContext + func (*MultiplexForkContext) IsMultiplexForkContext() + func (s *MultiplexForkContext) Accept(visitor antlr.ParseTreeVisitor) interface{} + func (s *MultiplexForkContext) AllEOP() []antlr.TerminalNode + func (s *MultiplexForkContext) AllSubPipeline() []ISubPipelineContext + func (s *MultiplexForkContext) CLOSE() antlr.TerminalNode + func (s *MultiplexForkContext) EOP(i int) antlr.TerminalNode + func (s *MultiplexForkContext) EnterRule(listener antlr.ParseTreeListener) + func (s *MultiplexForkContext) ExitRule(listener antlr.ParseTreeListener) + func (s *MultiplexForkContext) GetParser() antlr.Parser + func (s *MultiplexForkContext) GetRuleContext() antlr.RuleContext + func (s *MultiplexForkContext) OPEN() antlr.TerminalNode + func (s *MultiplexForkContext) SubPipeline(i int) ISubPipelineContext + func (s *MultiplexForkContext) ToStringTree(ruleNames []string, recog antlr.Recognizer) string + type NameContext struct + func NewEmptyNameContext() *NameContext + func NewNameContext(parser antlr.Parser, parent antlr.ParserRuleContext, invokingState int) *NameContext + func (*NameContext) IsNameContext() + func (s *NameContext) Accept(visitor antlr.ParseTreeVisitor) interface{} + func (s *NameContext) EnterRule(listener antlr.ParseTreeListener) + func (s *NameContext) ExitRule(listener antlr.ParseTreeListener) + func (s *NameContext) GetParser() antlr.Parser + func (s *NameContext) GetRuleContext() antlr.RuleContext + func (s *NameContext) IDENTIFIER() antlr.TerminalNode + func (s *NameContext) STRING() antlr.TerminalNode + func (s *NameContext) ToStringTree(ruleNames []string, recog antlr.Recognizer) string + type NamedSubPipelineContext struct + func NewEmptyNamedSubPipelineContext() *NamedSubPipelineContext + func NewNamedSubPipelineContext(parser antlr.Parser, parent antlr.ParserRuleContext, invokingState int) *NamedSubPipelineContext + func (*NamedSubPipelineContext) IsNamedSubPipelineContext() + func (s *NamedSubPipelineContext) Accept(visitor antlr.ParseTreeVisitor) interface{} + func (s *NamedSubPipelineContext) AllName() []INameContext + func (s *NamedSubPipelineContext) EnterRule(listener antlr.ParseTreeListener) + func (s *NamedSubPipelineContext) ExitRule(listener antlr.ParseTreeListener) + func (s *NamedSubPipelineContext) GetParser() antlr.Parser + func (s *NamedSubPipelineContext) GetRuleContext() antlr.RuleContext + func (s *NamedSubPipelineContext) NEXT() antlr.TerminalNode + func (s *NamedSubPipelineContext) Name(i int) INameContext + func (s *NamedSubPipelineContext) SubPipeline() ISubPipelineContext + func (s *NamedSubPipelineContext) ToStringTree(ruleNames []string, recog antlr.Recognizer) string + type ParameterContext struct + func NewEmptyParameterContext() *ParameterContext + func NewParameterContext(parser antlr.Parser, parent antlr.ParserRuleContext, invokingState int) *ParameterContext + func (*ParameterContext) IsParameterContext() + func (s *ParameterContext) Accept(visitor antlr.ParseTreeVisitor) interface{} + func (s *ParameterContext) AllName() []INameContext + func (s *ParameterContext) EQ() antlr.TerminalNode + func (s *ParameterContext) EnterRule(listener antlr.ParseTreeListener) + func (s *ParameterContext) ExitRule(listener antlr.ParseTreeListener) + func (s *ParameterContext) GetParser() antlr.Parser + func (s *ParameterContext) GetRuleContext() antlr.RuleContext + func (s *ParameterContext) Name(i int) INameContext + func (s *ParameterContext) ToStringTree(ruleNames []string, recog antlr.Recognizer) string + type ParameterListContext struct + func NewEmptyParameterListContext() *ParameterListContext + func NewParameterListContext(parser antlr.Parser, parent antlr.ParserRuleContext, invokingState int) *ParameterListContext + func (*ParameterListContext) IsParameterListContext() + func (s *ParameterListContext) Accept(visitor antlr.ParseTreeVisitor) interface{} + func (s *ParameterListContext) AllParameter() []IParameterContext + func (s *ParameterListContext) AllSEP() []antlr.TerminalNode + func (s *ParameterListContext) EnterRule(listener antlr.ParseTreeListener) + func (s *ParameterListContext) ExitRule(listener antlr.ParseTreeListener) + func (s *ParameterListContext) GetParser() antlr.Parser + func (s *ParameterListContext) GetRuleContext() antlr.RuleContext + func (s *ParameterListContext) Parameter(i int) IParameterContext + func (s *ParameterListContext) SEP(i int) antlr.TerminalNode + func (s *ParameterListContext) ToStringTree(ruleNames []string, recog antlr.Recognizer) string + type ParametersContext struct + func NewEmptyParametersContext() *ParametersContext + func NewParametersContext(parser antlr.Parser, parent antlr.ParserRuleContext, invokingState int) *ParametersContext + func (*ParametersContext) IsParametersContext() + func (s *ParametersContext) Accept(visitor antlr.ParseTreeVisitor) interface{} + func (s *ParametersContext) CLOSE_PARAMS() antlr.TerminalNode + func (s *ParametersContext) EnterRule(listener antlr.ParseTreeListener) + func (s *ParametersContext) ExitRule(listener antlr.ParseTreeListener) + func (s *ParametersContext) GetParser() antlr.Parser + func (s *ParametersContext) GetRuleContext() antlr.RuleContext + func (s *ParametersContext) OPEN_PARAMS() antlr.TerminalNode + func (s *ParametersContext) ParameterList() IParameterListContext + func (s *ParametersContext) SEP() antlr.TerminalNode + func (s *ParametersContext) ToStringTree(ruleNames []string, recog antlr.Recognizer) string + type PipelineContext struct + func NewEmptyPipelineContext() *PipelineContext + func NewPipelineContext(parser antlr.Parser, parent antlr.ParserRuleContext, invokingState int) *PipelineContext + func (*PipelineContext) IsPipelineContext() + func (s *PipelineContext) Accept(visitor antlr.ParseTreeVisitor) interface{} + func (s *PipelineContext) AllNEXT() []antlr.TerminalNode + func (s *PipelineContext) AllPipelineTailElement() []IPipelineTailElementContext + func (s *PipelineContext) CLOSE() antlr.TerminalNode + func (s *PipelineContext) DataInput() IDataInputContext + func (s *PipelineContext) EnterRule(listener antlr.ParseTreeListener) + func (s *PipelineContext) ExitRule(listener antlr.ParseTreeListener) + func (s *PipelineContext) GetParser() antlr.Parser + func (s *PipelineContext) GetRuleContext() antlr.RuleContext + func (s *PipelineContext) NEXT(i int) antlr.TerminalNode + func (s *PipelineContext) OPEN() antlr.TerminalNode + func (s *PipelineContext) PipelineElement() IPipelineElementContext + func (s *PipelineContext) PipelineTailElement(i int) IPipelineTailElementContext + func (s *PipelineContext) Pipelines() IPipelinesContext + func (s *PipelineContext) ToStringTree(ruleNames []string, recog antlr.Recognizer) string + type PipelineElementContext struct + func NewEmptyPipelineElementContext() *PipelineElementContext + func NewPipelineElementContext(parser antlr.Parser, parent antlr.ParserRuleContext, invokingState int) *PipelineElementContext + func (*PipelineElementContext) IsPipelineElementContext() + func (s *PipelineElementContext) Accept(visitor antlr.ParseTreeVisitor) interface{} + func (s *PipelineElementContext) EnterRule(listener antlr.ParseTreeListener) + func (s *PipelineElementContext) ExitRule(listener antlr.ParseTreeListener) + func (s *PipelineElementContext) Fork() IForkContext + func (s *PipelineElementContext) GetParser() antlr.Parser + func (s *PipelineElementContext) GetRuleContext() antlr.RuleContext + func (s *PipelineElementContext) ProcessingStep() IProcessingStepContext + func (s *PipelineElementContext) ToStringTree(ruleNames []string, recog antlr.Recognizer) string + func (s *PipelineElementContext) Window() IWindowContext + type PipelineTailElementContext struct + func NewEmptyPipelineTailElementContext() *PipelineTailElementContext + func NewPipelineTailElementContext(parser antlr.Parser, parent antlr.ParserRuleContext, invokingState int) *PipelineTailElementContext + func (*PipelineTailElementContext) IsPipelineTailElementContext() + func (s *PipelineTailElementContext) Accept(visitor antlr.ParseTreeVisitor) interface{} + func (s *PipelineTailElementContext) DataOutput() IDataOutputContext + func (s *PipelineTailElementContext) EnterRule(listener antlr.ParseTreeListener) + func (s *PipelineTailElementContext) ExitRule(listener antlr.ParseTreeListener) + func (s *PipelineTailElementContext) GetParser() antlr.Parser + func (s *PipelineTailElementContext) GetRuleContext() antlr.RuleContext + func (s *PipelineTailElementContext) MultiplexFork() IMultiplexForkContext + func (s *PipelineTailElementContext) PipelineElement() IPipelineElementContext + func (s *PipelineTailElementContext) ToStringTree(ruleNames []string, recog antlr.Recognizer) string + type PipelinesContext struct + func NewEmptyPipelinesContext() *PipelinesContext + func NewPipelinesContext(parser antlr.Parser, parent antlr.ParserRuleContext, invokingState int) *PipelinesContext + func (*PipelinesContext) IsPipelinesContext() + func (s *PipelinesContext) Accept(visitor antlr.ParseTreeVisitor) interface{} + func (s *PipelinesContext) AllEOP() []antlr.TerminalNode + func (s *PipelinesContext) AllPipeline() []IPipelineContext + func (s *PipelinesContext) EOP(i int) antlr.TerminalNode + func (s *PipelinesContext) EnterRule(listener antlr.ParseTreeListener) + func (s *PipelinesContext) ExitRule(listener antlr.ParseTreeListener) + func (s *PipelinesContext) GetParser() antlr.Parser + func (s *PipelinesContext) GetRuleContext() antlr.RuleContext + func (s *PipelinesContext) Pipeline(i int) IPipelineContext + func (s *PipelinesContext) ToStringTree(ruleNames []string, recog antlr.Recognizer) string + type ProcessingStepContext struct + func NewEmptyProcessingStepContext() *ProcessingStepContext + func NewProcessingStepContext(parser antlr.Parser, parent antlr.ParserRuleContext, invokingState int) *ProcessingStepContext + func (*ProcessingStepContext) IsProcessingStepContext() + func (s *ProcessingStepContext) Accept(visitor antlr.ParseTreeVisitor) interface{} + func (s *ProcessingStepContext) EnterRule(listener antlr.ParseTreeListener) + func (s *ProcessingStepContext) ExitRule(listener antlr.ParseTreeListener) + func (s *ProcessingStepContext) GetParser() antlr.Parser + func (s *ProcessingStepContext) GetRuleContext() antlr.RuleContext + func (s *ProcessingStepContext) Name() INameContext + func (s *ProcessingStepContext) Parameters() IParametersContext + func (s *ProcessingStepContext) SchedulingHints() ISchedulingHintsContext + func (s *ProcessingStepContext) ToStringTree(ruleNames []string, recog antlr.Recognizer) string + type SchedulingHintsContext struct + func NewEmptySchedulingHintsContext() *SchedulingHintsContext + func NewSchedulingHintsContext(parser antlr.Parser, parent antlr.ParserRuleContext, invokingState int) *SchedulingHintsContext + func (*SchedulingHintsContext) IsSchedulingHintsContext() + func (s *SchedulingHintsContext) Accept(visitor antlr.ParseTreeVisitor) interface{} + func (s *SchedulingHintsContext) CLOSE_HINTS() antlr.TerminalNode + func (s *SchedulingHintsContext) EnterRule(listener antlr.ParseTreeListener) + func (s *SchedulingHintsContext) ExitRule(listener antlr.ParseTreeListener) + func (s *SchedulingHintsContext) GetParser() antlr.Parser + func (s *SchedulingHintsContext) GetRuleContext() antlr.RuleContext + func (s *SchedulingHintsContext) OPEN_HINTS() antlr.TerminalNode + func (s *SchedulingHintsContext) ParameterList() IParameterListContext + func (s *SchedulingHintsContext) SEP() antlr.TerminalNode + func (s *SchedulingHintsContext) ToStringTree(ruleNames []string, recog antlr.Recognizer) string + type ScriptContext struct + func NewEmptyScriptContext() *ScriptContext + func NewScriptContext(parser antlr.Parser, parent antlr.ParserRuleContext, invokingState int) *ScriptContext + func (*ScriptContext) IsScriptContext() + func (s *ScriptContext) Accept(visitor antlr.ParseTreeVisitor) interface{} + func (s *ScriptContext) EOF() antlr.TerminalNode + func (s *ScriptContext) EnterRule(listener antlr.ParseTreeListener) + func (s *ScriptContext) ExitRule(listener antlr.ParseTreeListener) + func (s *ScriptContext) GetParser() antlr.Parser + func (s *ScriptContext) GetRuleContext() antlr.RuleContext + func (s *ScriptContext) Pipelines() IPipelinesContext + func (s *ScriptContext) ToStringTree(ruleNames []string, recog antlr.Recognizer) string + type SubPipelineContext struct + func NewEmptySubPipelineContext() *SubPipelineContext + func NewSubPipelineContext(parser antlr.Parser, parent antlr.ParserRuleContext, invokingState int) *SubPipelineContext + func (*SubPipelineContext) IsSubPipelineContext() + func (s *SubPipelineContext) Accept(visitor antlr.ParseTreeVisitor) interface{} + func (s *SubPipelineContext) AllNEXT() []antlr.TerminalNode + func (s *SubPipelineContext) AllPipelineTailElement() []IPipelineTailElementContext + func (s *SubPipelineContext) EnterRule(listener antlr.ParseTreeListener) + func (s *SubPipelineContext) ExitRule(listener antlr.ParseTreeListener) + func (s *SubPipelineContext) GetParser() antlr.Parser + func (s *SubPipelineContext) GetRuleContext() antlr.RuleContext + func (s *SubPipelineContext) NEXT(i int) antlr.TerminalNode + func (s *SubPipelineContext) PipelineTailElement(i int) IPipelineTailElementContext + func (s *SubPipelineContext) ToStringTree(ruleNames []string, recog antlr.Recognizer) string + type WindowContext struct + func NewEmptyWindowContext() *WindowContext + func NewWindowContext(parser antlr.Parser, parent antlr.ParserRuleContext, invokingState int) *WindowContext + func (*WindowContext) IsWindowContext() + func (s *WindowContext) Accept(visitor antlr.ParseTreeVisitor) interface{} + func (s *WindowContext) AllNEXT() []antlr.TerminalNode + func (s *WindowContext) AllProcessingStep() []IProcessingStepContext + func (s *WindowContext) CLOSE() antlr.TerminalNode + func (s *WindowContext) EnterRule(listener antlr.ParseTreeListener) + func (s *WindowContext) ExitRule(listener antlr.ParseTreeListener) + func (s *WindowContext) GetParser() antlr.Parser + func (s *WindowContext) GetRuleContext() antlr.RuleContext + func (s *WindowContext) NEXT(i int) antlr.TerminalNode + func (s *WindowContext) OPEN() antlr.TerminalNode + func (s *WindowContext) Parameters() IParametersContext + func (s *WindowContext) ProcessingStep(i int) IProcessingStepContext + func (s *WindowContext) SchedulingHints() ISchedulingHintsContext + func (s *WindowContext) ToStringTree(ruleNames []string, recog antlr.Recognizer) string + func (s *WindowContext) WINDOW() antlr.TerminalNode