wingfoil 6.0.5

graph based stream processing framework
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

// Shared payload + latency schema used by the latency_pub and latency_sub
// example binaries. Both processes must agree on the layout — the
// `latency_stages!` macro guarantees this when both sides declare the same
// stages in the same order.
use iceoryx2::prelude::ZeroCopySend;
use wingfoil::*;

/// The service the two processes connect on.
pub const SERVICE_NAME: &str = "wingfoil/examples/latency";

/// The business payload — must be `#[repr(C)]` and `ZeroCopySend` for iceoryx2.
#[repr(C)]
#[derive(Debug, Clone, Copy, Default, ZeroCopySend)]
pub struct Quote {
    pub seq: u64,
    pub price: f64,
}

// Latency schema, shared across processes. Stage order matters: it
// determines the offsets in the on-wire `[u64; N]` view of the record.
latency_stages! {
    pub QuoteLatency {
        // publisher side
        produce,
        publish,
        // subscriber side
        receive,
        strategy,
        ack,
    }
}