rpcutil

type Client interface {
	Call(method string, args interface{}, reply interface{}) error
	Go(method string, args interface{}, reply interface{}, done chan *rpc.Call) *rpc.Call
	Close() error
}

type ClientFactory func(addr string) (*rpc.Client, error)

type Clients []Client

type Peers struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type Pool struct {
	sync.RWMutex
	// contains filtered or unexported fields
}