Struct AggregatorInput

Source

pub struct AggregatorInput {
    pub offers: Vec<ProviderOfferContent>,
    pub heartbeats: Vec<HeartbeatContent>,
    pub receipts: Vec<CompletionReceipt>,
    pub consumers: HashMap<String, ConsumerProfile>,
    pub stake_statuses: HashMap<String, StakeStatus>,
    pub anchor_providers: HashSet<String>,
}

Expand description

Inputs to a single aggregator run. The caller (binary entry point) is responsible for I/O — fetching offers/heartbeats/ receipts from Nostr, fetching stake statuses from Esplora, loading consumer first-seen times. Once those are in hand, the snapshot is a pure function of them.

Fields§

§offers: Vec<ProviderOfferContent>§heartbeats: Vec<HeartbeatContent>§receipts: Vec<CompletionReceipt>§consumers: HashMap<String, ConsumerProfile>§stake_statuses: HashMap<String, StakeStatus>

Pre-computed by the binary entry point against Esplora, keyed by provider_npub. Letting the caller pass these in keeps compute_snapshot pure and lets two independent runs reproduce as long as they pass the same data.

§anchor_providers: HashSet<String>

5 anchor providers (Paygress-team-run) flagged in the UI.

Auto Trait Implementations§

§

AggregatorInput

Struct AggregatorInput Copy item path

Fields§

Auto Trait Implementations§

impl Freeze for AggregatorInput

impl RefUnwindSafe for AggregatorInput

impl Send for AggregatorInput

impl Sync for AggregatorInput

impl Unpin for AggregatorInput

impl UnsafeUnpin for AggregatorInput

impl UnwindSafe for AggregatorInput

Blanket Implementations§

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

fn type_id(&self) -> TypeId

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<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> PolicyExt for Twhere T: ?Sized,

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

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

impl<T> Same for T

type Output = T

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

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>

impl<A, B, T> HttpServerConnExec<A, B> for Twhere B: Body,

Struct AggregatorInput

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

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

impl<T> BorrowMut<T> for T
where T: ?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,

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

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

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

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

impl<A, B, T> HttpServerConnExec<A, B> for T
where B: Body,