fredis 10.1.0

An async client for Redis and Valkey.
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

#![allow(clippy::disallowed_names)]

use async_trait::async_trait;
use bytes_utils::Str;
use fredis::{prelude::*, types::Resolve};
use hickory_resolver::TokioResolver;
use std::{net::SocketAddr, sync::Arc};

pub struct HickoryDnsResolver(TokioResolver);

impl Default for HickoryDnsResolver {
  fn default() -> Self {
    HickoryDnsResolver(TokioResolver::builder(Default::default()).unwrap().build())
  }
}

#[async_trait]
impl Resolve for HickoryDnsResolver {
  async fn resolve(&self, host: Str, port: u16) -> Result<Vec<SocketAddr>, Error> {
    Ok(
      self
        .0
        .lookup_ip(&*host)
        .await?
        .into_iter()
        .map(|ip| SocketAddr::new(ip, port))
        .collect(),
    )
  }
}

#[tokio::main]
async fn main() -> Result<(), Error> {
  let client = Builder::default_centralized().build()?;
  client.set_resolver(Arc::new(HickoryDnsResolver::default())).await;
  client.init().await?;

  // ...

  client.quit().await?;
  Ok(())
}