uwheel 0.4.0

Embeddable Aggregate Management System for Streams and Queries
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

use core::cmp::Ordering;

/// Defines an ascending order of TopN aggregates
#[derive(Clone, Debug, Copy, Default)]
pub struct Ascending;

/// Defines a descending order of TopN aggregates
#[derive(Clone, Debug, Copy, Default)]
pub struct Descending;

/// A TopN Order type supporting either [Ascending] or [Descending] variants
pub trait Order: private::Sealed {
    #[doc(hidden)]
    fn ordering() -> Ordering;
}

impl Order for Ascending {
    fn ordering() -> Ordering {
        Ordering::Less
    }
}

impl Order for Descending {
    fn ordering() -> Ordering {
        Ordering::Greater
    }
}
/// Sealed traits
mod private {
    use core::fmt::Debug;

    pub trait Sealed: Clone + Copy + Debug + Default + Send + 'static {}
}

impl private::Sealed for Ascending {}
impl private::Sealed for Descending {}