Enum EventsResponse 

pub enum EventsResponse {
    Appended {
        summary: BatchWriteSummary,
    },
    Idempotent {
        result: IdempotentEventBatchResult,
    },
    Event {
        event: Option<Event>,
    },
    Pageful {
        page: Page<Event>,
    },
    Count {
        count: u64,
    },
    Error {
        message: String,
        retryable: bool,
        writer_task_failure: Option<WireWriterTaskFailure>,
    },
}

Response frame from the events daemon.

Variants

Appended

Fields

summary: BatchWriteSummary

Idempotent

Fields

result: IdempotentEventBatchResult

Event

Fields

event: Option<Event>

Pageful

Fields

page: Page<Event>

Count

Fields

count: u64

Error

Typed refusal. retryable distinguishes transient daemon-side conditions from contract errors (bad frame, version skew). writer_task_failure carries both request finality and whether the remote writer seam terminated. The retryable bit cannot express that distinction: an ordinary operation or COMMIT error may be transient or permanent while its transaction is independently proven rolled back. None means the error is not from a writer request. Cross-version frames never reach this mapping because dispatch_events_request refuses a mismatched version before any write executes.

Fields

message: String

retryable: bool

writer_task_failure: Option<WireWriterTaskFailure>

Trait Implementations

impl Debug for EventsResponse

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for EventsResponse

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for EventsResponse

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

where __S: Serializer,

Serialize this value into the given Serde serializer.