Affected by GO-2025-3682 and 4 other vulnerabilities

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

cache

package

v2.0.8 Latest Latest Go to latest Published: Mar 7, 2025 License: Apache-2.0 Imports: 9 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 ¶

type SyncCache
- func NewSyncCache(ctx api.StreamContext, cacheConf *conf.SinkConf) (*SyncCache, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type SyncCache ¶

type SyncCache struct {
	RuleID string
	OpID   string

	CacheLength int // readonly, for metrics only to save calculation
	// contains filtered or unexported fields
}

func NewSyncCache ¶

func NewSyncCache(ctx api.StreamContext, cacheConf *conf.SinkConf) (*SyncCache, error)

func (*SyncCache) AddCache ¶

func (c *SyncCache) AddCache(ctx api.StreamContext, item any) error

AddCache not thread safe!

func (*SyncCache) Flush ¶

func (c *SyncCache) Flush(ctx api.StreamContext)

Flush save memory states to disk.

func (*SyncCache) InitStore ¶ added in v2.0.5

func (c *SyncCache) InitStore(ctx api.StreamContext) error

func (*SyncCache) PopCache ¶

func (c *SyncCache) PopCache(ctx api.StreamContext) (any, bool)

PopCache not thread safe!

func (*SyncCache) SetupMeta ¶ added in v2.0.7

func (c *SyncCache) SetupMeta(ctx api.StreamContext)

Source Files ¶

View all Source files

sync_cache.go

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