gossip

Documentation

Index

• func New(config Config) (*cluster, error)
• func NewClusterServer(svc *cluster, logger logging.Logger) *clusterServer
• type Cluster
• type Config
• type Member
  • func (m Member) Hash() []byte

Functions

func New

func New(config Config) (*cluster, error)

func NewClusterServer

func NewClusterServer(svc *cluster, logger logging.Logger) *clusterServer

Types

type Cluster

type Cluster interface {
	SubscribeJoinEvents(callerName string) <-chan Member
	SubscribeLeaveEvents(callerName string) <-chan Member
	Join(ctx context.Context, addrs ...string) error
	Shutdown(ctx context.Context) error
}

type Config

type Config struct {
	Logger logging.Logger

	NodeId  string
	RpcAddr string

	// How frequently to gossip with other members
	GossipInterval time.Duration

	// Timeout for gossip requests, if a member doesn't respond within this time, it is considered a
	// suspect
	GossipTimeout time.Duration

	// Each interval, a member will gossip to this many other members
	GossipFactor int
}

type Member

type Member struct {
	NodeId  string
	RpcAddr string
}

func (Member) Hash

func (m Member) Hash() []byte

Hash returns a hash of the member to detect duplicates or changes.