IncRebalance increases Rebalance atomically and returns the new value.
(delta int64)
| 831 | |
| 832 | // IncRebalance increases Rebalance atomically and returns the new value. |
| 833 | func (s *TxStats) IncRebalance(delta int64) int64 { |
| 834 | return atomic.AddInt64(&s.Rebalance, delta) |
| 835 | } |
| 836 | |
| 837 | // GetRebalanceTime returns RebalanceTime atomically. |
| 838 | func (s *TxStats) GetRebalanceTime() time.Duration { |
no outgoing calls