Documentation ¶
Overview ¶
package sharded implements a memcache client that shards 2 or more memcache servers
Index ¶
- func New(conf config.Config) memcache.ClientInterface
- type ShardedClient
- func (c *ShardedClient) Add(item *memcache.Item) error
- func (c *ShardedClient) Decrement(key string, delta uint64) (newValue uint64, err error)
- func (c *ShardedClient) Delete(key string) error
- func (c *ShardedClient) DeleteAll() error
- func (c *ShardedClient) Finalize()
- func (c *ShardedClient) Get(key string) (item *memcache.Item, err error)
- func (c *ShardedClient) GetMulti(keys []string) (map[string]*memcache.Item, error)
- func (c *ShardedClient) GetMultiArray(keys []string) ([]*memcache.Item, error)
- func (c *ShardedClient) Increment(key string, delta uint64) (newValue uint64, err error)
- func (c *ShardedClient) Replace(item *memcache.Item) error
- func (c *ShardedClient) SendProxiedMessageAsync(command *message.SingleMessage)
- func (c *ShardedClient) Set(item *memcache.Item) error
- func (c *ShardedClient) Touch(key string, seconds int32) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type ShardedClient ¶
type ShardedClient struct {
// contains filtered or unexported fields
}
func (*ShardedClient) Decrement ¶
func (c *ShardedClient) Decrement(key string, delta uint64) (newValue uint64, err error)
func (*ShardedClient) Delete ¶
func (c *ShardedClient) Delete(key string) error
func (*ShardedClient) DeleteAll ¶
func (c *ShardedClient) DeleteAll() error
func (*ShardedClient) Finalize ¶
func (c *ShardedClient) Finalize()
func (*ShardedClient) Get ¶
func (c *ShardedClient) Get(key string) (item *memcache.Item, err error)
func (*ShardedClient) GetMultiArray ¶
func (c *ShardedClient) GetMultiArray(keys []string) ([]*memcache.Item, error)
func (*ShardedClient) Increment ¶
func (c *ShardedClient) Increment(key string, delta uint64) (newValue uint64, err error)
func (*ShardedClient) SendProxiedMessageAsync ¶
func (c *ShardedClient) SendProxiedMessageAsync(command *message.SingleMessage)
Directories ¶
Path | Synopsis |
---|---|
Package distribution implements distributions such as consistent hashing compatible with twemproxy (hopefully) This implementation draws from the Daisuke Maki's Perl module, which itself is based on the original libketama code.
|
Package distribution implements distributions such as consistent hashing compatible with twemproxy (hopefully) This implementation draws from the Daisuke Maki's Perl module, which itself is based on the original libketama code. |
Click to show internal directories.
Click to hide internal directories.