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) PopCache(ctx api.StreamContext) (any, bool)

Types

type SyncCache

type SyncCache struct {
	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) PopCache

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

PopCache not thread safe!