membership

type ChangedEvent struct {
	HostsAdded   []*HostInfo
	HostsUpdated []*HostInfo
	HostsRemoved []*HostInfo
}

type HostInfo struct {
	// contains filtered or unexported fields
}

type MockMonitor struct {
	// contains filtered or unexported fields
}

type MockMonitorMockRecorder struct {
	// contains filtered or unexported fields
}

type MockServiceResolver struct {
	// contains filtered or unexported fields
}

type MockServiceResolverMockRecorder struct {
	// contains filtered or unexported fields
}

type Monitor interface {
	common.Daemon

	WhoAmI() (*HostInfo, error)
	// EvictSelf evicts this member from the membership ring. After this method is
	// called, other members will discover that this node is no longer part of the
	// ring. This primitive is useful to carry out graceful host shutdown during deployments.
	EvictSelf() error
	Lookup(service string, key string) (*HostInfo, error)
	GetResolver(service string) (ServiceResolver, error)
	// AddListener adds a listener for this service.
	// The listener will get notified on the given
	// channel, whenever there is a membership change.
	// @service: The service to be listened on
	// @name: The name for identifying the listener
	// @notifyChannel: The channel on which the caller receives notifications
	AddListener(service string, name string, notifyChannel chan<- *ChangedEvent) error
	// RemoveListener removes a listener for this service.
	RemoveListener(service string, name string) error
	// GetReachableMembers returns addresses of all members of the ring
	GetReachableMembers() ([]string, error)
	// GetMemberCount returns the number of reachable members
	// currently in this node's membership list for the given role
	GetMemberCount(role string) (int, error)
}

type RingPop struct {
	*ringpop.Ringpop
	// contains filtered or unexported fields
}

type ServiceResolver interface {
	Lookup(key string) (*HostInfo, error)
	// AddListener adds a listener which will get notified on the given
	// channel, whenever membership changes.
	// @name: The name for identifying the listener
	// @notifyChannel: The channel on which the caller receives notifications
	AddListener(name string, notifyChannel chan<- *ChangedEvent) error
	// RemoveListener removes a listener for this service.
	RemoveListener(name string) error
	// MemberCount returns host count in hashring for any particular role
	MemberCount() int
	// Members returns all host addresses in hashring for any particular role
	Members() []*HostInfo
}