swim

type Cluster interface {
	GetMembers() []*rpc.Node
	Start()
	Stop()
}

type Collection interface {
	AddNode(node *rpc.Node)
	DeleteNode(address string)
	GetKeys() []string
	GetNodes() []*rpc.Node
	GetNodeByAddress(address string) (*rpc.Node, bool)
	GetRandomNode() (*rpc.Node, error)
	GetRandomNodes(size int) []*rpc.Node
	GetSampleSize(zscore float64, moe float64) int
	GetSortedNodes(o SortOrder) []*rpc.Node
	Len() int
}

type Config struct {
	Address          string
	BroadcastAddress string
	Seed             *rpc.Node
	RPCPort          uint32
	UDPPort          uint32
}

type Server interface {
	StartListener(address string, port int) error
	Stop()
	Join(ctx context.Context, in *rpc.JoinMessageInput) (*rpc.JoinMessageOutput, error)
	Leave(ctx context.Context, in *rpc.LeaveMessageInput) (*rpc.LeaveMessageOutput, error)
	Ping(ctx context.Context, in *rpc.PingMessageInput) (*rpc.PingMessageOutput, error)
	PingRequest(ctx context.Context, in *rpc.PingRequestMessageInput) (*rpc.PingMessageOutput, error)
}

type SortOrder int

type UDP interface {
	GetBroadcastAddress() (net.IP, error)
	SendBroadcast(address string, port int, node *rpc.Node) (int, error)
	StartListener(port int) error
	Stop()
}