cache

May 2, 2024

Changes in this version

type RedisConfig

+ Username string

Jan 26, 2024

Changes in this version

type MemcachedClientConfig

+ AutoDiscovery bool

Aug 26, 2022

Changes in this version

+ func ExtractCacheGenNumber(ctx context.Context) string

+ func HashKey(key string) string

+ func InjectCacheGenNumber(ctx context.Context, cacheGen string) context.Context

+ func IsEmptyTieredCache(cache Cache) bool

+ func StringToBytes(s string) []byte

+ type BackgroundConfig struct

+ WriteBackBuffer int

+ WriteBackGoroutines int

+ func (cfg *BackgroundConfig) RegisterFlagsWithPrefix(prefix string, description string, f *flag.FlagSet)

+ type Cache interface

+ Fetch func(ctx context.Context, keys []string) (found []string, bufs [][]byte, missing []string)

+ Stop func()

+ Store func(ctx context.Context, key []string, buf [][]byte)

+ func Instrument(name string, cache Cache, reg prometheus.Registerer) Cache

+ func New(cfg Config, reg prometheus.Registerer, logger log.Logger) (Cache, error)

+ func NewBackground(name string, cfg BackgroundConfig, cache Cache, reg prometheus.Registerer) Cache

+ func NewCacheGenNumMiddleware(downstreamCache Cache) Cache

+ func NewMockCache() Cache

+ func NewNoopCache() Cache

+ func NewSnappy(next Cache, logger log.Logger) Cache

+ func NewTiered(caches []Cache) Cache

+ func StopOnce(cache Cache) Cache

+ type Config struct

+ Background BackgroundConfig

+ Cache Cache

+ DefaultValidity time.Duration

+ EnableFifoCache bool

+ Fifocache FifoCacheConfig

+ Memcache MemcachedConfig

+ MemcacheClient MemcachedClientConfig

+ Prefix string

+ Redis RedisConfig

+ func (cfg *Config) RegisterFlagsWithPrefix(prefix string, description string, f *flag.FlagSet)

+ func (cfg *Config) Validate() error

+ type FifoCache struct

+ func NewFifoCache(name string, cfg FifoCacheConfig, reg prometheus.Registerer, logger log.Logger) *FifoCache

+ func (c *FifoCache) Fetch(ctx context.Context, keys []string) (found []string, bufs [][]byte, missing []string)

+ func (c *FifoCache) Get(ctx context.Context, key string) ([]byte, bool)

+ func (c *FifoCache) Stop()

+ func (c *FifoCache) Store(ctx context.Context, keys []string, values [][]byte)

+ type FifoCacheConfig struct

+ DeprecatedSize int

+ MaxSizeBytes string

+ MaxSizeItems int

+ Validity time.Duration

+ func (cfg *FifoCacheConfig) RegisterFlagsWithPrefix(prefix, description string, f *flag.FlagSet)

+ func (cfg *FifoCacheConfig) Validate() error

+ type GenNumMiddleware struct

+ func (c GenNumMiddleware) Fetch(ctx context.Context, keys []string) (found []string, bufs [][]byte, missing []string)

+ func (c GenNumMiddleware) Stop()

+ func (c GenNumMiddleware) Store(ctx context.Context, keys []string, buf [][]byte)

+ type Memcached struct

+ func NewMemcached(cfg MemcachedConfig, client MemcachedClient, name string, ...) *Memcached

+ func (c *Memcached) Fetch(ctx context.Context, keys []string) (found []string, bufs [][]byte, missed []string)

+ func (c *Memcached) Stop()

+ func (c *Memcached) Store(ctx context.Context, keys []string, bufs [][]byte)

+ type MemcachedClient interface

+ GetMulti func(keys []string) (map[string]*memcache.Item, error)

+ Set func(item *memcache.Item) error

+ func NewMemcachedClient(cfg MemcachedClientConfig, name string, r prometheus.Registerer, ...) MemcachedClient

+ type MemcachedClientConfig struct

+ Addresses string

+ CBFailures uint

+ CBInterval time.Duration

+ CBTimeout time.Duration

+ ConsistentHash bool

+ Host string

+ MaxIdleConns int

+ MaxItemSize int

+ Service string

+ Timeout time.Duration

+ UpdateInterval time.Duration

+ func (cfg *MemcachedClientConfig) RegisterFlagsWithPrefix(prefix, description string, f *flag.FlagSet)

+ type MemcachedConfig struct

+ BatchSize int

+ Expiration time.Duration

+ Parallelism int

+ func (cfg *MemcachedConfig) RegisterFlagsWithPrefix(prefix, description string, f *flag.FlagSet)

+ type MemcachedJumpHashSelector struct

+ func (s *MemcachedJumpHashSelector) Each(f func(net.Addr) error) error

+ func (s *MemcachedJumpHashSelector) PickServer(key string) (net.Addr, error)

+ func (s *MemcachedJumpHashSelector) SetServers(servers ...string) error

+ type RedisCache struct

+ func NewRedisCache(name string, redisClient *RedisClient, reg prometheus.Registerer, ...) *RedisCache

+ func (c *RedisCache) Fetch(ctx context.Context, keys []string) (found []string, bufs [][]byte, missed []string)

+ func (c *RedisCache) Stop()

+ func (c *RedisCache) Store(ctx context.Context, keys []string, bufs [][]byte)

+ type RedisClient struct

+ func NewRedisClient(cfg *RedisConfig) *RedisClient

+ func (c *RedisClient) Close() error

+ func (c *RedisClient) MGet(ctx context.Context, keys []string) ([][]byte, error)

+ func (c *RedisClient) MSet(ctx context.Context, keys []string, values [][]byte) error

+ func (c *RedisClient) Ping(ctx context.Context) error

+ type RedisConfig struct

+ DB int

+ EnableTLS bool

+ Endpoint string

+ Expiration time.Duration

+ IdleTimeout time.Duration

+ InsecureSkipVerify bool

+ MasterName string

+ MaxConnAge time.Duration

+ Password flagext.Secret

+ PoolSize int

+ Timeout time.Duration

+ func (cfg *RedisConfig) RegisterFlagsWithPrefix(prefix, description string, f *flag.FlagSet)