Method addReceivedBytes

kv/memberlist/tcp_transport_conn.go:89–94

addReceivedBytes adds bytes to the local received counter and flushes to Prometheus if threshold is reached.

(n int64)

// addReceivedBytes adds bytes to the local received counter and flushes to Prometheus if threshold is reached.
func (c *meteredConn) addReceivedBytes(n int64) {
	newTotal := c.receivedBytesLocal.Add(n)
	if newTotal >= flushThreshold {
		c.flush()
	}
}

// flush flushes any remaining local byte counters to the Prometheus counters.
func (c *meteredConn) flush() {