Struct HostDeliveryRecord 

pub struct HostDeliveryRecord { /* private fields */ }

One item’s journey to one host destination, as the ledger holds it.

Immutable: every transition returns a new record. The ledger decides whether a transition is allowed and writes the result, so the rules about what may follow what live in one place and an adapter cannot invent a shortcut through them.

Implementations

impl HostDeliveryRecord

pub fn queued( item: HostDeliveryItem, target: HostDeliveryTarget, policy: HostDeliveryPolicy, created_at: OffsetDateTime, ) -> Result<Self, DomainError>

A new delivery, queued, with its identity derived from what it is.

pub const fn id(&self) -> &HostDeliveryId

pub const fn item(&self) -> &HostDeliveryItem

pub const fn target(&self) -> &HostDeliveryTarget

pub const fn policy(&self) -> &HostDeliveryPolicy

pub const fn state(&self) -> &HostDeliveryState

pub const fn attempt(&self) -> DeliveryAttempt

pub const fn created_at(&self) -> OffsetDateTime

pub const fn updated_at(&self) -> OffsetDateTime

pub const fn history(&self) -> &DeliveryHistory

pub fn is_offerable_at(&self, now: OffsetDateTime) -> bool

Whether a host could be handed this delivery at now.

A live lease excludes everyone else; an expired one does not, and that is the whole of the exclusion rule. A delivery an activation adapter already pushed stays offerable, because reaching a host is not the same as the host having answered.

pub fn live_lease_at(&self, now: OffsetDateTime) -> Option<&HostDeliveryLease>

The lease currently excluding other holders, if one still does.

pub fn leased(&self, lease: HostDeliveryLease, now: OffsetDateTime) -> Self

Handed out exclusively.

pub fn delivered( &self, receipt: HostActivationReceipt, now: OffsetDateTime, ) -> Self

Pushed to the host by an activation adapter.

pub fn acknowledged( &self, observation: HostDeliveryObservation, now: OffsetDateTime, ) -> Self

The host said what it saw.

pub fn processed(&self, action: ProcessedActionRef, now: OffsetDateTime) -> Self

The host acted, and named the act.

pub fn failed(&self, reason: DeliveryFailureReason, now: OffsetDateTime) -> Self

Given up on, with the attempt that gave up counted.

pub fn requeued(&self, now: OffsetDateTime) -> Self

Back in the queue after a failed attempt, which is counted.

pub fn released(&self, now: OffsetDateTime) -> Self

Back in the queue because a holder gave up its lease, uncounted.

Releasing is not failing: a host that hands work back untouched has not used up one of the delivery’s chances.

pub fn expired(&self, cause: DeliveryExpiryCause, now: OffsetDateTime) -> Self

No longer worth making.

pub fn superseded( &self, by: Option<HostDeliveryId>, now: OffsetDateTime, ) -> Self

Closed because its destination was replaced.

by is the delivery opened in its place, when the work follows.

pub fn re_addressed( &self, target: HostDeliveryTarget, now: OffsetDateTime, ) -> Result<Self, DomainError>

The same delivery offered to a different destination.

A new identity, because the destination is part of what a delivery is: the replacement can be superseded, acknowledged and counted on its own without disturbing the record it follows.

Trait Implementations

impl Clone for HostDeliveryRecord

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for HostDeliveryRecord

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for HostDeliveryRecord

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for HostDeliveryRecord

impl PartialEq for HostDeliveryRecord

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for HostDeliveryRecord

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for HostDeliveryRecord