Function newMeteredConn

kv/memberlist/tcp_transport_conn.go:33–39

newMeteredConn creates a new metered connection wrapper.

(conn net.Conn, sentBytes, receivedBytes prometheus.Counter)

// newMeteredConn creates a new metered connection wrapper.
func newMeteredConn(conn net.Conn, sentBytes, receivedBytes prometheus.Counter) *meteredConn {
	return &meteredConn{
		Conn:                 conn,
		sentBytesCounter:     sentBytes,
		receivedBytesCounter: receivedBytes,
	}
}

// Read implement net.Conn.
func (c *meteredConn) Read(b []byte) (n int, err error) {