redis_discovery

package

v1.0.3 Latest Latest Go to latest Published: Oct 3, 2023 License: Apache-2.0 Imports: 10 Imported by: 1

Details

This section is empty.

This section is empty.

This section is empty.

type RedisDiscovery struct {
	discovery.ServiceDiscovery
	// contains filtered or unexported fields
}

RedisDiscovery

func NewRedisDiscovery(adminRedis *eredis.RedisClient) *RedisDiscovery

NewRedisDiscovery return a RedisDiscovery

func (s *RedisDiscovery) Close() error

Close closes the redis

func (this *RedisDiscovery) GetInfo() ([]string, error)

GetInfo get node information

func (this *RedisDiscovery) GetServerList() (map[string]string, error)

func (this *RedisDiscovery) Register() error

Register registers the NodeID and notify other nodes

func (this *RedisDiscovery) SetNodeAddr(addr string)

SetNodeAddr sets a addr

func (this *RedisDiscovery) UpdateInfo(nodeInfoByte []byte) error

UpdateInfo Update the information for this node

func (this *RedisDiscovery) WatchService(watchChan discovery.WatchChan)

WatchService Listens for a new node to start