deadpool-amqprs 0.3.0

Dead simple async pool for amqprs
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
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83

use std::convert::Infallible;

use amqprs::connection::OpenConnectionArguments;
use deadpool::Runtime;

use crate::{Manager, Pool, PoolBuilder, PoolConfig};

/// Configuration object.
///
/// # Example
///
/// ```rs
/// use deadpool_amqprs::Config;
/// use amqprs::connection::OpenConnectionArguments;
///
/// let config = Config::new_with_con_args(OpenConnectionArguments::default())
///
/// let pool = config.create_pool();
///
/// // Do things with `pool`.
/// ```
#[derive(Clone, Default)]
pub struct Config {
    /// The [`OpenConnectionArguments`] passed to [`amqprs::connection::Connection::open`].
    pub con_args: OpenConnectionArguments,
    /// The [`PoolConfig`] passed to deadpool.
    pub pool_config: Option<PoolConfig>,
}

impl Config {
    /// Creates a new config with [`OpenConnectionArguments`] and optionally [`PoolConfig`].
    #[must_use]
    pub const fn new(con_args: OpenConnectionArguments, pool_config: Option<PoolConfig>) -> Self {
        Self {
            con_args,
            pool_config,
        }
    }

    /// Creates a new config with only [`OpenConnectionArguments`]
    #[must_use]
    pub const fn new_with_con_args(con_args: OpenConnectionArguments) -> Self {
        Self {
            con_args,
            pool_config: None,
        }
    }

    /// Creates a new pool with the current config.
    ///
    /// # Info
    ///
    /// Unlike other `deadpool-*` libs, `deadpool-amqprs` does not require user to pass [`deadpool::Runtime`],
    /// because amqprs is built on top of `tokio`, meaning one can only use `tokio` with it.
    #[must_use]
    pub fn create_pool(&self) -> Pool {
        self.builder()
            .build()
            .expect("`PoolBuilder::build` errored when it shouldn't")
    }

    /// Returns a [`PoolBuilder`] using the current config.
    ///
    /// # Info
    ///
    /// Unlike other `deadpool-*` libs, `deadpool-amqprs` does not require user to pass [`deadpool::Runtime`],
    /// because amqprs is built on top of `tokio`, meaning one can only use `tokio` with it.
    pub fn builder(&self) -> PoolBuilder {
        Pool::builder(Manager::new(self.con_args.clone()))
            .config(self.pool_config.unwrap_or_default())
            .runtime(Runtime::Tokio1)
    }
}

impl std::fmt::Debug for Config {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        f.debug_struct("Config")
            .field("pool_config", &self.pool_config)
            .finish_non_exhaustive()
    }
}

pub type ConfigError = Infallible;