Struct RedisConf

pub struct RedisConf<'a> { /* private fields */ }

Implementations

impl<'a> RedisConf<'a>

pub fn builder() -> Self

Examples found in repository

examples/redis_basic.rs (line 7)

fn main() {
    let dsn = "redis://:@127.0.0.1:6379/0";
    let pool = RedisConf::builder().with_dsn(dsn).init_pool();
    let mut conn = pool.get().unwrap();

    // 设置单个pool timeout
    // let mut conn = pool.get_timeout(Duration::from_secs(2)).unwrap();
    let res: RedisResult<String> = conn.set("my_user", "daheige");
    if res.is_err() {
        println!("redis set error:{}", res.err().unwrap().to_string());
    } else {
        println!("set success");
    }
}

pub fn with_dsn(self, dsn: &'a str) -> Self

Examples found in repository

examples/redis_basic.rs (line 7)

fn main() {
    let dsn = "redis://:@127.0.0.1:6379/0";
    let pool = RedisConf::builder().with_dsn(dsn).init_pool();
    let mut conn = pool.get().unwrap();

    // 设置单个pool timeout
    // let mut conn = pool.get_timeout(Duration::from_secs(2)).unwrap();
    let res: RedisResult<String> = conn.set("my_user", "daheige");
    if res.is_err() {
        println!("redis set error:{}", res.err().unwrap().to_string());
    } else {
        println!("set success");
    }
}

pub fn with_cluster_nodes(self, nodes: Vec<&'a str>) -> Self

pub fn with_max_size(self, max: u32) -> Self

pub fn with_min_idle(self, min: u32) -> Self

pub fn with_max_lifetime(self, lifetime: Duration) -> Self

pub fn with_idle_timeout(self, timeout: Duration) -> Self

pub fn with_connect_timeout(self, timeout: Duration) -> Self

pub fn client(&self) -> RedisResult<Client>

pub fn cluster_client(&self) -> RedisResult<ClusterClient>

pub fn init_pool(&self) -> Pool<Client>

Examples found in repository

examples/redis_basic.rs (line 7)

fn main() {
    let dsn = "redis://:@127.0.0.1:6379/0";
    let pool = RedisConf::builder().with_dsn(dsn).init_pool();
    let mut conn = pool.get().unwrap();

    // 设置单个pool timeout
    // let mut conn = pool.get_timeout(Duration::from_secs(2)).unwrap();
    let res: RedisResult<String> = conn.set("my_user", "daheige");
    if res.is_err() {
        println!("redis set error:{}", res.err().unwrap().to_string());
    } else {
        println!("set success");
    }
}

pub fn init_cluster_pool(&self) -> Pool<ClusterClient>

Trait Implementations

impl<'a> Debug for RedisConf<'a>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'a> Default for RedisConf<'a>

fn default() -> RedisConf<'a>

Returns the “default value” for a type.