zcache

Jan 13, 2025

Changes in this version

type LocalConfig

+ HardMaxCacheSizeInMB int

Apr 3, 2024

Changes in this version

type CombinedConfig

+ GlobalMetricServer metrics.TaskMetrics

type RemoteConfig

+ MetricServer metrics.TaskMetrics

Apr 3, 2024

Changes in this version

+ type CleanupProcess struct

+ BatchSize int

+ Interval time.Duration

+ ThrottleTime time.Duration

type CombinedConfig

+ GlobalStatsMetrics StatsMetrics

type LocalConfig

+ CleanupProcess CleanupProcess

+ StatsMetrics StatsMetrics

type RemoteConfig

+ StatsMetrics StatsMetrics

+ type StatsMetrics struct

+ Enable bool

+ UpdateInterval time.Duration

Mar 27, 2024

Changes in this version

+ type CustomZ struct

+ Member interface{}

+ Score float64

type MockZCache

+ func (m *MockZCache) Expire(ctx context.Context, key string, ttl time.Duration) (bool, error)

+ func (m *MockZCache) ZIncrBy(ctx context.Context, key string, member string, increment float64) (float64, error)

+ func (m *MockZCache) ZRevRangeWithScores(ctx context.Context, key string, start, stop int64) ([]CustomZ, error)

type RemoteCache

+ Expire func(ctx context.Context, key string, ttl time.Duration) (bool, error)

+ ZIncrBy func(ctx context.Context, key string, member string, increment float64) (float64, error)

+ ZRevRangeWithScores func(ctx context.Context, key string, start, stop int64) ([]CustomZ, error)

Mar 8, 2024

Changes in this version

type LocalConfig

+ BatchSize int

+ CleanupInterval time.Duration

+ MetricServer metrics.TaskMetrics

+ ThrottleTime time.Duration

Feb 28, 2024

Changes in this version

type MockZCache

+ func (m *MockZCache) TTL(ctx context.Context, key string) (time.Duration, error)

type RemoteCache

+ TTL func(ctx context.Context, key string) (time.Duration, error)

Feb 20, 2024

Changes in this version

type MockZCache

+ func (m *MockZCache) GetStats() ZCacheStats

+ func (m *MockZCache) IsNotFoundError(err error) bool

+ func (m *MockZCache) SetupAndMonitorMetrics(appName string, metricsServer metrics.TaskMetrics, ...) []error

Feb 1, 2024

Changes in this version

+ type CacheItem struct

+ ExpiresAt int64

+ Value []byte

+ func NewCacheItem(value []byte, ttl time.Duration) CacheItem

+ func (item CacheItem) IsExpired() bool

Dec 29, 2023

Changes in this version

type CombinedConfig

+ GlobalLogger *zap.Logger

type LocalConfig

+ Logger *zap.Logger

type RemoteConfig

+ Logger *zap.Logger

type ZCache

+ IsNotFoundError func(err error) bool

Dec 28, 2023

Changes in this version

type CombinedConfig

+ GlobalPrefix string

+ GlobalTtlSeconds int

+ IsRemoteBestEffort bool

Dec 28, 2023

Changes in this version

+ const KeySplitter

+ type CombinedCache interface

+ func NewCombinedCache(combinedConfig *CombinedConfig) (CombinedCache, error)

+ type CombinedConfig struct

+ Local *LocalConfig

+ Remote *RemoteConfig

type LocalConfig

+ Prefix string

+ type RedisStats struct

+ Pool *redis.PoolStats

type RemoteConfig

+ Prefix string

type ZCache

+ GetStats func() ZCacheStats

+ SetupAndMonitorMetrics func(appName string, metricsServer metrics.TaskMetrics, ...) []error

+ type ZCacheStats struct

+ Local *bigcache.Stats

+ Remote *RedisStats

Dec 22, 2023

Changes in this version

+ type LocalCache interface

+ func NewLocalCache(config *LocalConfig) (LocalCache, error)

+ type LocalConfig struct

+ EvictionInSeconds int

+ func (c *LocalConfig) ToBigCacheConfig() bigcache.Config

+ type RemoteCache interface

+ Decr func(ctx context.Context, key string) (int64, error)

