Enum BandwidthControllerRequest

Source

pub enum BandwidthControllerRequest {
    EcashTicket(ReturnSender<Option<PreparedCredential>>, EcashTicketRequest),
    UpgradeModeToken(ReturnSender<Option<String>>),
    AttemptRevertSpending(ReturnSender<bool>, PreparedCredentialMetadata),
    SetCredentialFetcher(ReturnSender<()>, Option<Arc<dyn CredentialFetcher>>),
    SetPublicDataFetcher(ReturnSender<()>, Option<Arc<dyn CredentialPublicDataFetcher>>),
    Reset(ReturnSender<()>),
    ClearEmergencyCredentials(ReturnSender<()>),
    GetAvailableTicketbooks(ReturnSender<AvailableTicketbooks>),
    RestockTicketbooks(ReturnSender<()>, Vec<TicketType>),
    WaitForTicketbooks(ReturnSender<()>, Vec<TicketType>),
}

Variants§

§

SetCredentialFetcher(ReturnSender<()>, Option<Arc<dyn CredentialFetcher>>)

Sets (or clears, with None) the credential fetcher; a new one triggers an immediate restock.

§

SetPublicDataFetcher(ReturnSender<()>, Option<Arc<dyn CredentialPublicDataFetcher>>)

Sets (or clears, with None) the global-data fetcher.

§

Reset(ReturnSender<()>)

Cancels in-flight fetches, drops the fetcher, clears all stored credentials, and fails every parked readiness waiter.

§

ClearEmergencyCredentials(ReturnSender<()>)

Removes the stored emergency (upgrade-mode) credentials only, leaving ticketbooks intact.

§

GetAvailableTicketbooks(ReturnSender<AvailableTicketbooks>)

Returns the currently stored ticketbooks (also logs a stock summary).

§

RestockTicketbooks(ReturnSender<()>, Vec<TicketType>)

Checks the given ticket types and kicks off a background restock for any running low or about to expire. Resolves once the check has been scheduled, not once the fetches finish.

Not to be used lightly: the automatic triggers (ticket handout, timer, fetcher install) already keep every type stocked. This is a manual safety valve, not a routine call.

§

WaitForTicketbooks(ReturnSender<()>, Vec<TicketType>)

Resolves once every required ticket type is usable (stocked or covered by upgrade mode), or fails if a required type is neither stocked nor being fetched.

BandwidthControllerRequest

Enum BandwidthControllerRequest Copy item path

Variants§

EcashTicket(ReturnSender<Option<PreparedCredential>>, EcashTicketRequest)

UpgradeModeToken(ReturnSender<Option<String>>)

AttemptRevertSpending(ReturnSender<bool>, PreparedCredentialMetadata)

SetCredentialFetcher(ReturnSender<()>, Option<Arc<dyn CredentialFetcher>>)

SetPublicDataFetcher(ReturnSender<()>, Option<Arc<dyn CredentialPublicDataFetcher>>)

Reset(ReturnSender<()>)

ClearEmergencyCredentials(ReturnSender<()>)

GetAvailableTicketbooks(ReturnSender<AvailableTicketbooks>)

RestockTicketbooks(ReturnSender<()>, Vec<TicketType>)

WaitForTicketbooks(ReturnSender<()>, Vec<TicketType>)

Trait Implementations§

impl Display for BandwidthControllerRequest

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

Auto Trait Implementations§

impl !RefUnwindSafe for BandwidthControllerRequest

impl !UnwindSafe for BandwidthControllerRequest

impl Freeze for BandwidthControllerRequest

impl Send for BandwidthControllerRequest

impl Sync for BandwidthControllerRequest

impl Unpin for BandwidthControllerRequest

impl UnsafeUnpin for BandwidthControllerRequest

Blanket Implementations§

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

fn type_id(&self) -> TypeId

impl<U> As for U

fn as_<T>(self) -> Twhere T: CastFrom<U>, U: Sized,

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> Classify for T

type Classified = T

fn classify(self) -> T

impl<T> Declassify for T

type Declassified = T

fn declassify(self) -> T

impl<T> Deprecatable for T

fn deprecate(self) -> Deprecated<Self>where Self: Sized,

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> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>where F: FnOnce(&Self) -> bool,

impl<T> OptionalSet for T

fn with_optional<F, T>(self, f: F, val: Option<T>) -> Selfwhere F: Fn(Self, T) -> Self, Self: Sized,

fn with_validated_optional<F, T, V, E>( self, f: F, value: Option<T>, validate: V, ) -> Result<Self, E>where F: Fn(Self, T) -> Self, V: Fn(&T) -> Result<(), E>, Self: Sized,

fn with_optional_env<F, T>(self, f: F, val: Option<T>, env_var: &str) -> Selfwhere F: Fn(Self, T) -> Self, T: FromStr, <T as FromStr>::Err: Debug, Self: Sized,

fn with_optional_custom_env<F, T, G>( self, f: F, val: Option<T>, env_var: &str, parser: G, ) -> Selfwhere F: Fn(Self, T) -> Self, G: Fn(&str) -> T, Self: Sized,

impl<T> Pointable for T

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

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

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

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

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

impl<T> Same for T

type Output = T

impl<T> ToString for Twhere T: Display + ?Sized,

fn to_string(&self) -> String

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

type Error = Infallible

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

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>,

Enum BandwidthControllerRequest

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

fn as_<T>(self) -> T
where T: CastFrom<U>, U: Sized,

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,

fn deprecate(self) -> Deprecated<Self>
where Self: Sized,

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

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

fn with_optional<F, T>(self, f: F, val: Option<T>) -> Self
where F: Fn(Self, T) -> Self, Self: Sized,

fn with_validated_optional<F, T, V, E>( self, f: F, value: Option<T>, validate: V, ) -> Result<Self, E>
where F: Fn(Self, T) -> Self, V: Fn(&T) -> Result<(), E>, Self: Sized,

fn with_optional_env<F, T>(self, f: F, val: Option<T>, env_var: &str) -> Self
where F: Fn(Self, T) -> Self, T: FromStr, <T as FromStr>::Err: Debug, Self: Sized,

fn with_optional_custom_env<F, T, G>( self, f: F, val: Option<T>, env_var: &str, parser: G, ) -> Self
where F: Fn(Self, T) -> Self, G: Fn(&str) -> T, Self: Sized,

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

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

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

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

impl<T> ToString for T
where T: Display + ?Sized,

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>,