Struct OnDemandMigrationStatus

Source

pub struct OnDemandMigrationStatus {Show 13 fields
    pub configured: bool,
    pub enabled: bool,
    pub module_enabled: bool,
    pub provider: Option<String>,
    pub endpoint_host: Option<String>,
    pub breaker: Option<BreakerStatus>,
    pub counters: Option<RuntimeCounters>,
    pub last_source_error: Option<LastSourceError>,
    pub inflight_pulls: u64,
    pub queue_depth: u64,
    pub served_by_source_ratio: Option<f64>,
    pub updated_at: Option<String>,
    pub backfill: Option<BackfillSummary>,
}

Expand description

Response of GET .../on-demand-migration/{bucket}/status.

This is the answering node’s view: counters, queue depth and breaker state are per node, while the configuration is cluster-wide.

Fields§

§configured: bool§enabled: bool§module_enabled: bool§provider: Option<String>§endpoint_host: Option<String>§breaker: Option<BreakerStatus>§counters: Option<RuntimeCounters>§last_source_error: Option<LastSourceError>§inflight_pulls: u64§queue_depth: u64§served_by_source_ratio: Option<f64>

Deliberately null on the server today. Rendered as an em dash, never as zero: a missing ratio and a zero ratio mean different things.

§updated_at: Option<String>§backfill: Option<BackfillSummary>

OnDemandMigrationStatus

Struct OnDemandMigrationStatus Copy item path

Fields§

Trait Implementations§

impl Clone for OnDemandMigrationStatus

fn clone(&self) -> OnDemandMigrationStatus

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

impl Debug for OnDemandMigrationStatus

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

impl Default for OnDemandMigrationStatus

fn default() -> OnDemandMigrationStatus

impl<'de> Deserialize<'de> for OnDemandMigrationStatus

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where __D: Deserializer<'de>,

impl PartialEq for OnDemandMigrationStatus

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

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

impl Serialize for OnDemandMigrationStatus

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>where __S: Serializer,

impl StructuralPartialEq for OnDemandMigrationStatus

Auto Trait Implementations§

impl Freeze for OnDemandMigrationStatus

impl RefUnwindSafe for OnDemandMigrationStatus

impl Send for OnDemandMigrationStatus

impl Sync for OnDemandMigrationStatus

impl Unpin for OnDemandMigrationStatus

impl UnsafeUnpin for OnDemandMigrationStatus

impl UnwindSafe for OnDemandMigrationStatus

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere T: 'a,

fn explicit(self, class: Class, tag: u32) -> TaggedParser<'a, Explicit, Self, E>

impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere T: 'a,

fn implicit( self, class: Class, constructed: bool, tag: u32, ) -> TaggedParser<'a, Implicit, Self, E>

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DTwhere ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DTwhere ST: ?Sized, DT: ?Sized,

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<T> DeserializeOwned for Twhere T: for<'de> Deserialize<'de>,

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

fn in_current_span(self) -> Instrumented<Self> ⓘ

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> Read<Exclusive, BecauseExclusive> for Twhere T: ?Sized,

impl<T> Same for T

type Output = T

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

fn clone_into(&self, target: &mut T)

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = !

fn try_from(value: U) -> Result<T, !>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘwhere S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ

Struct OnDemandMigrationStatus

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
where __D: Deserializer<'de>,

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
where S: Serializer,

impl<T> Any for T
where T: 'static + ?Sized,

impl<'a, T, E> AsTaggedExplicit<'a, E> for T
where T: 'a,

impl<'a, T, E> AsTaggedImplicit<'a, E> for T
where T: 'a,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

impl<T> CloneToUninit for T
where T: Clone,

impl<T> DeserializeOwned for T
where T: for<'de> Deserialize<'de>,

impl<T, U> Into<U> for T
where U: From<T>,

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

impl<T> ToOwned for T
where T: Clone,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,