GetRebalanceTime returns RebalanceTime atomically.
()
| 836 | |
| 837 | // GetRebalanceTime returns RebalanceTime atomically. |
| 838 | func (s *TxStats) GetRebalanceTime() time.Duration { |
| 839 | return atomicLoadDuration(&s.RebalanceTime) |
| 840 | } |
| 841 | |
| 842 | // IncRebalanceTime increases RebalanceTime atomically and returns the new value. |
| 843 | func (s *TxStats) IncRebalanceTime(delta time.Duration) time.Duration { |