Documentation
¶
Index ¶
- Constants
- type Conf
- type RedisDriver
- func (rd *RedisDriver) GetServiceNodeList(serviceName string) ([]string, error)
- func (rd *RedisDriver) Ping() error
- func (rd *RedisDriver) RegisterServiceNode(serviceName string) (nodeID string, err error)
- func (rd *RedisDriver) SetHeartBeat(nodeID string)
- func (rd *RedisDriver) SetTimeout(timeout time.Duration)
Constants ¶
View Source
const GlobalKeyPrefix = "distributed-cron:"
GlobalKeyPrefix is global redis key preifx
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Conf ¶
type Conf struct {
Proto string
// first use addr
Addr string
Password string
Host string
Port int
MaxActive int
MaxIdle int
IdleTimeout time.Duration
Wait bool
}
RedisConf is redis config
type RedisDriver ¶
type RedisDriver struct {
Key string
// contains filtered or unexported fields
}
RedisDriver is redisDriver
func NewDriver ¶
func NewDriver(conf *Conf, options ...redis.DialOption) (*RedisDriver, error)
NewDriver return a redis driver
func (*RedisDriver) GetServiceNodeList ¶
func (rd *RedisDriver) GetServiceNodeList(serviceName string) ([]string, error)
GetServiceNodeList get a serveice node list
func (*RedisDriver) RegisterServiceNode ¶
func (rd *RedisDriver) RegisterServiceNode(serviceName string) (nodeID string, err error)
RegisterServiceNode register a service node
func (*RedisDriver) SetHeartBeat ¶
func (rd *RedisDriver) SetHeartBeat(nodeID string)
SetHeartBeat set herbear
func (*RedisDriver) SetTimeout ¶
func (rd *RedisDriver) SetTimeout(timeout time.Duration)
SetTimeout set redis timeout
Source Files
Click to show internal directories.
Click to hide internal directories.