laminarmq 0.0.5

A scalable, distributed message queue powered by a segmented, partitioned, replicated and immutable log.
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

#[cfg(test)]
mod tests {
    use super::super::{
        super::super::{commit_log::segmented_log::index, common::_TestStorage},
        storage::InMemStorage,
    };
    use std::marker::PhantomData;

    #[test]
    fn test_index_read_append_truncate_consistency() {
        futures_lite::future::block_on(async {
            index::test::_test_index_read_append_truncate_consistency(|| async {
                (
                    _TestStorage {
                        storage: InMemStorage::default(),
                        persistent: false,
                    },
                    PhantomData::<(crc32fast::Hasher, u32)>,
                )
            })
            .await;
        });
    }
}