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

plugin

package

v2.0.0 Latest Latest Go to latest Published: Oct 25, 2024 License: Apache-2.0 Imports: 1 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 ¶

Index ¶

Variables
type EXTENSION_TYPE
type FuncPlugin
- func (fp *FuncPlugin) GetSymbols() []string
type IOPlugin
type Plugin
- func NewPluginByType(t PluginType) Plugin
type PluginType

Constants ¶

This section is empty.

Variables ¶

View Source

var ExtensionTypes = []string{
	"none", "internal", "native", "portable", "service", "wasm", "js",
}

View Source

var PluginTypeMap = map[string]PluginType{
	"sources":   SOURCE,
	"sinks":     SINK,
	"functions": FUNCTION,
	"portable":  PORTABLE,
}

View Source

var PluginTypes = []string{"sources", "sinks", "functions", "portable"}

Functions ¶

This section is empty.

Types ¶

type EXTENSION_TYPE ¶

type EXTENSION_TYPE int

const (
	NONE_EXTENSION EXTENSION_TYPE = iota
	INTERNAL
	NATIVE_EXTENSION
	PORTABLE_EXTENSION
	SERVICE_EXTENSION
	JS_EXTENSION
)

type FuncPlugin ¶

type FuncPlugin struct {
	IOPlugin
	// Optional, if not specified, a default element with the same name of the file will be registered
	Functions []string `json:"functions"`
}

func (*FuncPlugin) GetSymbols ¶

func (fp *FuncPlugin) GetSymbols() []string

type IOPlugin ¶

type IOPlugin struct {
	Name       string   `json:"name" yaml:"name"`
	File       string   `json:"file" yaml:"file"`
	ShellParas []string `json:"shellParas,omitempty" yaml:"shellParas,omitempty"`
}

IOPlugin Unify model. Flat all properties for each kind.

func (*IOPlugin) GetFile ¶

func (p *IOPlugin) GetFile() string

func (*IOPlugin) GetInstallScripts ¶

func (p *IOPlugin) GetInstallScripts() []byte

func (*IOPlugin) GetName ¶

func (p *IOPlugin) GetName() string

func (*IOPlugin) GetShellParas ¶

func (p *IOPlugin) GetShellParas() []string

func (*IOPlugin) GetSymbols ¶

func (p *IOPlugin) GetSymbols() []string

func (*IOPlugin) SetName ¶

func (p *IOPlugin) SetName(n string)

type Plugin ¶

type Plugin interface {
	GetName() string
	GetFile() string
	GetShellParas() []string
	GetSymbols() []string
	SetName(n string)
	GetInstallScripts() []byte
}

func NewPluginByType ¶

func NewPluginByType(t PluginType) Plugin

type PluginType ¶

type PluginType int

const (
	SOURCE PluginType = iota
	SINK
	FUNCTION
	PORTABLE
)

Source Files ¶

View all Source files

plugin.go

Directories ¶

Path	Synopsis
js
native
portable
runtime

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