type Raft …
type Transporter …
type Transport …
func (t *Transport) Start() error { … }
func (t *Transport) Handler() http.Handler { … }
func (t *Transport) Get(id types.ID) Peer { … }
func (t *Transport) Send(msgs []raftpb.Message) { … }
func (t *Transport) Stop() { … }
func (t *Transport) CutPeer(id types.ID) { … }
func (t *Transport) MendPeer(id types.ID) { … }
func (t *Transport) AddRemote(id types.ID, us []string) { … }
func (t *Transport) AddPeer(id types.ID, us []string) { … }
func (t *Transport) RemovePeer(id types.ID) { … }
func (t *Transport) RemoveAllPeers() { … }
func (t *Transport) removePeer(id types.ID) { … }
func (t *Transport) UpdatePeer(id types.ID, us []string) { … }
func (t *Transport) ActiveSince(id types.ID) time.Time { … }
func (t *Transport) SendSnapshot(m snap.Message) { … }
type Pausable …
func (t *Transport) Pause() { … }
func (t *Transport) Resume() { … }
func (t *Transport) ActivePeers() (cnt int) { … }