zebflow 0.10.3

Reactive web automation platform — pipelines, templates, and real-time collaboration in a single binary.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

//! Typed master/worker control messages.

use serde::{Deserialize, Serialize};
use serde_json::Value;

/// Control request sent over the master/worker transport.
#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
#[serde(tag = "kind", rename_all = "snake_case")]
pub enum ControlRequest {
    /// Worker registration request.
    RegisterWorker { node_id: String, metadata: Value },
    /// Heartbeat message from worker to master.
    Heartbeat { node_id: String, metadata: Value },
    /// Project bundle sync request.
    SyncProject {
        owner: String,
        project: String,
        bundle: Value,
    },
}

/// Control response sent back over the master/worker transport.
#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
#[serde(tag = "kind", rename_all = "snake_case")]
pub enum ControlResponse {
    /// Generic success response.
    Ack { message: String },
    /// Error-like response payload.
    Rejected { code: String, message: String },
}