mysql_async 0.37.0

Tokio based asynchronous MySql client library.
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

use std::{
    collections::VecDeque,
    sync::{atomic::Ordering, Arc},
};

use super::{metrics::Metrics, IdlingConn};

#[derive(Default, Debug)]
pub(crate) struct InPoolConnections {
    pub(crate) connections: VecDeque<IdlingConn>,
    pub(crate) metrics: Arc<Metrics>,
}

impl InPoolConnections {
    pub(crate) fn new(capacity: usize, metrics: Arc<Metrics>) -> Self {
        Self {
            connections: VecDeque::with_capacity(capacity),
            metrics,
        }
    }

    pub(crate) fn push_back(&mut self, conn: IdlingConn) {
        self.metrics
            .connections_in_pool
            .fetch_add(1, Ordering::Relaxed);
        self.connections.push_back(conn);
    }

    pub(crate) fn pop_back(&mut self) -> Option<IdlingConn> {
        let res = self.connections.pop_back();
        if res.is_some() {
            self.metrics
                .connections_in_pool
                .fetch_sub(1, Ordering::Relaxed);
        }

        res
    }

    pub(crate) fn pop_front(&mut self) -> Option<IdlingConn> {
        let res = self.connections.pop_front();
        if res.is_some() {
            self.metrics
                .connections_in_pool
                .fetch_sub(1, Ordering::Relaxed);
        }

        res
    }

    pub(crate) fn len(&self) -> usize {
        self.connections.len()
    }
}