cache

Jul 30, 2025

Changes in this version

+ const BackupBarrierCheckInterval

+ const BackupBarrierLockKey

+ const BackupBarrierStatusLocked

+ const BackupBarrierStatusLocking

+ const BackupBarrierStatusUnlocked

Jun 23, 2025

Changes in this version

+ const LazyWriterRepeatDelayMkS

+ const LazyWriterValueProcessDelayMkS

type Config

+ func (cc *Config) GetId() string

+ func (cc *Config) SetLazyWriterRepeatDelayMkS(lazyWriterRepeatDelayMkS int) *Config

+ func (cc *Config) SetLazyWriterValueProcessDelayMkS(lazyWriterValueProcessDelayMkS int) *Config

Sep 15, 2023

Changes in this version

+ const KVStorePrefix

+ const LRUSize

+ const LevelSubscriptionNotificationsBufferMaxSize

+ type Config struct

+ func NewCacheConfig() *Config

+ func (ro *Config) SetKVStorePrefix(kvStorePrefix string) *Config

+ func (ro *Config) SetLRUSize(lruSize int) *Config

+ func (ro *Config) SetLevelSubscriptionNotificationsBufferMaxSize(levelSubscriptionNotificationsBufferMaxSize int) *Config

+ type KeyValue struct

+ Key interface{}

+ Value interface{}

+ type Store struct

+ func NewCacheStore(ctx context.Context, cacheConfig *Config, kv nats.KeyValue) *Store

+ func (cs *Store) DeleteValue(key string, updateInKV bool, customDeleteTime int64, transactionID string)

+ func (cs *Store) Destroy()

+ func (cs *Store) GetKeysByPattern(pattern string) []string

+ func (cs *Store) GetValue(key string) ([]byte, error)

+ func (cs *Store) GetValueAsJSON(key string) (*easyjson.JSON, error)

+ func (cs *Store) GetValueUpdateTime(key string) int64

+ func (cs *Store) SetValue(key string, value []byte, updateInKV bool, customSetTime int64, ...)

+ func (cs *Store) SetValueIfDoesNotExist(key string, newValue []byte, updateInKV bool, customSetTime int64) bool

+ func (cs *Store) SubscribeLevelCallback(key string, callbackID string) chan KeyValue

+ func (cs *Store) TransactionBegin(transactionID string)

+ func (cs *Store) TransactionEnd(transactionID string)

+ func (cs *Store) UnsubscribeLevelCallback(key string, callbackID string)

+ type StoreValue struct

+ func (csv *StoreValue) ConsistencyLoss(lossTime int64)

+ func (csv *StoreValue) Delete(updateInKV bool, customDeleteTime int64)

+ func (csv *StoreValue) GetFullKeyString() string

+ func (csv *StoreValue) LoadChild(key interface{}, safe bool) (*StoreValue, bool)

+ func (csv *StoreValue) Lock(caller string)

+ func (csv *StoreValue) Put(value interface{}, updateInKV bool, customPutTime int64)

+ func (csv *StoreValue) Range(f func(key, value interface{}) bool)

+ func (csv *StoreValue) StoreChild(key interface{}, child *StoreValue, safe bool)

+ func (csv *StoreValue) TryPurgeConfirm(safe bool) bool

+ func (csv *StoreValue) TryPurgeReady(safe bool) bool

+ func (csv *StoreValue) Unlock(caller string)

+ func (csv *StoreValue) ValueExists() bool

+ type Transaction struct

+ type TransactionOperator struct