Method flush

kv/memberlist/tcp_transport_conn.go:97–104

flush flushes any remaining local byte counters to the Prometheus counters.

()

// flush flushes any remaining local byte counters to the Prometheus counters.
func (c *meteredConn) flush() {
	if sentBytes := c.sentBytesLocal.Swap(0); sentBytes > 0 {
		c.sentBytesCounter.Add(float64(sentBytes))
	}
	if receivedBytes := c.receivedBytesLocal.Swap(0); receivedBytes > 0 {
		c.receivedBytesCounter.Add(float64(receivedBytes))
	}
}