Struct ControlPlane 

pub struct ControlPlane<S> { /* private fields */ }

Drives a partition through its migration phases against a MigrationStore, enforcing the drain barrier between cutover and completion (docs/06 §5).

Implementations

impl<S: MigrationStore> ControlPlane<S>

pub fn new(store: S) -> Self

Builds a controller over store with the default drain barrier and the system clock.

pub fn with_barrier(self, barrier: Duration) -> Self

Sets the drain barrier (builder style).

pub fn with_clock(self, clock: Arc<dyn Clock>) -> Self

Swaps the clock the barrier reads (tests inject a ManualClock).

pub async fn begin_migration( &self, partition: &PartitionId, to: Placement, ) -> Result<Epoch, ControlError>

Begins migrating partition toward to. Writes keep flowing to the origin during the ensuing drain phase.

Errors

ControlError::Transition if the partition is unknown or migrating.

pub async fn enter_cutover( &self, partition: &PartitionId, ) -> Result<Epoch, ControlError>

Enters the cutover window and starts the drain barrier clock. Writes are now rejected fleet-wide (every instance polls this fresh).

Errors

ControlError::Transition if the partition is not draining.

pub async fn complete_migration( &self, partition: &PartitionId, ) -> Result<Epoch, ControlError>

Completes the migration once the drain barrier has elapsed since cutover, the pointer flip. Refused (without mutating the store) while in-flight pre-cutover writes might still be committing.

Errors

ControlError::BarrierPending if the barrier has not elapsed; ControlError::Transition if the partition is not in cutover.

pub async fn abort_migration( &self, partition: &PartitionId, ) -> Result<Epoch, ControlError>

Aborts an in-flight migration, returning the partition to its origin and clearing any pending barrier.

Errors

ControlError::Transition if the partition is not migrating.

pub async fn state( &self, partition: &PartitionId, ) -> Option<(PartitionState, Epoch)>

The partition’s current migration state and epoch, or None. For operator/observability read-out (docs/06 §5).

Trait Implementations

impl<S: Debug> Debug for ControlPlane<S>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.