members

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

type ErrorEvent struct {
	Error error
}

type Event interface {
	// Type is one of the EventType
	Type() EventType
}

type EventBus interface {

	// RegisterEventHandler attaches a event listener to all the members events
	// and broadcasts the event to the handler.
	RegisterEventHandler(EventHandler) error

	// DeregisterEventHandler removes the event listener.
	DeregisterEventHandler(EventHandler) error

	// DispatchEvent dispatches an event to all the members in the cluster.
	DispatchEvent(Event) error
}

type EventHandler interface {
	HandleEvent(Event) error
}

type EventType int

type Member interface {

	// Name returns the name of the member
	Name() string

	// Address returns the host:port of the member
	Address() string
}

type MemberEvent struct {
	EventType MemberEventType
	Members   []Member
}

type MemberEventType int

type MemberList interface {

	// NumMembers returns the number of alive nodes currently known. Between
	// the time of calling this and calling Members, the number of alive nodes
	// may have changed, so this shouldn't be used to determine how many
	// members will be returned by Members.
	NumMembers() int

	// LocalNode is used to return the local Member
	LocalNode() Member

	// Members returns a point-in-time snapshot of the members of this cluster.
	Members() []Member
}

type Members interface {
	EventBus

	// Join joins an existing members cluster. Returns the number of nodes
	// successfully contacted. The returned error will be non-nil only in the
	// case that no nodes could be contacted.
	Join() (int, error)

	// Leave gracefully exits the cluster. It is safe to call this multiple
	// times.
	Leave() error

	// Memberlist is used to get access to the underlying Memberlist instance
	MemberList() MemberList

	// Walk over a set of alive members
	Walk(func(PeerInfo) error) error

	// Close the current members cluster
	Close() error
}

type Option func(*Config) error

type PeerInfo struct {
	Name    string
	Type    PeerType
	APIAddr string
	APIPort int
}

type PeerType string

type QueryEvent struct {
	Name    string
	Payload []byte
	// contains filtered or unexported fields
}

type UserEvent struct {
	Name    string
	Payload []byte
}