Documentation ¶
Index ¶
- Constants
- func RegisterDriver(driverName string, driver Driver)
- type Driver
- type DriverConnOpt
- type RedisDriver
- func (this *RedisDriver) GetNodeList(serverName string) []string
- func (this *RedisDriver) Open(dataSourceOption DriverConnOpt)
- func (this *RedisDriver) RegisterNode(serverName string) (nodeId string)
- func (this *RedisDriver) SetHeartBeat(nodeId string)
- func (this *RedisDriver) SetTimeout(timeout time.Duration)
Constants ¶
View Source
const GlobalKeyPrefix = "distributed-cron:"
Variables ¶
This section is empty.
Functions ¶
func RegisterDriver ¶
Types ¶
type Driver ¶
type DriverConnOpt ¶
type RedisDriver ¶
type RedisDriver struct { Key string // contains filtered or unexported fields }
func (*RedisDriver) GetNodeList ¶
func (this *RedisDriver) GetNodeList(serverName string) []string
func (*RedisDriver) Open ¶
func (this *RedisDriver) Open(dataSourceOption DriverConnOpt)
func (*RedisDriver) RegisterNode ¶
func (this *RedisDriver) RegisterNode(serverName string) (nodeId string)
func (*RedisDriver) SetHeartBeat ¶
func (this *RedisDriver) SetHeartBeat(nodeId string)
func (*RedisDriver) SetTimeout ¶
func (this *RedisDriver) SetTimeout(timeout time.Duration)
Click to show internal directories.
Click to hide internal directories.