redis

Documentation

Index

• Constants
• type Conf
• type RedisDriver
  • func NewDriver(conf *Conf, options ...redis.DialOption) (*RedisDriver, error)
  • 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

const GlobalKeyPrefix = "distributed-cron:"

GlobalKeyPrefix is global redis key preifx

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

func (rd *RedisDriver) Ping() error

Ping is check redis valid

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