Documentation
¶
Index ¶
- type Conf
- type RedisClusterDriver
- func (rd *RedisClusterDriver) GetServiceNodeList(serviceName string) ([]string, error)
- func (rd *RedisClusterDriver) Ping() error
- func (rd *RedisClusterDriver) RegisterServiceNode(serviceName string) (nodeID string, err error)
- func (rd *RedisClusterDriver) SetHeartBeat(nodeID string)
- func (rd *RedisClusterDriver) SetLogger(log dlog.Logger)
- func (rd *RedisClusterDriver) SetTimeout(timeout time.Duration)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Conf ¶
type Conf struct {
Proto string
// first use addr
Addrs []string
Password string
MaxRedirects int
ReadOnly bool
TLSConfig *tls.Config
}
Conf is redis cluster client config
type RedisClusterDriver ¶
type RedisClusterDriver struct {
Key string
// contains filtered or unexported fields
}
RedisClusterDriver is
func NewDriver ¶
func NewDriver(conf *Conf) (*RedisClusterDriver, error)
NewDriver return a redis driver
func (*RedisClusterDriver) GetServiceNodeList ¶
func (rd *RedisClusterDriver) GetServiceNodeList(serviceName string) ([]string, error)
GetServiceNodeList get a service node list on redis cluster
func (*RedisClusterDriver) Ping ¶
func (rd *RedisClusterDriver) Ping() error
Ping to check redis cluster is valid or not
func (*RedisClusterDriver) RegisterServiceNode ¶
func (rd *RedisClusterDriver) RegisterServiceNode(serviceName string) (nodeID string, err error)
RegisterServiceNode register a service node
func (*RedisClusterDriver) SetHeartBeat ¶
func (rd *RedisClusterDriver) SetHeartBeat(nodeID string)
SetHeartBeat set heartbeat
func (*RedisClusterDriver) SetLogger ¶
func (rd *RedisClusterDriver) SetLogger(log dlog.Logger)
func (*RedisClusterDriver) SetTimeout ¶
func (rd *RedisClusterDriver) SetTimeout(timeout time.Duration)
SetTimeout set redis key expiration timeout
Source Files
Click to show internal directories.
Click to hide internal directories.