node

package

Go to main page

Versions in this module

v1

v1.14.6

Nov 11, 2024

v1.14.5

Oct 21, 2024

v1.14.4

Sep 18, 2024

v1.14.3

Aug 28, 2024

v1.14.2

Aug 20, 2024

v1.14.1

Jul 19, 2024 GO-2024-3078

GO-2024-3078: LF Edge eKuiper has a SQL Injection in sqlKvStore in github.com/lf-edge/ekuiper

v1.14.0

Jun 26, 2024 GO-2024-3078

GO-2024-3078: LF Edge eKuiper has a SQL Injection in sqlKvStore in github.com/lf-edge/ekuiper

Changes in this version

+ const BatchKey

+ const EventInputKey

+ const MsgCountKey

+ const OffsetKey

+ const StreamWMKey

+ const TriggerTimeKey

+ const WatermarkKey

+ const WindowInputsKey

+ func LookupPing(lookupType string, config map[string]interface{}) error

+ func SinkPing(sinkType string, config map[string]interface{}) error

+ func SourcePing(sourceType string, config map[string]interface{}) error

+ type BatchOp struct

+ func NewBatchOp(name string, rOpt *api.RuleOption, batchSize, lingerInterval int) (*BatchOp, error)

+ func (b *BatchOp) Exec(ctx api.StreamContext, _ chan<- error)

+ func (o BatchOp) AddInputCount()

+ func (o BatchOp) GetInput() (chan<- interface{}, string)

+ func (o BatchOp) GetInputCount() int

+ func (o BatchOp) SetBarrierHandler(bh checkpoint.BarrierHandler)

+ type DataSourceNode interface

+ GetMetrics func() []any

+ GetName func() string

+ Open func(ctx api.StreamContext, errCh chan<- error)

+ RemoveMetrics func(ruleId string)

+ type DecodeOp struct

+ func NewDecodeOp(name, StreamName string, ruleId string, rOpt *api.RuleOption, ...) (*DecodeOp, error)

+ func (o *DecodeOp) AttachSchema(ctx api.StreamContext, dataSource string, ...)

+ func (o *DecodeOp) DetachSchema(ruleId string)

+ func (o *DecodeOp) Exec(ctx api.StreamContext, errCh chan<- error)

+ func (o *DecodeOp) Worker(item any) []any

+ func (o DecodeOp) AddInputCount()

+ func (o DecodeOp) GetInput() (chan<- interface{}, string)

+ func (o DecodeOp) GetInputCount() int

+ func (o DecodeOp) SetBarrierHandler(bh checkpoint.BarrierHandler)

+ type DecompressOp struct

+ func NewDecompressOp(name string, rOpt *api.RuleOption, compressMethod string) (*DecompressOp, error)

+ func (o *DecompressOp) Exec(ctx api.StreamContext, errCh chan<- error)

+ func (o *DecompressOp) Worker(item any) []any

+ func (o DecompressOp) AddInputCount()

+ func (o DecompressOp) GetInput() (chan<- interface{}, string)

+ func (o DecompressOp) GetInputCount() int

+ func (o DecompressOp) SetBarrierHandler(bh checkpoint.BarrierHandler)

+ type DynamicChannelBuffer struct

+ In chan api.SourceTuple

+ Out chan api.SourceTuple

+ func NewDynamicChannelBuffer() *DynamicChannelBuffer

+ func (b *DynamicChannelBuffer) Close()

+ func (b *DynamicChannelBuffer) GetLength() int

+ func (b *DynamicChannelBuffer) SetLimit(limit int)

+ type EventTimeTrigger struct

+ func NewEventTimeTrigger(window *WindowConfig) (*EventTimeTrigger, error)

+ type JoinAlignNode struct

+ func NewJoinAlignNode(name string, emitters []string, options *api.RuleOption) (*JoinAlignNode, error)

+ func (n *JoinAlignNode) Exec(ctx api.StreamContext, errCh chan<- error)

+ func (o JoinAlignNode) AddInputCount()

+ func (o JoinAlignNode) GetInput() (chan<- interface{}, string)

+ func (o JoinAlignNode) GetInputCount() int

+ func (o JoinAlignNode) SetBarrierHandler(bh checkpoint.BarrierHandler)

+ type LookupConf struct

+ Cache bool

+ CacheMissingKey bool

+ CacheTTL int

+ type LookupNode struct

+ func NewLookupNode(name string, fields []string, keys []string, joinType ast.JoinType, ...) (*LookupNode, error)

+ func (n *LookupNode) Exec(ctx api.StreamContext, errCh chan<- error)

+ func (o LookupNode) AddInputCount()

+ func (o LookupNode) GetInput() (chan<- interface{}, string)

