pub enum ServerPush {
ObserverProgressed {
conversation_id: ConversationId,
refused_epoch: ObserverEpoch,
observer_progress: DeliverySeq,
},
ParticipantDelivery(ParticipantDelivery),
MarkerSettled {
conversation_id: ConversationId,
refused_epoch: SettlementEpoch,
},
}Expand description
Exhaustive pushed participant control/value.
Variants§
ObserverProgressed
Observer progress wake (0x0200).
Fields
conversation_id: ConversationIdConversation whose observer advanced.
refused_epoch: ObserverEpochRefusal epoch the progress may wake.
observer_progress: DeliverySeqCurrent observer progress.
ParticipantDelivery(ParticipantDelivery)
Participant record delivery (0x0201).
MarkerSettled
Marker-settlement clearing wake (0x0202).
Paired with the MarkerSettlementBackpressure refusal and delivered
CONNECTION-SCOPED: exactly to the connections that received that refusal
in this process lifetime, mirroring ObserverProgressed’s connection-level
delivery. A refused attach client holds no binding and therefore receives
no ParticipantDelivery, so without this wake the only honest client
behavior would be polling.
It is NEVER sent to a connection refused at the enrollment wrapper: that
wrapper carries no membership predicate, so its refusal
(EnrollmentSettlementBackpressure) carries neither epoch nor wake
(participant contract §0.16 condition 2, enrollment wrapper).
Fields
conversation_id: ConversationIdConversation whose marker settlement cleared.
refused_epoch: SettlementEpochRefusal epoch this clearing wakes; matched by the stage-11 retry
against the refusal’s own refused_epoch.
Implementations§
Source§impl ServerPush
impl ServerPush
Sourcepub const fn discriminant(&self) -> PushDiscriminant
pub const fn discriminant(&self) -> PushDiscriminant
Returns the stable push discriminant.
Trait Implementations§
Source§impl Clone for ServerPush
impl Clone for ServerPush
Source§fn clone(&self) -> ServerPush
fn clone(&self) -> ServerPush
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read more