Struct RedisPool

pub struct RedisPool { /* private fields */ }

Implementations

impl RedisPool

pub fn max_connections(&mut self, size: u32) -> &mut Self

Examples found in repository

examples/basic.rs (line 11)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let mut pool: RedisPool = RedisPool::from_str("localhost:6379").unwrap();
    // Or from SocketAddr
    // let mut pool = RedisPool::from(SocketAddr::from(([127, 0, 0, 1], 6379)));

    let _ = pool.max_connections(10).establish_pool().await?;

    pool.send_command("SET foo bar").await?;

    Ok(())
}

examples/read_from_stream.rs (line 14)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let mut pool = RedisPool::from_str("localhost:6379").unwrap();
    // Or from SocketAddr
    // let mut pool = RedisPool::from(SocketAddr::from(([127, 0, 0, 1], 6379)));

    let _ = pool.max_connections(10).establish_pool().await?;

    let redis_connection: Rc<RefCell<RedisConnection>> = pool.send_command("SET foo bar").await?;

    let mut redis_connection_guard = redis_connection.borrow_mut();

    let mut buffer = [0; 1024];

    redis_connection_guard.stream.read(&mut buffer).await?;

    println!("Response: {}", String::from_utf8_lossy(&buffer)); // Response: +OK

    let redis_connection: Rc<RefCell<RedisConnection>> = pool.send_command("PING").await?;

    let mut redis_connection_guard = redis_connection.borrow_mut();

    let mut buffer = [0; 1024];

    redis_connection_guard.stream.read(&mut buffer).await?;

    println!("Response: {}", String::from_utf8_lossy(&buffer)); // Response: +PONG

    Ok(())
}

pub async fn establish_pool(&mut self) -> Result<(), RedisError>

Examples found in repository

examples/basic.rs (line 11)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let mut pool: RedisPool = RedisPool::from_str("localhost:6379").unwrap();
    // Or from SocketAddr
    // let mut pool = RedisPool::from(SocketAddr::from(([127, 0, 0, 1], 6379)));

    let _ = pool.max_connections(10).establish_pool().await?;

    pool.send_command("SET foo bar").await?;

    Ok(())
}

examples/read_from_stream.rs (line 14)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let mut pool = RedisPool::from_str("localhost:6379").unwrap();
    // Or from SocketAddr
    // let mut pool = RedisPool::from(SocketAddr::from(([127, 0, 0, 1], 6379)));

    let _ = pool.max_connections(10).establish_pool().await?;

    let redis_connection: Rc<RefCell<RedisConnection>> = pool.send_command("SET foo bar").await?;

    let mut redis_connection_guard = redis_connection.borrow_mut();

    let mut buffer = [0; 1024];

    redis_connection_guard.stream.read(&mut buffer).await?;

    println!("Response: {}", String::from_utf8_lossy(&buffer)); // Response: +OK

    let redis_connection: Rc<RefCell<RedisConnection>> = pool.send_command("PING").await?;

    let mut redis_connection_guard = redis_connection.borrow_mut();

    let mut buffer = [0; 1024];

    redis_connection_guard.stream.read(&mut buffer).await?;

    println!("Response: {}", String::from_utf8_lossy(&buffer)); // Response: +PONG

    Ok(())
}

pub async fn send_command( &mut self, command: &str, ) -> Result<Rc<RefCell<RedisConnection>>, RedisError>

Examples found in repository

examples/basic.rs (line 13)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let mut pool: RedisPool = RedisPool::from_str("localhost:6379").unwrap();
    // Or from SocketAddr
    // let mut pool = RedisPool::from(SocketAddr::from(([127, 0, 0, 1], 6379)));

    let _ = pool.max_connections(10).establish_pool().await?;

    pool.send_command("SET foo bar").await?;

    Ok(())
}

examples/read_from_stream.rs (line 16)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let mut pool = RedisPool::from_str("localhost:6379").unwrap();
    // Or from SocketAddr
    // let mut pool = RedisPool::from(SocketAddr::from(([127, 0, 0, 1], 6379)));

    let _ = pool.max_connections(10).establish_pool().await?;

    let redis_connection: Rc<RefCell<RedisConnection>> = pool.send_command("SET foo bar").await?;

    let mut redis_connection_guard = redis_connection.borrow_mut();

    let mut buffer = [0; 1024];

    redis_connection_guard.stream.read(&mut buffer).await?;

    println!("Response: {}", String::from_utf8_lossy(&buffer)); // Response: +OK

    let redis_connection: Rc<RefCell<RedisConnection>> = pool.send_command("PING").await?;

    let mut redis_connection_guard = redis_connection.borrow_mut();

    let mut buffer = [0; 1024];

    redis_connection_guard.stream.read(&mut buffer).await?;

    println!("Response: {}", String::from_utf8_lossy(&buffer)); // Response: +PONG

    Ok(())
}

Trait Implementations

impl From<SocketAddr> for RedisPool

fn from(addr: SocketAddr) -> Self

Converts to this type from the input type.

impl FromStr for RedisPool

type Err = RedisError

The associated error which can be returned from parsing.

fn from_str(connection_str: &str) -> Result<Self, Self::Err>

Parses a string s to return a value of this type.