tigrbl_rs_ports 0.4.1

Trait and envelope boundaries for Rust atoms, handlers, engines, and callbacks.
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
33
34
35
36
37
38

use crate::errors::PortResult;
use tigrbl_rs_spec::values::Value;

#[derive(Debug, Clone, PartialEq, Eq)]
pub enum ChannelFamily {
    Request,
    Response,
    Stream,
    Socket,
    Session,
}

#[derive(Debug, Clone, PartialEq, Eq)]
pub enum ChannelSubevent {
    Connect,
    Receive,
    Emit,
    Complete,
    Disconnect,
}

#[derive(Debug, Clone, PartialEq, Eq)]
pub struct OpChannel {
    pub kind: String,
    pub family: ChannelFamily,
    pub exchange: String,
    pub protocol: String,
    pub path: String,
    pub selector: Option<String>,
    pub framing: Option<String>,
    pub subevents: Vec<ChannelSubevent>,
}

pub trait ChannelPort: Send + Sync {
    fn receive(&self, channel: &OpChannel) -> PortResult<Option<Value>>;
    fn emit(&self, channel: &OpChannel, payload: Value) -> PortResult<()>;
    fn complete(&self, channel: &OpChannel) -> PortResult<()>;
}