pulsar 6.7.2

Rust client for Apache Pulsar
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

/// position of the first message that will be consumed
#[derive(Default, Clone, Debug, PartialEq)]
pub enum InitialPosition {
    /// start at the oldest message
    Earliest,
    /// start at the most recent message
    #[default]
    Latest,
}

impl From<InitialPosition> for i32 {
    #[cfg_attr(feature = "telemetry", tracing::instrument(skip_all))]
    fn from(i: InitialPosition) -> Self {
        match i {
            InitialPosition::Earliest => 1,
            InitialPosition::Latest => 0,
        }
    }
}