kubernetes/vendor/go.etcd.io/etcd/server/v3/etcdserver/api/rafthttp/transport.go

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() {}

// CutPeer drops messages to the specified peer.
func (t *Transport) CutPeer(id types.ID) {}

// MendPeer recovers the message dropping behavior of the given peer.
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() {}

// the caller of this function must have the peers mutex.
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() {}

// ActivePeers returns a channel that closes when an initial
// peer connection has been established. Use this to wait until the
// first peer connection becomes active.
func (t *Transport) ActivePeers() (cnt int) {}