disruptor-mp 0.1.0-alpha.2

Ultra-low-latency and high-throughput multiprocess ring-buffer substrate over SHM and mmap (LMAX Disruptor design, extended cross-process), with cross-process producer/consumer coordination, required-consumer liveness, and observability counters.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use disruptor_mp::{
    backend,
    lock_free::{ConsumerBarrier, ProducerBarrier, SharedCursor},
    shared_memory::{SharedMemoryConfig, SharedRingBuffer, ShmRingBuffer},
    CoordinationMode, DiscoveryMode, SharedConsumer, SharedProducer,
};

#[test]
fn public_namespace_smoke_test() {
    let _ = std::mem::size_of::<SharedMemoryConfig>();
    let _ = std::mem::size_of::<SharedCursor>();
    let _ = std::mem::size_of::<ConsumerBarrier>();
    let _ = std::mem::size_of::<ProducerBarrier>();

    let _shared_ring: Option<SharedRingBuffer<u64>> = None;
    let _shm_ring: Option<ShmRingBuffer<u64>> = None;
    let _backend_shm_ring: Option<backend::shared_memory::ShmRingBuffer<u64>> = None;
    let _producer: Option<SharedProducer<u64>> = None;
    let _consumer: Option<SharedConsumer<u64>> = None;

    let _mode = CoordinationMode::Immediate;
    let _discovery = DiscoveryMode::Disabled;
}