redis

package

v0.6.0 Latest Latest Go to latest Published: Apr 26, 2023 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Driver is Driver

func NewDriver(opts *redis.Options) (*Driver, error)

NewDriver return a redis driver

func (rd *Driver) GetServiceNodeList(serviceName string) ([]*node.Node, error)

GetServiceNodeList get a serveice node list

func (rd *Driver) Ping() error

Ping is check redis valid

func (rd *Driver) RegisterServiceNode(node *node.Node) (nodeID string, err error)

RegisterServiceNode register a service node

func (rd *Driver) SetHeartBeat(node *node.Node)

SetHeartBeat set heatbeat

func (rd *Driver) SetLogger(log dlog.Logger)

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

SetTimeout set redis timeout