+ func (o LookupNode) GetInputCount() int

+ func (o LookupNode) SetBarrierHandler(bh checkpoint.BarrierHandler)

+ type MergeableTopo interface

+ Close func(ruleId string)

+ GetSource func() DataSourceNode

+ LinkTopo func(parentTopo *api.PrintableTopo, parentJointName string)

+ MergeSrc func(parentTopo *api.PrintableTopo)

+ SubMetrics func() ([]string, []any)

+ type OperatorNode interface

+ AddInputCount func()

+ Broadcast func(data interface{})

+ GetInputCount func() int

+ GetStreamContext func() api.StreamContext

+ RemoveMetrics func(name string)

+ SetBarrierHandler func(checkpoint.BarrierHandler)

+ SetQos func(api.Qos)

+ type SchemaNode interface

+ AttachSchema func(api.StreamContext, string, map[string]*ast.JsonStreamField, bool)

+ DetachSchema func(string)

+ type SinkConf struct

+ BatchSize int

+ BufferLength int

+ Concurrency int

+ DataField string

+ DataTemplate string

+ Delimiter string

+ Fields []string

+ Format string

+ LingerInterval int

+ Omitempty bool

+ SchemaId string

+ SendSingle bool

+ func ParseConf(logger api.Logger, props map[string]any) (*SinkConf, error)

+ type SinkNode struct

+ func NewSinkNode(name string, sinkType string, props map[string]interface{}) *SinkNode

+ func NewSinkNodeWithSink(name string, sink api.Sink, props map[string]interface{}) *SinkNode

+ func (m *SinkNode) AddOutput(_ chan<- interface{}, name string) error

+ func (m *SinkNode) Broadcast(_ interface{})

+ func (m *SinkNode) Open(ctx api.StreamContext, result chan<- error)

+ func (o SinkNode) AddInputCount()

+ func (o SinkNode) GetInput() (chan<- interface{}, string)

+ func (o SinkNode) GetInputCount() int

+ func (o SinkNode) SetBarrierHandler(bh checkpoint.BarrierHandler)

+ type SourceConnectorNode struct

+ func NewSourceConnectorNode(name string, ss api.SourceConnector, dataSource string, props map[string]any, ...) (*SourceConnectorNode, error)

+ func (m *SourceConnectorNode) Open(ctx api.StreamContext, ctrlCh chan<- error)

+ func (m *SourceConnectorNode) Run(ctx api.StreamContext, ctrlCh chan<- error)

+ func (o SourceConnectorNode) AddOutput(output chan<- interface{}, name string) error

+ func (o SourceConnectorNode) Broadcast(val interface{})

+ func (o SourceConnectorNode) GetMetrics() []any

+ func (o SourceConnectorNode) GetName() string

+ func (o SourceConnectorNode) GetStreamContext() api.StreamContext

+ func (o SourceConnectorNode) RemoveMetrics(ruleId string)

+ func (o SourceConnectorNode) SetQos(qos api.Qos)

+ type SourceInstanceNode interface

+ GetSource func() api.Source

+ type SourceNode struct

+ IsSchemaless bool

+ IsWildcard bool

+ func NewSourceNode(name string, st ast.StreamType, op UnOperation, options *ast.Options, ...) *SourceNode

+ func (m *SourceNode) GetSource() api.Source

+ func (m *SourceNode) Open(ctx api.StreamContext, errCh chan<- error)

+ func (m *SourceNode) SetProps(props map[string]interface{})

+ func (o SourceNode) AddOutput(output chan<- interface{}, name string) error

+ func (o SourceNode) Broadcast(val interface{})

+ func (o SourceNode) GetMetrics() []any

+ func (o SourceNode) GetName() string

+ func (o SourceNode) GetStreamContext() api.StreamContext

+ func (o SourceNode) RemoveMetrics(ruleId string)

+ func (o SourceNode) SetQos(qos api.Qos)

+ type SwitchConfig struct

+ Cases []ast.Expr

+ StopAtFirstMatch bool

+ type SwitchNode struct

+ func NewSwitchNode(name string, conf *SwitchConfig, options *api.RuleOption) (*SwitchNode, error)

+ func (n *SwitchNode) AddOutput(output chan<- interface{}, name string) error

+ func (n *SwitchNode) Exec(ctx api.StreamContext, errCh chan<- error)

+ func (n *SwitchNode) GetEmitter(outputIndex int) api.Emitter

+ func (o SwitchNode) AddInputCount()

+ func (o SwitchNode) GetInput() (chan<- interface{}, string)

+ func (o SwitchNode) GetInputCount() int

+ func (o SwitchNode) SetBarrierHandler(bh checkpoint.BarrierHandler)

