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

const DefaultConnReadTimeout …

const DefaultConnWriteTimeout …

const recvBufSize …

const maxPendingProposals …

const streamAppV2 …

const streamMsg …

const pipelineMsg …

const sendSnap …

var ConnReadTimeout …

var ConnWriteTimeout …

type Peer …

type peer …

func startPeer(t *Transport, urls types.URLs, peerID types.ID, fs *stats.FollowerStats) *peer { … }

func (p *peer) send(m raftpb.Message) { … }

func (p *peer) sendSnap(m snap.Message) { … }

func (p *peer) update(urls types.URLs) { … }

func (p *peer) attachOutgoingConn(conn *outgoingConn) { … }

func (p *peer) activeSince() time.Time { … }

// Pause pauses the peer. The peer will simply drops all incoming
// messages without returning an error.
func (p *peer) Pause() { … }

// Resume resumes a paused peer.
func (p *peer) Resume() { … }

func (p *peer) stop() { … }

// pick picks a chan for sending the given message. The picked chan and the picked chan
// string name are returned.
func (p *peer) pick(m raftpb.Message) (writec chan<- raftpb.Message, picked string) { … }

func isMsgApp(m raftpb.Message) bool { … }

func isMsgSnap(m raftpb.Message) bool { … }