compio-pool 0.1.0

A bb8-style connection pool for compio: build once, clone the handle onto each thread-per-core io_uring runtime, and lease ring-local connections that never cross threads
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


use compio_pool::Builder; 
use compio_pool::ManageConnection;
use compio_pool::Pool; 


struct UdpConnection{
    addr: std::net::SocketAddr,
    connections: Vec<std::net::UdpSocket>,
}; 

type UdpConnectionError = std::io::Error;

impl ManageConnection for UdpConnection {
    type Connection = std::net::UdpSocket;
    type Error = UdpConnectionError;

    async fn connect(&self) -> Result<Self::Connection, Self::Error> {
        // let socket = std::net::UdpSocket::bind("
        todo!(); 
    }
    
    fn is_valid(&self, conn: &mut Self::Connection)
    -> impl Future<Output = Result<(), Self::Error>> {
        todo!()
    }
    
    fn has_broken(&self, conn: &mut Self::Connection) -> bool {
        todo!()
    }

}


#[compio::main]
async fn main() { 
    let file_pool = Pool::builder().max_size(4).build(compio_pool::FileManager);
}