+ Exists func(ctx context.Context, keys ...string) (int64, error)

+ FlushAll func(ctx context.Context) error

+ HGet func(ctx context.Context, key, field string) (string, error)

+ HSet func(ctx context.Context, key string, values ...interface{}) (int64, error)

+ Incr func(ctx context.Context, key string) (int64, error)

+ LPush func(ctx context.Context, key string, values ...interface{}) (int64, error)

+ RPush func(ctx context.Context, key string, values ...interface{}) (int64, error)

+ SAdd func(ctx context.Context, key string, members ...interface{}) (int64, error)

+ SMembers func(ctx context.Context, key string) ([]string, error)

+ func NewRemoteCache(config *RemoteConfig) (RemoteCache, error)

+ type RemoteConfig struct

+ Addr string

+ DB int

+ DialTimeout time.Duration

+ IdleCheckFrequency time.Duration

+ IdleTimeout time.Duration

+ MaxConnAge time.Duration

+ MinIdleConns int

+ Network string

+ Password string

+ PoolSize int

+ PoolTimeout time.Duration

+ ReadTimeout time.Duration

+ WriteTimeout time.Duration

+ func (c *RemoteConfig) ToRedisConfig() *redis.Options

Dec 21, 2023

Changes in this version

+ type Config struct

+ Addr string

+ DB int

+ DialTimeout time.Duration

+ IdleCheckFrequency time.Duration

+ IdleTimeout time.Duration

+ MaxConnAge time.Duration

+ MinIdleConns int

+ Network string

+ Password string

+ PoolSize int

+ PoolTimeout time.Duration

+ ReadTimeout time.Duration

+ WriteTimeout time.Duration

+ func (c *Config) ToRedisConfig() *redis.Options

+ type MockZCache struct

+ func (m *MockZCache) Decr(ctx context.Context, key string) (int64, error)

+ func (m *MockZCache) Delete(ctx context.Context, key string) error

+ func (m *MockZCache) Exists(ctx context.Context, keys ...string) (int64, error)

+ func (m *MockZCache) FlushAll(ctx context.Context) error

+ func (m *MockZCache) Get(ctx context.Context, key string, data interface{}) error

+ func (m *MockZCache) HGet(ctx context.Context, key, field string) (string, error)

+ func (m *MockZCache) HSet(ctx context.Context, key string, values ...interface{}) (int64, error)

+ func (m *MockZCache) Incr(ctx context.Context, key string) (int64, error)

+ func (m *MockZCache) LPush(ctx context.Context, key string, values ...interface{}) (int64, error)

+ func (m *MockZCache) RPush(ctx context.Context, key string, values ...interface{}) (int64, error)

+ func (m *MockZCache) SAdd(ctx context.Context, key string, members ...interface{}) (int64, error)

+ func (m *MockZCache) SMembers(ctx context.Context, key string) ([]string, error)

+ func (m *MockZCache) Set(ctx context.Context, key string, value interface{}, expiration time.Duration) error

+ type MockZMutex struct

+ func (m *MockZMutex) Lock() error

+ func (m *MockZMutex) Name() string

+ func (m *MockZMutex) Unlock() (bool, error)

+ type ZCache interface

+ Decr func(ctx context.Context, key string) (int64, error)

+ Delete func(ctx context.Context, key string) error

+ Exists func(ctx context.Context, keys ...string) (int64, error)

+ FlushAll func(ctx context.Context) error

+ Get func(ctx context.Context, key string, data interface{}) error

+ HGet func(ctx context.Context, key, field string) (string, error)

+ HSet func(ctx context.Context, key string, values ...interface{}) (int64, error)

+ Incr func(ctx context.Context, key string) (int64, error)

+ LPush func(ctx context.Context, key string, values ...interface{}) (int64, error)

+ RPush func(ctx context.Context, key string, values ...interface{}) (int64, error)

+ SAdd func(ctx context.Context, key string, members ...interface{}) (int64, error)

+ SMembers func(ctx context.Context, key string) ([]string, error)

+ Set func(ctx context.Context, key string, value interface{}, expiration time.Duration) error

+ func NewCache(config *Config) ZCache

+ type ZMutex interface

+ Lock func() error

+ Name func() string

+ Unlock func() (bool, error)