bijux-dag-runtime 0.4.0

Execution engine, replay semantics, and runtime policy layer for Bijux DAG graphs.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

use serde::{Deserialize, Serialize};

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct RemoteExecutionRequest {
    pub run_id: String,
    pub node_id: String,
    pub contract_digest: String,
}

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct RemoteExecutionReceipt {
    pub submission_id: String,
    pub accepted: bool,
    pub reason: Option<String>,
}

pub trait RemoteExecutorSubmitter: Send + Sync {
    fn submit(&self, request: RemoteExecutionRequest) -> Result<RemoteExecutionReceipt, String>;
}