rabbitmq-backup-core 0.1.0

Core engine for RabbitMQ backup and restore operations
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

//! Simple channel ID tracking.
//!
//! For this backup tool, each queue gets its own AMQP connection + channel.
//! This module provides minimal channel ID management.

/// Tracks allocated channel IDs on a connection.
pub struct ChannelPool {
    allocated: Vec<u16>,
}

impl ChannelPool {
    pub fn new() -> Self {
        Self {
            allocated: Vec::new(),
        }
    }

    pub fn track(&mut self, channel_id: u16) {
        self.allocated.push(channel_id);
    }

    pub fn allocated(&self) -> &[u16] {
        &self.allocated
    }
}

impl Default for ChannelPool {
    fn default() -> Self {
        Self::new()
    }
}