Affected by GO-2025-3508 and 5 other vulnerabilities

GO-2025-3508: LF Edge eKuiper allows Stored XSS in Rules Functionality in github.com/lf-edge/ekuiper

GO-2025-3682: LF Edge eKuiper Vulnerable to Stored XSS in Configuration Key Functionality in github.com/lf-edge/ekuiper

GO-2025-3799: LF Edge eKuiper vulnerable to File Path Traversal leading to file replacement in github.com/lf-edge/ekuiper

GO-2025-3800: eKuiper /config/uploads API arbitrary file writing may lead to RCE in github.com/lf-edge/ekuiper

GO-2025-3827: eKuiper API endpoints handling SQL queries with user-controlled table names. in github.com/lf-edge/ekuiper

GO-2025-4158: LF Edge eKuiper is vulnerable to Arbitrary File Read/Write via unsanitized names and zip extraction in github.com/lf-edge/ekuiper

sql

package

v2.0.0-alpha.8 Latest Latest Go to latest Published: Jul 8, 2024 License: Apache-2.0 Imports: 15 Imported by: 0

Details

This section is empty.

This section is empty.

func GetSink() api.Sink

func GetSource() api.Source

type SQLConf struct {
	Interval cast.DurationConf `json:"interval"`
	DBUrl    string            `json:"dburl"`
}

type SQLSinkConnector struct {
	// contains filtered or unexported fields
}

func (s *SQLSinkConnector) Close(ctx api.StreamContext) error

func (s *SQLSinkConnector) Collect(ctx api.StreamContext, item api.MessageTuple) (err error)

func (s *SQLSinkConnector) CollectList(ctx api.StreamContext, items api.MessageTupleList) (err error)

func (s *SQLSinkConnector) Connect(ctx api.StreamContext) error

func (s *SQLSinkConnector) Provision(ctx api.StreamContext, configs map[string]any) error

type SQLSourceConnector struct {
	Query sqlgen.SqlQueryGenerator
	// contains filtered or unexported fields
}

func (s *SQLSourceConnector) Close(ctx api.StreamContext) error

func (s *SQLSourceConnector) Connect(ctx api.StreamContext) error

func (s *SQLSourceConnector) GetOffset() (interface{}, error)

func (s *SQLSourceConnector) Provision(ctx api.StreamContext, props map[string]any) error

func (s *SQLSourceConnector) Pull(ctx api.StreamContext, recvTime time.Time, ingest api.TupleIngest, ingestError api.ErrorIngest)

func (s *SQLSourceConnector) ResetOffset(input map[string]interface{}) error

func (s *SQLSourceConnector) Rewind(offset interface{}) error

Path	Synopsis
client
testx