kredis

Documentation

Index

• Constants
• type RedisDriver
  • func NewDriver(c *redis.Client) (*RedisDriver, error)
  • func (rd *RedisDriver) DoHeartBeat(nodeID string, timeout time.Duration)
  • func (rd *RedisDriver) GetServiceNodeList(serviceName string) ([]string, error)
  • func (rd *RedisDriver) IsCheckAlive() bool
  • func (rd *RedisDriver) Ping() error
  • func (rd *RedisDriver) RegisterServiceNode(serviceName string, lifeTime time.Duration) (nodeID string)

Constants

const GlobalKeyPrefix = "kcron:"

GlobalKeyPrefix is global redis key preifx

Types

type RedisDriver

type RedisDriver struct {
	Client *redis.Client
	Key    string
	// contains filtered or unexported fields
}

RedisDriver is redisDriver

func NewDriver

func NewDriver(c *redis.Client) (*RedisDriver, error)

NewDriver return a redis driver

func (*RedisDriver) DoHeartBeat

func (rd *RedisDriver) DoHeartBeat(nodeID string, timeout time.Duration)

DoHeartBeat set heart beat

func (*RedisDriver) GetServiceNodeList

func (rd *RedisDriver) GetServiceNodeList(serviceName string) ([]string, error)

GetServiceNodeList get a serveice node list

func (*RedisDriver) IsCheckAlive

func (rd *RedisDriver) IsCheckAlive() bool

func (*RedisDriver) Ping

func (rd *RedisDriver) Ping() error

Ping is check redis valid

func (*RedisDriver) RegisterServiceNode

func (rd *RedisDriver) RegisterServiceNode(serviceName string, lifeTime time.Duration) (nodeID string)

RegisterServiceNode register a service node