gossip

Jul 4, 2023

Changes in this version

type IGossip

+ SyncNodes func(ctx context.Context, consistent *hash.ConsistentHash, nodeName, port string)

+ type Serf struct

+ Enabled bool

+ EventCh chan serf.Event

+ func NewSerfGossip(node string) (*Serf, error)

+ func (s *Serf) Shutdown() error

+ func (s *Serf) SyncNodes(ctx context.Context, consistent *hash.ConsistentHash, nodeName, port string)

May 4, 2023

Changes in this version

+ func ExternalIP() (string, error)

+ type Gossip struct

+ Enabled bool

+ func InitMemberList(nodes []string, grpcPort int) (*Gossip, error)

+ func (g *Gossip) Shutdown() error

+ func (g *Gossip) SyncMemberList() (nodes []string)

+ type IGossip interface

+ Shutdown func() error

+ SyncMemberList func() (nodes []string)