pub struct AggregationReceipt {
pub reply: Result<Exchange, CamelError>,
pub claims: Vec<Option<InFlightClaim>>,
}Expand description
Result of AggregatorService::submit_with_claim.
Claim-propagation contract (drainclaim): on a pending stash the claim stays inside the bucket; on sync completion the bucket’s claims (the submitter’s included) are returned here so the caller can hold them across the aggregated exchange’s continuation; on error the submitted claim was dropped inside (rejected = released).
Fields§
§reply: Result<Exchange, CamelError>The pending-marked ack or the aggregated exchange — the same
shapes the tower Service::call returns.
claims: Vec<Option<InFlightClaim>>Claims released with this receipt. Empty for a pending stash (claims stay in the bucket) and for errors.
Auto Trait Implementations§
impl !Freeze for AggregationReceipt
impl !RefUnwindSafe for AggregationReceipt
impl !UnwindSafe for AggregationReceipt
impl Send for AggregationReceipt
impl Sync for AggregationReceipt
impl Unpin for AggregationReceipt
impl UnsafeUnpin for AggregationReceipt
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more