cache

Documentation

Index

• type SyncCache
  • func NewSyncCache(ctx api.StreamContext, cacheConf *conf.SinkConf) (*SyncCache, error)
  • func (c *SyncCache) AddCache(ctx api.StreamContext, item any) error
  • func (c *SyncCache) Flush(ctx api.StreamContext)
  • func (c *SyncCache) InitStore(ctx api.StreamContext) error
  • func (c *SyncCache) PopCache(ctx api.StreamContext) (any, bool)
  • func (c *SyncCache) SetupMeta(ctx api.StreamContext)

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

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

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