kubernetes/vendor/go.etcd.io/etcd/server/v3/etcdserver/api/snap/message.go

type Message …

func NewMessage(rs raftpb.Message, rc io.ReadCloser, rcSize int64) *Message { … }

// CloseNotify returns a channel that receives a single value
// when the message sent is finished. true indicates the sent
// is successful.
func (m Message) CloseNotify() <-chan bool { … }

func (m Message) CloseWithError(err error) { … }