liminal-rs 0.2.0

A conversation-based messaging bus built on beamr
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 super::{
    RecordedSignalDelivery, SignalDeliverer, SignalOperation, SignalPayload, SignalRecorder,
};
use crate::aion::AionSurfaceError;
use crate::conversation::ParticipantPid;

#[derive(Debug)]
pub(super) struct NoopSignalDeliverer;

impl SignalDeliverer for NoopSignalDeliverer {
    fn deliver(
        &self,
        workflow_pid: ParticipantPid,
        signal: SignalPayload,
    ) -> Result<(), AionSurfaceError> {
        let _ = (workflow_pid, signal);
        Ok(())
    }
}

#[derive(Debug)]
pub(super) struct NoopSignalRecorder;

impl SignalRecorder for NoopSignalRecorder {
    fn replay_deliveries(
        &self,
        channel_name: &str,
        workflow_id: &str,
    ) -> Result<Vec<RecordedSignalDelivery>, AionSurfaceError> {
        let _ = (channel_name, workflow_id);
        Ok(Vec::new())
    }

    fn record(&self, operation: SignalOperation) -> Result<(), AionSurfaceError> {
        let _ = operation;
        Ok(())
    }
}