betex 0.35.0

Betfair / Prediction Market Exchange
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
39
40
41
42
43
44
45
46
47
48
49
50

pub mod traits;

use rkyv::{bytecheck::CheckBytes, with::Skip};
use serde::{Deserialize, Serialize};

pub type RingSlot<T> = crossbeam_utils::CachePadded<Envelope<T>>;

#[derive(Debug, Clone)]
pub struct ResponseCallback {
    pub tx: flume::Sender<
        Result<crate::book::protocol::response::Response, crate::engine::error::EngineError>,
    >,
}

#[derive(
    Debug,
    Default,
    Clone,
    Serialize,
    Deserialize,
    rkyv::Archive,
    rkyv::Serialize,
    rkyv::Deserialize,
    CheckBytes,
)]
pub struct Envelope<T> {
    // Global Application sequence, set by publisher.
    pub seq: u64,
    pub payload: T,

    // framing
    pub tx_id: u64,  // monotonic transaction id
    pub tx_len: u16, // number of events in this transaction (solo event: 1)
    pub tx_ix: u16,  // 0-based index within the transaction (solo event: 0)

    #[serde(skip)]
    /// Runtime-only response callback for this tx (not persisted).
    #[rkyv(with = Skip)]
    pub response_cb: Option<ResponseCallback>,
}

impl<T> Envelope<T> {
    pub fn is_tx_start(&self) -> bool {
        self.tx_ix == 0
    }

    pub fn is_tx_end(&self) -> bool {
        self.tx_ix + 1 == self.tx_len
    }
}