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

file

package

v2.0.0 Latest Latest Go to latest Published: Oct 25, 2024 License: Apache-2.0 Imports: 23 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/lf-edge/ekuiper

Links

Open Source Insights

Documentation ¶

Constants ¶

View Source

const (
	GZIP = "gzip"
	ZSTD = "zstd"
)

Variables ¶

This section is empty.

Functions ¶

func GetSink ¶

func GetSink() api.Sink

func GetSource ¶

func GetSource() api.Source

Types ¶

type FileType ¶

type FileType string

const (
	JSON_TYPE    FileType = "json"
	CSV_TYPE     FileType = "csv"
	LINES_TYPE   FileType = "lines"
	PARQUET_TYPE FileType = "parquet"
)

type Source ¶

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

Source load data from file system. Depending on file types, it may read line by line like lines, csv. Otherwise, it reads the file as a whole and send to company reader node to read and split. The planner need to plan according to the file type.

func (*Source) Close ¶

func (fs *Source) Close(ctx api.StreamContext) error

func (*Source) Connect ¶

func (fs *Source) Connect(ctx api.StreamContext, sch api.StatusChangeHandler) error

func (*Source) Info ¶

func (fs *Source) Info() (i model.NodeInfo)

func (*Source) Load ¶

func (fs *Source) Load(ctx api.StreamContext, ingest api.TupleIngest, ingestError api.ErrorIngest)

func (*Source) Provision ¶

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

func (*Source) Pull ¶

func (fs *Source) Pull(ctx api.StreamContext, _ time.Time, ingest api.TupleIngest, ingestError api.ErrorIngest)

Pull file source may ingest bytes or tuple For stream source, it ingest one line For batch source, it ingest the whole file, thus it need a reader node to coordinate and read the content into lines/array

func (*Source) SetEofIngest ¶

func (fs *Source) SetEofIngest(eof api.EOFIngest)

type SourceConfig ¶

type SourceConfig struct {
	FileName         string            `json:"datasource"`
	FileType         string            `json:"fileType"`
	Path             string            `json:"path"`
	Interval         cast.DurationConf `json:"interval"`
	IsTable          bool              `json:"isTable"`
	Parallel         bool              `json:"parallel"`
	SendInterval     cast.DurationConf `json:"sendInterval"`
	ActionAfterRead  int               `json:"actionAfterRead"`
	MoveTo           string            `json:"moveTo"`
	IgnoreStartLines int               `json:"ignoreStartLines"`
	IgnoreEndLines   int               `json:"ignoreEndLines"`
	// Only use for planning
	Decompression string `json:"decompression"`
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
reader
writer

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