Enum Frame 

pub enum Frame {
    ReqHeader {
        client_id: String,
        schema_version: i32,
    },
    PushCommit {
        client_commit_id: String,
        operations: Vec<Operation>,
    },
    PullHeader {
        limit_commits: i32,
        limit_snapshot_rows: i32,
        max_snapshot_pages: i32,
        accept: u8,
    },
    Subscription {
        id: String,
        table: String,
        scopes: Vec<(String, Vec<String>)>,
        params: Option<RawJson>,
        cursor: i64,
        bootstrap_state: Option<RawJson>,
    },
    RespHeader {
        required_schema_version: Option<i32>,
        latest_schema_version: Option<i32>,
    },
    Lease {
        lease_id: String,
        expires_at_ms: i64,
    },
    PushResult {
        client_commit_id: String,
        status: PushStatus,
        commit_seq: Option<i64>,
        results: Vec<OpResult>,
    },
    SubStart {
        id: String,
        status: SubStatus,
        reason_code: String,
        effective_scopes: Vec<(String, Vec<String>)>,
        bootstrap: bool,
    },
    Commit {
        commit_seq: i64,
        created_at_ms: i64,
        actor_id: String,
        tables: Vec<String>,
        changes: Vec<Change>,
    },
    SegmentRef {
        segment_id: String,
        media_type: MediaType,
        table: String,
        byte_length: i64,
        row_count: i64,
        as_of_commit_seq: i64,
        scope_digest: String,
        row_cursor: Option<String>,
        next_row_cursor: Option<String>,
        url: Option<String>,
        url_expires_at_ms: Option<i64>,
    },
    SegmentInline {
        payload: Vec<u8>,
    },
    SubEnd {
        next_cursor: i64,
        bootstrap_state: Option<RawJson>,
    },
    Error {
        code: String,
        message: String,
        category: String,
        retryable: bool,
        recommended_action: String,
        details: Option<RawJson>,
    },
    Unknown {
        frame_type: u8,
        payload: Vec<u8>,
    },
}

Variants

ReqHeader

Fields

client_id: String

schema_version: i32

PushCommit

Fields

client_commit_id: String

operations: Vec<Operation>

PullHeader

Fields

limit_commits: i32

limit_snapshot_rows: i32

max_snapshot_pages: i32

accept: u8

Subscription

Fields

id: String

table: String

scopes: Vec<(String, Vec<String>)>

params: Option<RawJson>

cursor: i64

bootstrap_state: Option<RawJson>

RespHeader

Fields

required_schema_version: Option<i32>

latest_schema_version: Option<i32>

Lease

§7.3.2: a server-issued auth lease delivered to the client (opaque).

Fields

lease_id: String

expires_at_ms: i64

PushResult

Fields

client_commit_id: String

status: PushStatus

commit_seq: Option<i64>

results: Vec<OpResult>

SubStart

Fields

id: String

status: SubStatus

reason_code: String

effective_scopes: Vec<(String, Vec<String>)>

bootstrap: bool

Commit

Fields

commit_seq: i64

created_at_ms: i64

actor_id: String

tables: Vec<String>

changes: Vec<Change>

SegmentRef

Fields

segment_id: String

media_type: MediaType

table: String

byte_length: i64

row_count: i64

as_of_commit_seq: i64

scope_digest: String

row_cursor: Option<String>

next_row_cursor: Option<String>

url: Option<String>

url_expires_at_ms: Option<i64>

SegmentInline

Raw payload bytes, validated at decode as a structurally valid rows segment (§5.7) and preserved verbatim for re-encoding.

Fields

payload: Vec<u8>

SubEnd

Fields

next_cursor: i64

bootstrap_state: Option<RawJson>

Error

Fields

code: String

message: String

category: String

retryable: bool

recommended_action: String

details: Option<RawJson>

Unknown

Unknown frame preserved by the §1.2 rule-2 skip rule: never dropped, re-encoded byte-for-byte in its original position.

Fields

frame_type: u8

payload: Vec<u8>

Trait Implementations

impl Clone for Frame

fn clone(&self) -> Frame

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Frame

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

Formats the value using the given formatter.

impl PartialEq for Frame

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for Frame