redis

Documentation

Index

• type RedisDriver
  • func NewDriver(client *redis.Client) (*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)

Types

type RedisDriver

type RedisDriver struct {
	Key string
	// contains filtered or unexported fields
}

RedisDriver is redisDriver

func NewDriver

func NewDriver(client *redis.Client) (*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 heatbeat

func (*RedisDriver) SetTimeout

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

SetTimeout set redis timeout