(ctx context.Context, instanceID string, partitionID int32)
| 33 | } |
| 34 | |
| 35 | func (l *PartitionRingEditor) RemoveMultiPartitionOwner(ctx context.Context, instanceID string, partitionID int32) error { |
| 36 | return l.updateRing(ctx, func(ring *PartitionRingDesc) (bool, error) { |
| 37 | return ring.RemoveOwner(multiPartitionOwnerInstanceID(instanceID, partitionID)), nil |
| 38 | }) |
| 39 | } |
| 40 | |
| 41 | func (l *PartitionRingEditor) SetPartitionStateChangeLock(ctx context.Context, partitionID int32, locked bool) error { |
| 42 | return l.updateRing(ctx, func(ring *PartitionRingDesc) (bool, error) { |