hebo 0.3.3

Distributed MQTT broker
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
48
49
50
51
52
53
54

// Copyright (c) 2021 Xu Shaohua <shaohua@biofan.org>. All rights reserved.
// Use of this source is governed by Affero General Public License that can be found
// in the LICENSE file.

use codec::QoS;

pub type ListenerId = u32;
pub type SessionId = u64;
pub type Uptime = u64;

/// Global session id.
///
/// It is a `(listener_id, session_id)` pair.
#[derive(Debug, Default, Clone, Copy, PartialEq, Eq, PartialOrd, Ord, Hash)]
pub struct SessionGid {
    listener_id: ListenerId,
    session_id: SessionId,
}

impl SessionGid {
    #[must_use]
    pub const fn new(listener_id: ListenerId, session_id: SessionId) -> Self {
        Self {
            listener_id,
            session_id,
        }
    }

    /// Get listener id.
    #[must_use]
    #[inline]
    pub const fn listener_id(&self) -> ListenerId {
        self.listener_id
    }

    /// Get session id.
    #[must_use]
    #[inline]
    pub const fn session_id(&self) -> SessionId {
        self.session_id
    }
}

/// Represents a session object.
#[derive(Debug, Clone)]
pub struct SessionInfo {
    pub listener_id: ListenerId,
    pub session_id: SessionId,
    pub qos: QoS,
    pub client_id: String,
    pub ip: String,
    pub connected_at: u64,
    pub tls: bool,
}