Method UpdatePartitionState

ring/partition_ring_model.go:219–237

UpdatePartitionState changes the state of a partition. Returns true if the state was changed, or false if the update was a no-op.

(id int32, state PartitionState, now time.Time)

// UpdatePartitionState changes the state of a partition. Returns true if the state was changed,
// or false if the update was a no-op.
func (m *PartitionRingDesc) UpdatePartitionState(id int32, state PartitionState, now time.Time) (bool, error) {
	d, ok := m.Partitions[id]
	if !ok {
		return false, nil
	}

	if d.State == state {
		return false, nil
	}

	if d.StateChangeLocked {
		return false, ErrPartitionStateChangeLocked
	}

	d.State = state
	d.StateTimestamp = now.Unix()
	m.Partitions[id] = d
	return true, nil
}

// UpdatePartitionStateChangeLock changes the state change lock of a partition. Returns true if the lock was changed,
// or false if the update was a no-op.