Enum actyx_sdk::service::SubscribeMonotonicResponse [−][src]
pub enum SubscribeMonotonicResponse { State { snapshot: SnapshotData, }, Event { event: EventResponse<Payload>, caught_up: bool, }, TimeTravel { new_start: EventKey, }, }
Expand description
Response to subscribeMonotonic is a stream of events terminated by a time travel
Variants
This message may be sent in the beginning when a suitable snapshot has been found for this session. It may also be sent at later times when suitable snapshots become available by other means (if for example this session is computed also on a different node).
Show fields
Fields of State
snapshot: SnapshotData
This is the main message, a new event that is to be applied directly to the currently known state to produce the next state.
Show fields
Fields of Event
event: EventResponse<Payload>
caught_up: bool
This message ends the stream in case a replay becomes necessary due to time travel. The contained event key signals how far back the replay will reach so that the consumer can invalidate locally stored snapshots (if relevant).
Show fields
Fields of TimeTravel
new_start: EventKey
Trait Implementations
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
[src]
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
[src]Deserialize this value from the given Serde deserializer. Read more
This method tests for self
and other
values to be equal, and is used
by ==
. Read more
This method tests for !=
.
This method returns an ordering between self
and other
values if one exists. Read more
This method tests less than (for self
and other
) and is used by the <
operator. Read more
This method tests less than or equal to (for self
and other
) and is used by the <=
operator. Read more
This method tests greater than (for self
and other
) and is used by the >
operator. Read more
Auto Trait Implementations
impl RefUnwindSafe for SubscribeMonotonicResponse
impl Send for SubscribeMonotonicResponse
impl Sync for SubscribeMonotonicResponse
impl Unpin for SubscribeMonotonicResponse
impl UnwindSafe for SubscribeMonotonicResponse
Blanket Implementations
Mutably borrows from an owned value. Read more
Casts the value.
Compare self to key
and return true
if they are equal.
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
Performs the conversion.
Performs the conversion.
Casts the value.
Casts the value.
Casts the value.
Casts the value.