api

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

+ type Closable interface

+ Close func(ctx StreamContext) error

+ type Collector interface

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

+ type DatetimeRange struct

+ Begin string

+ BeginTimestamp int64

+ End string

+ EndTimestamp int64

+ type DefaultSourceTuple struct

+ M map[string]interface{}

+ Mess map[string]interface{}

+ Time time.Time

+ func NewDefaultRawTuple(raw []byte, meta map[string]interface{}, ts time.Time) *DefaultSourceTuple

+ func NewDefaultSourceTuple(message map[string]interface{}, meta map[string]interface{}) *DefaultSourceTuple

+ func NewDefaultSourceTupleWithTime(message map[string]interface{}, meta map[string]interface{}, ...) *DefaultSourceTuple

+ func (t *DefaultSourceTuple) Message() map[string]interface{}

+ func (t *DefaultSourceTuple) Meta() map[string]interface{}

+ func (t *DefaultSourceTuple) Raw() []byte

+ func (t *DefaultSourceTuple) Timestamp() time.Time

+ type Emitter interface

+ AddOutput func(chan<- interface{}, string) error

+ type Function interface

+ Exec func(args []interface{}, ctx FunctionContext) (interface{}, bool)

+ IsAggregate func() bool

+ Validate func(args []interface{}) error

+ type FunctionContext interface

+ GetFuncId func() int

+ type GraphNode struct

+ NodeType string

+ Props map[string]interface{}

+ Type string

+ UI map[string]interface{}

+ type Logger interface

+ Debug func(args ...interface{})

+ Debugf func(format string, args ...interface{})

+ Debugln func(args ...interface{})

+ Error func(args ...interface{})

+ Errorf func(format string, args ...interface{})

+ Errorln func(args ...interface{})

+ Info func(args ...interface{})

+ Infof func(format string, args ...interface{})

+ Infoln func(args ...interface{})

+ Warn func(args ...interface{})

+ Warnf func(format string, args ...interface{})

+ Warnln func(args ...interface{})

+ type LookupSource interface

+ Configure func(datasource string, props map[string]interface{}) error

+ Lookup func(ctx StreamContext, fields []string, keys []string, values []interface{}) ([]SourceTuple, error)

+ Open func(ctx StreamContext) error

+ type MessageClient interface

+ Ping func() error

+ Publish func(c StreamContext, topic string, message []byte, params map[string]interface{}) error

+ Subscribe func(c StreamContext, subChan []TopicChannel, messageErrors chan error, ...) error

+ type Operator interface

+ Exec func(StreamContext, chan<- error)

+ GetMetrics func() []any

+ GetName func() string

+ type PrintableTopo struct

+ Edges map[string][]interface{}

+ Sources []string

+ type Qos int

+ const AtLeastOnce

+ const AtMostOnce

+ const ExactlyOnce

+ type RawTuple interface

+ Raw func() []byte

+ type ResendSink interface

+ CollectResend func(ctx StreamContext, data interface{}) error

+ type RestartStrategy struct

+ Attempts int

+ Delay int

+ JitterFactor float64

+ MaxDelay int

+ Multiplier float64

+ type Rewindable interface

+ GetOffset func() (interface{}, error)

+ ResetOffset func(input map[string]interface{}) error

+ Rewind func(offset interface{}) error

+ type Rule struct

+ Actions []map[string]interface{}

+ Graph *RuleGraph

+ Id string

+ Name string

+ Options *RuleOption

+ Sql string

+ Triggered bool

+ func GetDefaultRule(name, sql string) *Rule

+ func (r *Rule) IsLongRunningScheduleRule() bool

+ func (r *Rule) IsScheduleRule() bool

+ type RuleGraph struct

+ Nodes map[string]*GraphNode

+ Topo *PrintableTopo

+ type RuleOption struct

+ BufferLength int

+ CheckpointInterval int

+ Concurrency int

+ Cron string

+ CronDatetimeRange []DatetimeRange

+ Debug bool

+ Duration string

+ IsEventTime bool

+ LateTol int64

+ LogFilename string

+ Qos Qos

+ RestartStrategy *RestartStrategy

+ SendError bool

+ SendMetaToSink bool

+ type Sink interface

+ Collect func(ctx StreamContext, data interface{}) error

+ Configure func(props map[string]interface{}) error

+ Open func(ctx StreamContext) error

+ type Source interface

+ Configure func(datasource string, props map[string]interface{}) error

+ Open func(ctx StreamContext, consumer chan<- SourceTuple, errCh chan<- error)

+ type SourceConnector interface

+ Connect func(ctx StreamContext) error

+ type SourceMeta struct

+ SourceName string

+ SourceType string

+ type SourceTuple interface

+ Message func() map[string]interface{}

+ Meta func() map[string]interface{}

+ Timestamp func() time.Time

+ type Store interface

+ Clean func() error

+ GetOpState func(opId string) (*sync.Map, error)

+ SaveCheckpoint func(checkpointId int64) error

+ SaveState func(checkpointId int64, opId string, state map[string]interface{}) error

+ type StreamContext interface

+ Decode func(data []byte) (map[string]interface{}, error)

+ DecodeIntoList func(data []byte) ([]map[string]interface{}, error)

+ DeleteState func(key string) error

+ GetCounter func(key string) (int, error)

+ GetInstanceId func() int

+ GetLogger func() Logger

+ GetOpId func() string

+ GetRootPath func() string

+ GetRuleId func() string

+ GetState func(key string) (interface{}, error)

+ IncrCounter func(key string, amount int) error

+ ParseJsonPath func(jsonPath string, data interface{}) (interface{}, error)

+ ParseTemplate func(template string, data interface{}) (string, error)

+ PutState func(key string, value interface{}) error

+ SetError func(e error)

+ TransformOutput func(data interface{}) ([]byte, bool, error)

+ WithCancel func() (StreamContext, context.CancelFunc)

+ WithInstance func(instanceId int) StreamContext

+ WithMeta func(ruleId string, opId string, store Store) StreamContext

+ type Subscriber interface

+ Subscribe func(ctx StreamContext) error

+ type TopNode interface

+ GetName func() string

+ type TopicChannel struct

+ Messages chan<- interface{}

+ Topic string

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

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