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

var snapResponseReadTimeout …

type snapshotSender …

func newSnapshotSender(tr *Transport, picker *urlPicker, to types.ID, status *peerStatus) *snapshotSender { … }

func (s *snapshotSender) stop() { … }

func (s *snapshotSender) send(merged snap.Message) { … }

// post posts the given request.
// It returns nil when request is sent out and processed successfully.
func (s *snapshotSender) post(req *http.Request) (err error) { … }

func createSnapBody(lg *zap.Logger, merged snap.Message) io.ReadCloser { … }