gossip

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 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 struct {
	NodeId  string
	RpcAddr string
}