Enum DispatchCommand 

pub enum DispatchCommand {
    Action {
        name: String,
        args: Vec<u8>,
        conn: ConnHandle,
        reply: Sender<Result<Vec<u8>>>,
    },
    QueueSend {
        name: String,
        body: Vec<u8>,
        conn: ConnHandle,
        request: Request,
        wait: bool,
        timeout_ms: Option<u64>,
        reply: Sender<Result<QueueSendResult>>,
    },
    Http {
        request: Request,
        reply: Sender<HttpDispatchResult>,
    },
    OpenWebSocket {
        conn: ConnHandle,
        ws: WebSocket,
        request: Option<Request>,
        reply: Sender<Result<()>>,
    },
    WorkflowHistory {
        reply: Sender<Result<Option<Vec<u8>>>>,
    },
    WorkflowReplay {
        entry_id: Option<String>,
        reply: Sender<Result<Option<Vec<u8>>>>,
    },
}

Variants

Action

Fields

name: String

args: Vec<u8>

conn: ConnHandle

reply: Sender<Result<Vec<u8>>>

QueueSend

Fields

name: String

body: Vec<u8>

conn: ConnHandle

request: Request

wait: bool

timeout_ms: Option<u64>

reply: Sender<Result<QueueSendResult>>

Http

Fields

request: Request

reply: Sender<HttpDispatchResult>

OpenWebSocket

Fields

conn: ConnHandle

ws: WebSocket

request: Option<Request>

reply: Sender<Result<()>>

WorkflowHistory

Fields

reply: Sender<Result<Option<Vec<u8>>>>

WorkflowReplay

Fields

entry_id: Option<String>

reply: Sender<Result<Option<Vec<u8>>>>