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

const connReadLimitByte …

const snapshotLimitByte …

var RaftPrefix …

var ProbingPrefix …

var RaftStreamPrefix …

var RaftSnapshotPrefix …

var errIncompatibleVersion …

var ErrClusterIDMismatch …

type peerGetter …

type writerToResponse …

type pipelineHandler …

// newPipelineHandler returns a handler for handling raft messages
// from pipeline for RaftPrefix.
//
// The handler reads out the raft message from request body,
// and forwards it to the given raft state machine for processing.
func newPipelineHandler(t *Transport, r Raft, cid types.ID) http.Handler { … }

func (h *pipelineHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) { … }

type snapshotHandler …

func newSnapshotHandler(t *Transport, r Raft, snapshotter *snap.Snapshotter, cid types.ID) http.Handler { … }

const unknownSnapshotSender …

// ServeHTTP serves HTTP request to receive and process snapshot message.
//
// If request sender dies without closing underlying TCP connection,
// the handler will keep waiting for the request body until TCP keepalive
// finds out that the connection is broken after several minutes.
// This is acceptable because
// 1. snapshot messages sent through other TCP connections could still be
// received and processed.
// 2. this case should happen rarely, so no further optimization is done.
func (h *snapshotHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) { … }

type streamHandler …

func newStreamHandler(t *Transport, pg peerGetter, r Raft, id, cid types.ID) http.Handler { … }

func (h *streamHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) { … }

// checkClusterCompatibilityFromHeader checks the cluster compatibility of
// the local member from the given header.
// It checks whether the version of local member is compatible with
// the versions in the header, and whether the cluster ID of local member
// matches the one in the header.
func checkClusterCompatibilityFromHeader(lg *zap.Logger, localID types.ID, header http.Header, cid types.ID) error { … }

type closeNotifier …

func newCloseNotifier() *closeNotifier { … }

func (n *closeNotifier) Close() error { … }

func (n *closeNotifier) closeNotify() <-chan struct{ … }