+ type TupleList struct

+ func NewTupleList(tuples []*xsql.Tuple, windowSize int) (TupleList, error)

+ type UnFunc func(api.StreamContext, interface{}) interface

+ func (f UnFunc) Apply(ctx api.StreamContext, data interface{}) interface{}

+ type UnOperation interface

+ Apply func(ctx api.StreamContext, data interface{}, fv *xsql.FunctionValuer, ...) interface{}

+ type UnaryOperator struct

+ func New(name string, options *api.RuleOption) *UnaryOperator

+ func (o *UnaryOperator) Exec(ctx api.StreamContext, errCh chan<- error)

+ func (o *UnaryOperator) SetOperation(op UnOperation)

+ func (o UnaryOperator) AddInputCount()

+ func (o UnaryOperator) GetInput() (chan<- interface{}, string)

+ func (o UnaryOperator) GetInputCount() int

+ func (o UnaryOperator) SetBarrierHandler(bh checkpoint.BarrierHandler)

+ type WatermarkOp struct

+ func NewWatermarkOp(name string, sendWatermark bool, streams []string, options *api.RuleOption) *WatermarkOp

+ func (o WatermarkOp) AddInputCount()

+ func (o WatermarkOp) GetInput() (chan<- interface{}, string)

+ func (o WatermarkOp) GetInputCount() int

+ func (o WatermarkOp) SetBarrierHandler(bh checkpoint.BarrierHandler)

+ func (w *WatermarkOp) Exec(ctx api.StreamContext, errCh chan<- error)

+ type WindowConfig struct

+ Delay int64

+ Interval int64

+ Length int64

+ RawInterval int

+ StateFuncs []*ast.Call

+ TimeUnit ast.Token

+ TriggerCondition ast.Expr

+ Type ast.WindowType

+ type WindowOperator struct

+ func NewWindowOp(name string, w WindowConfig, options *api.RuleOption) (*WindowOperator, error)

+ func (o *WindowOperator) Exec(ctx api.StreamContext, errCh chan<- error)

+ func (o WindowOperator) AddInputCount()

+ func (o WindowOperator) GetInput() (chan<- interface{}, string)

+ func (o WindowOperator) GetInputCount() int

+ func (o WindowOperator) SetBarrierHandler(bh checkpoint.BarrierHandler)

v1.14.0-dev.1

Mar 25, 2024 GO-2024-3078

GO-2024-3078: LF Edge eKuiper has a SQL Injection in sqlKvStore in github.com/lf-edge/ekuiper

v1.14.0-beta.4

Jun 18, 2024 GO-2024-3078

GO-2024-3078: LF Edge eKuiper has a SQL Injection in sqlKvStore in github.com/lf-edge/ekuiper

v1.14.0-beta.3

Jun 14, 2024 GO-2024-3078

GO-2024-3078: LF Edge eKuiper has a SQL Injection in sqlKvStore in github.com/lf-edge/ekuiper

v1.14.0-beta.2

Jun 6, 2024 GO-2024-3078

GO-2024-3078: LF Edge eKuiper has a SQL Injection in sqlKvStore in github.com/lf-edge/ekuiper

v1.14.0-beta.1

Jun 4, 2024 GO-2024-3078

GO-2024-3078: LF Edge eKuiper has a SQL Injection in sqlKvStore in github.com/lf-edge/ekuiper

v1.14.0-alpha.4

May 16, 2024 GO-2024-3078

GO-2024-3078: LF Edge eKuiper has a SQL Injection in sqlKvStore in github.com/lf-edge/ekuiper

v1.14.0-alpha.3

May 10, 2024 GO-2024-3078

GO-2024-3078: LF Edge eKuiper has a SQL Injection in sqlKvStore in github.com/lf-edge/ekuiper

v1.14.0-alpha.2

Mar 29, 2024 GO-2024-3078

GO-2024-3078: LF Edge eKuiper has a SQL Injection in sqlKvStore in github.com/lf-edge/ekuiper

v1.14.0-alpha.1

Mar 22, 2024 GO-2024-3078

GO-2024-3078: LF Edge eKuiper has a SQL Injection in sqlKvStore in github.com/lf-edge/ekuiper

v1.14.0-alpha.0

Mar 25, 2024 GO-2024-3078

GO-2024-3078: LF Edge eKuiper has a SQL Injection in sqlKvStore in github.com/lf-edge/ekuiper

v1.4.0-beta.2

Jun 6, 2024 GO-2024-3078

GO-2024-3078: LF Edge eKuiper has a SQL Injection in sqlKvStore in github.com/lf-edge/ekuiper

Other modules containing this package

github.com/lf-edge/ekuiper/v2

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