cluster

type Cluster interface {
	Start()
	Shutdown()
	Join(addr ...string) (int, error)
	Members() []Member
	MembersByReplicaSet(replicaSets ...uint64) []Member
	MemberByID(string) Member
	MemberByHash(uint64) Member
	ReplicaSet() uint64
	ServerID() []byte
	TotalReplicas() int
	Addr() string
	SetGatewayAddrs(hostPorts []string) error
	SetTunnelAddrs(hostPorts []string) error
	Subscribe(d Delegate)
}

type Delegate interface {
	OnJoin(hash uint64)
	OnLeave(hash uint64)
}

type Member interface {
	Proto(info *rony.Edge) *rony.Edge
	ServerID() string
	ReplicaSet() uint64
	GatewayAddr() []string
	TunnelAddr() []string
	Dial() (net.Conn, error)
}