Enum Output 

pub enum Output {
    Transmit(Transmission),
    StoreCheckpoint {
        conversation: ConversationKey,
        next_id: u8,
        epoch: u16,
    },
    LookupOutbound {
        request_id: u32,
        conversation: ConversationKey,
        sequence: MessageSequence,
    },
    StoreArchive {
        key: ArchiveKey,
        payload: Vec<u8, MAX_FRAME>,
    },
    DeleteArchive {
        conversation: ConversationKey,
        message_id: u8,
    },
    StoreMessage(MessageMutation),
    Event(Event),
    Diagnostic(Diagnostic),
}

One drained output: an effect for the platform or an application event.

Variants

Transmit(Transmission)

StoreCheckpoint

Persist the outbound stream checkpoint before transmitting the frames queued after it.

Failure contract: outputs are ordered, so the platform sees this before the Output::Transmits it covers. If the write fails, the platform must drop (not send) those transmissions and resynchronize via Engine::restore; sending them anyway risks reusing a wire ID after the next power cycle without announcing a Sequence Reset.

Fields

conversation: ConversationKey

next_id: u8

epoch: u16

LookupOutbound

Look up resendable outbound material; answer with Engine::archive_result.

Fields

request_id: u32

conversation: ConversationKey

sequence: MessageSequence

StoreArchive

Store resendable material without transmitting it. Emitted when an edit re-issues the original message ID’s archive with the edited body: a later resend request for that ID must serve the edited content, never the superseded original.

Fields

key: ArchiveKey

payload: Vec<u8, MAX_FRAME>

DeleteArchive

Delete every archived fragment stored under this message ID (the unfragmented entry included). Emitted before an edit’s replacement Output::StoreArchives — so stale fragments of a differently fragmented original can never be served — and on delete, where the retracted content must no longer be resendable at all.

Fields

conversation: ConversationKey

message_id: u8

StoreMessage(MessageMutation)

Event(Event)

Diagnostic(Diagnostic)

Trait Implementations

impl Clone for Output

fn clone(&self) -> Output

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Output

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

Formats the value using the given formatter.