relay-knowledge 1.1.14

Graph-database-based knowledge graph project.
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
31
32

use std::{error::Error, fmt, future::Future, pin::Pin};

/// Future returned by one bounded external worker request.
pub type WorkerOutboundFuture<'a> =
    Pin<Box<dyn Future<Output = Result<serde_json::Value, WorkerOutboundError>> + Send + 'a>>;

/// Adapter-neutral failure returned by an external worker endpoint.
#[derive(Debug, Clone, PartialEq, Eq)]
pub struct WorkerOutboundError {
    pub message: String,
}

impl fmt::Display for WorkerOutboundError {
    fn fmt(&self, formatter: &mut fmt::Formatter<'_>) -> fmt::Result {
        formatter.write_str(&self.message)
    }
}

impl Error for WorkerOutboundError {}

/// Bounded JSON transport used by worker orchestration.
pub trait WorkerOutboundPort: Send + Sync {
    fn post_json<'a>(
        &'a self,
        endpoint: &'a str,
        payload: &'a serde_json::Value,
    ) -> WorkerOutboundFuture<'a>;
}

#[cfg(test)]
#[path = "worker_outbound_tests.rs"]
mod tests;