redis_cluster

Documentation

Index

• Constants
• type Conf
• type RedisClusterDriver
  • func NewDriver(conf *Conf) (*RedisClusterDriver, error)
  • 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) SetTimeout(timeout time.Duration)

Constants

const GlobalKeyPrefix = "distributed-cron:"

GlobalKeyPrefix is global redis key preifx

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) SetTimeout

func (rd *RedisClusterDriver) SetTimeout(timeout time.Duration)

SetTimeout set redis key expiration timeout