cluster

type Cluster interface {
	io.Closer

	// Node returns the local node
	Node() Node

	// Replica returns a replica by ID
	Replica(ReplicaID) *Replica

	// Replicas returns the set of remote replicas
	Replicas() ReplicaSet

	// Watch watches the cluster for changes to the replicas
	Watch(chan<- ReplicaSet) error
}

type Node struct {
	ID NodeID
}

type NodeID string

type Replica struct {
	Node
	ID ReplicaID
	// contains filtered or unexported fields
}

type ReplicaID NodeID

type ReplicaSet map[ReplicaID]*Replica

type Service func(NodeID, *grpc.Server)

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