Skip to main content

SubscribeReport

Struct SubscribeReport 

Source
pub struct SubscribeReport {
    pub handle: SubscriptionHandle,
    pub ok: Vec<SeriesKey>,
    pub failed: Vec<FailedStream>,
    pub seed_outcomes: Vec<(SeriesKey, SeedOutcome)>,
}
Expand description

Outcome of crate::Station::subscribe in continue-on-error mode.

handle always exists and carries events for every stream in ok. failed is a per-stream list of subscribes that did not produce a live forwarder. The most common entry there is StationError::StreamNotSupported — the venue genuinely does not expose the requested stream on the WS wire. Other errors (transport, REST, symbol normalize) also land here so the consumer can log them without aborting the whole subscribe batch.

failed is empty on success — callers that want fail-fast semantics can simply if !report.failed.is_empty() { return Err(...) }.

Fields§

§handle: SubscriptionHandle§ok: Vec<SeriesKey>§failed: Vec<FailedStream>§seed_outcomes: Vec<(SeriesKey, SeedOutcome)>

Cold-seed crate::SeedOutcome recorded for every ok key whose acquire path ran a trade-history seed fetch (derived kinds that consume Kind::Trade — footprint/counted-bars/price-path/CVD/TPO families). Absent entries mean either no seed fetch happened for that key (WS-only cold start, poll-only stream, or a re-acquire of an already-live mux) or the key is not in ok.

Not abused for failed — a truncated-but-nonempty seed is still a successful subscribe (the key is in ok); check SeedOutcome::truncated_by to see whether the venue capped it.

Implementations§

Source§

impl SubscribeReport

Source

pub fn is_fully_ok(&self) -> bool

True if every requested stream produced a live forwarder.

Source

pub fn total(&self) -> usize

Convenience: total streams requested (ok.len() + failed.len()).

Trait Implementations§

Source§

impl Debug for SubscribeReport

Source§

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

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

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

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

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

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

Source§

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

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

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

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

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

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

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

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

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

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

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

Source§

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

The type returned in the event of a conversion error.
Source§

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

Performs the conversion.
Source§

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

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

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

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more