Struct InboundPrefillBuffer 

pub struct InboundPrefillBuffer { /* private fields */ }

Implementations

impl InboundPrefillBuffer

pub fn new() -> Self

pub fn record_inbound_inter_call( &self, call: InboundInterCall, ) -> Result<(), Error>

Trait Implementations

impl Clone for InboundPrefillBuffer

fn clone(&self) -> InboundPrefillBuffer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for InboundPrefillBuffer

fn default() -> InboundPrefillBuffer

Returns the “default value” for a type.

impl SideEffectPrefillSource for InboundPrefillBuffer

fn update_interest<'life0, 'async_trait>( &'life0 self, interest: SideEffectInterest, ) -> Pin<Box<dyn Future<Output = Result<InterestAck, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn fetch_prefill_for_lyquid<'life0, 'async_trait>( &'life0 self, _lyquid: LyquidID, _from_exclusive: Option<CallOrderKey>, _until_exclusive: ChainPos, _limit: usize, ) -> Pin<Box<dyn Future<Output = Result<PrefillFetchBatch, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn fetch_inbound_for_lyquid<'life0, 'async_trait>( &'life0 self, lyquid: LyquidID, from_exclusive: Option<CallOrderKey>, until_exclusive: ChainPos, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<PrefillInboundBatch, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn record_observed_inbound_inter_call<'life0, 'async_trait>( &'life0 self, call: InboundInterCall, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Record one local inbound inter-call observed during execution.

fn resolve_call_output<'life0, 'async_trait>( &'life0 self, _key: InterCallOutputKey, ) -> Pin<Box<dyn Future<Output = Result<Option<CallEventOutput>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,