Documentation ¶
Overview ¶
CRC16 implementation according to CCITT standards. Copyright 2001-2010 Georges Menie (www.menie.org) Copyright 2013 The Go Authors. All rights reserved. http://redis.io/topics/cluster-spec#appendix-a-crc16-reference-implementation-in-ansi-c
Index ¶
- Constants
- Variables
- func GetSlotID(key string, slots []redis.ClusterSlot) string
- func IsInSlot(key string, slot redis.ClusterSlot) bool
- func Key(key string) string
- func RandomSlot() int
- func Slot(key string) int
- type Connection
- type Redis
- type RedisInterface
- type SentinelConnection
- type SingleConnection
Constants ¶
View Source
const ( Sentinel = "sentinel" Cluster = "cluster" DefaultPoolSize = 100 DefaultReadTimeout = 1000 DefaultWriteTimeout = 1000 )
View Source
const SlotNumber = 16384
Variables ¶
View Source
var (
ErrorMissingRedisAddress = errors.New("missing redis address")
)
Functions ¶
Types ¶
type Connection ¶
type Connection interface {
BuildClient() (redis.UniversalClient, error)
}
func NewRedisConfig ¶
func NewRedisConfig(add string, db int) Connection
type Redis ¶
type Redis struct { redis.UniversalClient Slots []redis.ClusterSlot }
func NewConnection ¶
func NewConnection(conn Connection) (*Redis, error)
func (*Redis) GetClient ¶
func (br *Redis) GetClient() redis.UniversalClient
func (*Redis) GetClusterSlots ¶
func (br *Redis) GetClusterSlots() ([]redis.ClusterSlot, error)
func (*Redis) GetRedisSlot ¶
func (*Redis) GetRedisSlotID ¶
type RedisInterface ¶
type RedisInterface interface { redis.UniversalClient GetClient() redis.UniversalClient GetClusterSlots() ([]redis.ClusterSlot, error) GetRedisSlot(key string) int GetRedisSlotID(key string) string }
type SentinelConnection ¶
type SentinelConnection struct {
// contains filtered or unexported fields
}
func (*SentinelConnection) BuildClient ¶
func (conn *SentinelConnection) BuildClient() (redis.UniversalClient, error)
type SingleConnection ¶
type SingleConnection struct {
// contains filtered or unexported fields
}
func (*SingleConnection) BuildClient ¶
func (conn *SingleConnection) BuildClient() (redis.UniversalClient, error)
Click to show internal directories.
Click to hide internal directories.