Enum Inbound 

pub enum Inbound {
    Request {
        id: u64,
        method: String,
        params: Payload,
    },
    Subscribe {
        id: u64,
        topic: String,
    },
    Unsubscribe {
        sub: String,
    },
    Write {
        topic: String,
        payload: Payload,
    },
    Ping,
}

A logical request arriving over a Connection (what the server receives).

Variants

Request

An RPC call expecting a single Outbound::Reply.

Fields

id: u64

Correlation id, echoed in the reply.

method: String

Method name (e.g. "record.set", "query").

params: Payload

Unparsed method parameters.

Subscribe

Open a subscription producing many Outbound::Events.

Fields

id: u64

Correlation id for the subscription handshake.

topic: String

Topic to subscribe to.

Unsubscribe

Close a previously opened subscription.

Fields

sub: String

Subscription id to cancel.

Write

A fire-and-forget write (no reply).

Fields

topic: String

Destination topic.

payload: Payload

Unparsed record value.

Ping

Keepalive.