Enum WebSocketMessage 

pub enum WebSocketMessage {
    Subscribe {
        id: String,
        query: String,
        args: Value,
    },
    Unsubscribe {
        subscription_id: SubscriptionId,
    },
    Ping,
    Pong,
    Data {
        subscription_id: SubscriptionId,
        data: Value,
    },
    DeltaUpdate {
        subscription_id: SubscriptionId,
        delta: Delta<Value>,
    },
    JobUpdate {
        client_sub_id: String,
        job: JobData,
    },
    WorkflowUpdate {
        client_sub_id: String,
        workflow: WorkflowData,
    },
    Error {
        code: String,
        message: String,
    },
    ErrorWithId {
        id: String,
        code: String,
        message: String,
    },
}

Message types for WebSocket communication.

Variants

Subscribe

Subscribe to a query.

Fields

id: String

query: String

args: Value

Unsubscribe

Unsubscribe from a subscription.

Fields

subscription_id: SubscriptionId

Ping

Ping for keepalive.

Pong

Pong response.

Data

Initial data for subscription.

Fields

subscription_id: SubscriptionId

data: Value

DeltaUpdate

Delta update for subscription.

Fields

subscription_id: SubscriptionId

delta: Delta<Value>

JobUpdate

Job progress update.

Fields

client_sub_id: String

job: JobData

WorkflowUpdate

Workflow progress update.

Fields

client_sub_id: String

workflow: WorkflowData

Error

Error message.

Fields

code: String

message: String

ErrorWithId

Error message with subscription ID.

Fields

id: String

code: String

message: String

Trait Implementations

impl Clone for WebSocketMessage

fn clone(&self) -> WebSocketMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WebSocketMessage

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

Formats the value using the given formatter.