Enum ServerControl 

pub enum ServerControl {
    HelloAck {
        protocol_major: ProtocolVersion,
        protocol_minor: u32,
        capabilities: Vec<CapabilityName>,
        sealed: bool,
        watermark: Option<Seq>,
    },
    HelloRefusal {
        code: KernelErrorCode,
        message: String,
    },
    Response {
        request_id: RequestId,
        result: KernelResult,
    },
    EventBatch {
        request_id: RequestId,
        events: Vec<EventEnvelope>,
        cursor: Seq,
    },
    StreamClosed {
        request_id: RequestId,
        code: KernelErrorCode,
        last_cursor: Option<Seq>,
    },
}

Everything the kernel may send on kind 0x01.

Variants

HelloAck

Fields

protocol_major: ProtocolVersion

protocol_minor: u32

min(client_minor, server_minor).

capabilities: Vec<CapabilityName>

The INTERSECTION of what the client asked for and what this kernel offers. A client must not assume anything absent here.

sealed: bool

watermark: Option<Seq>

HelloRefusal

Fields

code: KernelErrorCode

message: String

Response

Fields

request_id: RequestId

result: KernelResult

EventBatch

One batch on a live subscription. cursor is the last sequence in the batch — what a reconnect resumes from.

Fields

request_id: RequestId

events: Vec<EventEnvelope>

cursor: Seq

StreamClosed

A subscription ended. last_cursor is what the consumer actually received, so a slow-consumer disconnect resumes without a gap.

Fields

request_id: RequestId

code: KernelErrorCode

last_cursor: Option<Seq>

Trait Implementations

impl Clone for ServerControl

fn clone(&self) -> ServerControl

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ServerControl

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ServerControl

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for ServerControl

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for ServerControl

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for ServerControl

impl Type for ServerControl

fn definition(types: &mut Types) -> DataType

Returns a DataType that represents Self.