server

Aug 21, 2019

Changes in this version

+ const StateCasID

+ const StateFlag

+ const StateKey

+ const StateSize

+ var ErrCacheMiss = xerrors.New("cache miss hit")

+ var ErrCannotAssignCacheServer = xerrors.New("cannot assign cache server because server number is zero")

+ var ErrMalformedKey = xerrors.New("malformed: key is too long or contains invalid characters")

+ var ErrMemcacheCASConflict = xerrors.New("memcache: compare-and-swap conflict")

+ var ErrMemcacheCacheMiss = xerrors.New("memcache: cache miss")

+ var ErrMemcacheNoServers = xerrors.New("memcache: no servers configured or available")

+ var ErrMemcacheNoStats = xerrors.New("memcache: no statistics available")

+ var ErrMemcacheNotStored = xerrors.New("memcache: item not stored")

+ var ErrMemcacheServerError = xerrors.New("memcache: server error")

+ var ErrRedisCacheMiss = xerrors.New("redis: cache miss")

+ var ErrRedisNotStored = xerrors.New("redis: item not stored")

+ var ErrSetMaxIdleConnections = xerrors.New("maxIdle must be 1 or more")

+ var ErrSetTimeout = xerrors.New("timeout must be 1 or more")

+ type CacheGetResponse struct

+ CasID uint64

+ Flags uint32

+ Value []byte

+ type CacheKey interface

+ Addr func() net.Addr

+ Hash func() uint32

+ LockKey func() CacheKey

+ String func() string

+ Type func() CacheKeyType

+ type CacheKeyType int

+ const CacheKeyTypeLLC

+ const CacheKeyTypeNone

+ const CacheKeyTypeSLC

+ func (typ *CacheKeyType) UnmarshalJSON(bytes []byte) error

+ func (typ CacheKeyType) MarshalJSON() ([]byte, error)

+ func (typ CacheKeyType) String() string

+ type CacheServer interface

+ Add func(CacheKey, []byte, time.Duration) error

+ Delete func(CacheKey) error

+ Flush func() error

+ Get func(CacheKey) (*CacheGetResponse, error)

+ GetClient func() *Client

+ GetMulti func([]CacheKey) (*Iterator, error)

+ Set func(*CacheStoreRequest) error

+ SetMaxIdleConnections func(int) error

+ SetTimeout func(time.Duration) error

+ func NewMemcachedBySelectors(slcSelector *Selector, llcSelector *Selector) CacheServer

+ func NewRedisBySelectors(slcSelector *Selector, llcSelector *Selector) CacheServer

+ type CacheStoreRequest struct

+ CasID uint64

+ Expiration time.Duration

+ Key CacheKey

+ Value []byte

+ type Client struct

+ func (c *Client) AddLastLevelCacheServers(servers ...string) error

+ func (c *Client) AddSecondLevelCacheServers(servers ...string) error

+ func (c *Client) RemoveLastLevelCacheServers(servers ...string) error

+ func (c *Client) RemoveSecondLevelCacheServers(servers ...string) error

+ type ConnectTimeoutError struct

+ Addr net.Addr

+ func (cte *ConnectTimeoutError) Error() string

+ type HashKey uint32

+ type HashKeyOrder []HashKey

+ func (h HashKeyOrder) Len() int

+ func (h HashKeyOrder) Less(i, j int) bool

+ func (h HashKeyOrder) Swap(i, j int)

+ type Hashring struct

+ func NewHashring(addrs []net.Addr) *Hashring

+ func (h *Hashring) Add(node net.Addr) *Hashring

+ func (h *Hashring) Get(key CacheKey) net.Addr

+ func (h *Hashring) Remove(node net.Addr) (*Hashring, error)

+ type Item struct

+ Expiration int32

+ Flags uint32

+ Key CacheKey

+ Value []byte

+ type Iterator struct

+ func NewIterator(keys []CacheKey) *Iterator

+ func (i *Iterator) Content() *CacheGetResponse

+ func (i *Iterator) Error() error

+ func (i *Iterator) Key() CacheKey

+ func (i *Iterator) Next() bool

+ func (i *Iterator) SetContent(idx int, res *CacheGetResponse)

+ func (i *Iterator) SetError(idx int, err error)

+ type MemcachedClient struct

+ func (c *MemcachedClient) Add(key CacheKey, value []byte, expiration time.Duration) error

+ func (c *MemcachedClient) CompareAndSwap(item *Item) error

+ func (c *MemcachedClient) Decrement(key CacheKey, delta uint64) (newValue uint64, err error)

+ func (c *MemcachedClient) Delete(key CacheKey) error

+ func (c *MemcachedClient) DeleteAll() error

+ func (c *MemcachedClient) Flush() error

+ func (c *MemcachedClient) FlushAll() error

+ func (c *MemcachedClient) Get(key CacheKey) (*CacheGetResponse, error)

+ func (c *MemcachedClient) GetClient() *Client

+ func (c *MemcachedClient) GetMulti(keys []CacheKey) (*Iterator, error)

+ func (c *MemcachedClient) Increment(key CacheKey, delta uint64) (newValue uint64, err error)

+ func (c *MemcachedClient) Replace(item *Item) error

+ func (c *MemcachedClient) Set(req *CacheStoreRequest) error

+ func (c *MemcachedClient) SetMaxIdleConnections(maxIdle int) error

+ func (c *MemcachedClient) SetTimeout(timeout time.Duration) error

+ func (c *MemcachedClient) Touch(key CacheKey, seconds int32) (err error)

+ type RedisClient struct

+ func (c *RedisClient) Add(key CacheKey, value []byte, expiration time.Duration) error

+ func (c *RedisClient) Delete(key CacheKey) error

+ func (c *RedisClient) Flush() error

+ func (c *RedisClient) Get(key CacheKey) (*CacheGetResponse, error)

+ func (c *RedisClient) GetClient() *Client

+ func (c *RedisClient) GetMulti(keys []CacheKey) (*Iterator, error)

+ func (c *RedisClient) Set(req *CacheStoreRequest) error

+ func (c *RedisClient) SetMaxIdleConnections(maxIdle int) error

+ func (c *RedisClient) SetTimeout(timeout time.Duration) error

+ type Selector struct

+ func NewSelector(servers ...string) (*Selector, error)

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

+ func (s *Selector) PickServer(key CacheKey) (net.Addr, error)

+ type StringCacheKey string

+ func (s StringCacheKey) Addr() net.Addr

+ func (s StringCacheKey) Hash() uint32

+ func (s StringCacheKey) LockKey() CacheKey

+ func (s StringCacheKey) String() string

+ func (s StringCacheKey) Type() CacheKeyType