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
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47

pub mod segmented_log {
    #[cfg(test)]
    pub mod tests {
        use super::super::super::{
            super::super::{super::common::serde_compat::bincode, commit_log::segmented_log},
            segment::InMemSegmentStorageProvider,
        };
        use futures_time::{future::FutureExt, time::Duration};
        use std::marker::PhantomData;

        #[test]
        fn test_segmented_log_read_append_truncate_consistency() {
            futures_lite::future::block_on(async {
                segmented_log::test::_test_segmented_log_read_append_truncate_consistency(
                    InMemSegmentStorageProvider::<u32>::default(),
                    PhantomData::<((), crc32fast::Hasher, bincode::BinCode)>,
                )
                .await;
            });
        }

        #[test]
        fn test_segmented_log_remove_expired_segments() {
            async_io::block_on(async {
                segmented_log::test::_test_segmented_log_remove_expired_segments(
                    InMemSegmentStorageProvider::<u32>::default(),
                    |duration| async {}.delay(Duration::from(duration)),
                    PhantomData::<((), crc32fast::Hasher, bincode::BinCode)>,
                )
                .await;
            });
        }

        #[test]
        fn test_segmented_log_segment_index_caching() {
            async_io::block_on(async {
                segmented_log::test::_test_segmented_log_segment_index_caching(
                    InMemSegmentStorageProvider::<u32>::default(),
                    |duration| async {}.delay(Duration::from(duration)),
                    true,
                    PhantomData::<((), crc32fast::Hasher, bincode::BinCode)>,
                )
                .await;
            });
        }
    }
}