cache

Documentation

Index

• type SyncCache
  • func NewSyncCache(ctx api.StreamContext, in <-chan []map[string]interface{}, errCh chan<- error, ...) *SyncCache
  • func NewSyncCacheWithExitChanel(ctx api.StreamContext, in <-chan []map[string]interface{}, errCh chan<- error, ...) *SyncCache

Types

type SyncCache

type SyncCache struct {
	Out chan []map[string]interface{}
	Ack chan bool

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

func NewSyncCache

func NewSyncCache(ctx api.StreamContext, in <-chan []map[string]interface{}, errCh chan<- error, cacheConf *conf.SinkConf, bufferLength int) *SyncCache

func NewSyncCacheWithExitChanel

func NewSyncCacheWithExitChanel(ctx api.StreamContext, in <-chan []map[string]interface{}, errCh chan<- error, cacheConf *conf.SinkConf, bufferLength int, exitCh chan<- struct{}) *SyncCache