Versions in this module Expand all Collapse all v0 v0.26.0 Apr 9, 2022 Changes in this version + var DefaultRedisClientConfig = RedisClientConfig + func NewMemcachedClient(logger log.Logger, name string, conf []byte, reg prometheus.Registerer) (*memcachedClient, error) + func NewMemcachedClientWithConfig(logger log.Logger, name string, config MemcachedClientConfig, ...) (*memcachedClient, error) + type AddressProvider interface + Addresses func() []string + Resolve func(context.Context, []string) error + type MemcachedClient = RemoteCacheClient + type MemcachedClientConfig struct + Addresses []string + AutoDiscovery bool + DNSProviderUpdateInterval time.Duration + MaxAsyncBufferSize int + MaxAsyncConcurrency int + MaxGetMultiBatchSize int + MaxGetMultiConcurrency int + MaxIdleConnections int + MaxItemSize model.Bytes + Timeout time.Duration + 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 RedisClient struct + func NewRedisClient(logger log.Logger, name string, conf []byte, reg prometheus.Registerer) (*RedisClient, error) + func NewRedisClientWithConfig(logger log.Logger, name string, config RedisClientConfig, ...) (*RedisClient, error) + func (c *RedisClient) GetMulti(ctx context.Context, keys []string) map[string][]byte + func (c *RedisClient) SetAsync(ctx context.Context, key string, value []byte, ttl time.Duration) error + func (c *RedisClient) SetMulti(ctx context.Context, data map[string][]byte, ttl time.Duration) + func (c *RedisClient) Stop() + type RedisClientConfig struct + Addr string + DB int + DialTimeout time.Duration + GetMultiBatchSize int + IdleTimeout time.Duration + MaxConnAge time.Duration + MaxGetMultiConcurrency int + MaxSetMultiConcurrency int + MinIdleConns int + Password string + PoolSize int + ReadTimeout time.Duration + SetMultiBatchSize int + Username string + WriteTimeout time.Duration + type RemoteCacheClient interface + GetMulti func(ctx context.Context, keys []string) map[string][]byte + SetAsync func(ctx context.Context, key string, value []byte, ttl time.Duration) error + Stop func()
Go to main page