Method IncRebalanceTime

tx.go:843–845

IncRebalanceTime increases RebalanceTime atomically and returns the new value.

(delta time.Duration)

// IncRebalanceTime increases RebalanceTime atomically and returns the new value.
func (s *TxStats) IncRebalanceTime(delta time.Duration) time.Duration {
	return atomicAddDuration(&s.RebalanceTime, delta)
}

// GetSplit returns Split atomically.
func (s *TxStats) GetSplit() int64 {