Struct OutboxMessageId 

pub struct OutboxMessageId(/* private fields */);

English:
Owned adapter-assigned identifier for an outbox message.

The string is not validated or generated here. It need not equal a domain event’s delivery identifier; uniqueness and identifier scope belong to the outbox adapter.

日本語:
アダプターが割り当てる、所有されたアウトボックスメッセージ識別子です。

ここでは文字列を検証・生成しません。ドメインイベントの配信識別子と同じである 必要はなく、一意性と識別子のスコープはアウトボックスアダプターが定めます。

Implementations

impl OutboxMessageId

pub fn new(value: impl Into<String>) -> OutboxMessageId

English:
Converts value to the stored string, accepting empty strings as well.

日本語:
value を保存用の文字列へ変換します。空文字列も受け付けます。

Examples found in repository

examples/reliable_delivery.rs (line 115)

    fn save_and_enqueue<'a>(
        &'a mut self,
        account: &'a Account,
        expected: ExpectedRevision,
        events: Vec<Credited>,
    ) -> Pin<Box<dyn Future<Output = Result<AppendResult, AppendError<Self::Error>>> + Send + 'a>>
    {
        Box::pin(async move {
            if events.is_empty() {
                return Err(AppendError::EmptyBatch);
            }
            if self
                .saved
                .as_ref()
                .is_some_and(|saved| saved.id != account.id)
            {
                return Err(AppendError::Adapter("demo stores only one account"));
            }
            let matches = match (expected, self.revision) {
                (ExpectedRevision::NoStream(_), None) => true,
                (ExpectedRevision::Revision(want), Some(have)) => want == have,
                _ => false,
            };
            if !matches {
                return Err(AppendError::Conflict(RevisionConflict {
                    expected,
                    current: self.revision.map_or(
                        CurrentRevision::NoStream(NoStream),
                        CurrentRevision::Revision,
                    ),
                }));
            }
            let first = match self.revision {
                None => 0,
                Some(current) => current
                    .value()
                    .checked_add(1)
                    .ok_or(AppendError::RevisionExhausted { current })?,
            };
            let last = first.checked_add(events.len() as u64 - 1).ok_or(
                AppendError::RevisionExhausted {
                    current: StreamRevision::new(first),
                },
            )?;
            let mut snapshot = account.clone();
            snapshot.pull_events();
            self.saved = Some(snapshot);
            self.revision = Some(StreamRevision::new(last));
            for (offset, event) in events.into_iter().enumerate() {
                self.queue.push_back((
                    OutboxMessageId::new(format!("{}:{}", account.id, first + offset as u64)),
                    event,
                ));
            }
            Ok(AppendResult {
                resulting_revision: StreamRevision::new(last),
            })
        })
    }

pub fn as_str(&self) -> &str

English:
Borrows the message identifier without cloning its string.

日本語:
文字列を複製せずにメッセージ識別子を借用します。

Examples found in repository

examples/reliable_delivery.rs (line 226)

async fn deliver(
    outbox: &mut Outbox,
    broker: &mut Broker,
    model: &mut ReadModel,
    checkpoints: &mut Checkpoints,
) -> Result<ProjectionApplication, &'static str> {
    let claim = outbox.claim().await?.ok_or("queue empty")?;
    let (id, event) = claim.into_parts();
    broker.publish(&event).await?;
    // This demo directly feeds a consumer after publishing; no real broker is used.
    // Message IDs are stable across retries; these cursors are not sortable offsets.
    let checkpoint = ProjectionCheckpoint::new(id.as_str().to_owned());
    let result = model.apply_once(&event, &checkpoint).await?;
    checkpoints.save(checkpoint).await?;
    outbox.acknowledge(&id).await?;
    Ok(result)
}

pub fn into_inner(self) -> String

English:
Consumes the identifier and returns its owned string.

日本語:
識別子を消費し、所有された文字列を返します。

Trait Implementations

impl Clone for OutboxMessageId

fn clone(&self) -> OutboxMessageId

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OutboxMessageId

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

Formats the value using the given formatter.

impl Eq for OutboxMessageId

impl Hash for OutboxMessageId

fn hash<__H>(&self, state: &mut __H)

where __H: Hasher,

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for OutboxMessageId

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for OutboxMessageId