Enum ClientMessage 

pub enum ClientMessage {
    Subscribe {
        id: String,
        function_name: String,
        args: Option<Value>,
    },
    Unsubscribe {
        id: String,
    },
    SubscribeJob {
        id: String,
        job_id: String,
    },
    UnsubscribeJob {
        id: String,
    },
    SubscribeWorkflow {
        id: String,
        workflow_id: String,
    },
    UnsubscribeWorkflow {
        id: String,
    },
    Ping,
    Auth {
        token: String,
    },
}

Incoming WebSocket message from client.

Variants

Subscribe

Subscribe to a query.

Fields

id: String

function_name: String

args: Option<Value>

Unsubscribe

Unsubscribe from a subscription.

Fields

id: String

SubscribeJob

Subscribe to job progress updates.

Fields

id: String

Client-provided subscription ID (for correlation)

job_id: String

Job UUID - MUST be validated as UUID

UnsubscribeJob

Unsubscribe from job updates.

Fields

id: String

SubscribeWorkflow

Subscribe to workflow progress updates.

Fields

id: String

Client-provided subscription ID (for correlation)

workflow_id: String

Workflow run UUID - MUST be validated as UUID

UnsubscribeWorkflow

Unsubscribe from workflow updates.

Fields

id: String

Ping

Ping for keepalive.

Auth

Authentication.

Fields

token: String

Trait Implementations

impl Debug for ClientMessage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ClientMessage

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.