Struct PlacementAt 

pub struct PlacementAt {
    pub placement: Placement,
    pub epoch: Epoch,
    pub phase: MigrationPhase,
    pub endpoint: Option<String>,
}

A Placement together with the placement-table epoch it was read at and the partition’s migration phase.

The epoch flows into the routing decision and onto the write so migration cutover can detect a write resolved against a superseded placement (docs/06 §2); the phase is shape-only context for observability.

Examples

use osproxy_spi::{Placement, PlacementAt, MigrationPhase};
use osproxy_spi::core::{ClusterId, Epoch};

let at = PlacementAt::new(
    Placement::DedicatedCluster { cluster: ClusterId::from("eu-1") },
    Epoch::new(7),
)
.with_phase(MigrationPhase::Draining);
assert_eq!(at.epoch, Epoch::new(7));
assert_eq!(at.phase, MigrationPhase::Draining);

Fields

placement: Placement

The resolved placement.

epoch: Epoch

The epoch the placement table was at when this was read.

phase: MigrationPhase

The partition’s migration phase at read time.

endpoint: Option<String>

The base URL of the placement’s cluster. The tenancy is the source of truth for where each cluster lives; the sink builds a pool for this URL the first time it routes to the cluster. Required to reach a live cluster (an in-memory sink ignores it).

Implementations

impl PlacementAt

pub fn new(placement: Placement, epoch: Epoch) -> Self

Pairs a placement with the epoch it was read at (settled, not migrating, no endpoint).

pub fn with_phase(self, phase: MigrationPhase) -> Self

Sets the migration phase (builder style).

pub fn with_endpoint(self, endpoint: impl Into<String>) -> Self

Sets the cluster’s base URL (builder style). This is how the tenancy tells the proxy where the placement’s cluster lives, e.g. .with_endpoint("https://eu-1.internal:9200").

Trait Implementations

impl Clone for PlacementAt

fn clone(&self) -> PlacementAt

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PlacementAt

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

Formats the value using the given formatter.

impl Eq for PlacementAt

impl PartialEq for PlacementAt

fn eq(&self, other: &PlacementAt) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for PlacementAt