redis

package
v0.0.0-...-bb01cf8 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 27, 2020 License: MIT Imports: 6 Imported by: 0

Documentation

Index

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 {
	Host     string
	Port     int
	Password string
}

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) (*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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL