samsa 0.1.8

Rust-native Kafka/Redpanda protocol and client implementation.
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

use super::AdminAPI;
use crate::error::{Error, Result};
use std::collections::HashMap;
use std::sync::{Arc, Mutex};

#[derive(Clone, Debug, Default)]
pub struct Builder {
    urls: Vec<String>,
}

impl Builder {
    pub fn new() -> Self {
        Self::default()
    }

    pub fn build(self) -> Result<AdminAPI> {
        let client = reqwest::Client::builder()
            .build()
            .map_err(|err| Error::ArgError(err.to_string()))?;
        Ok(AdminAPI {
            broker_id_to_urls: Arc::new(Mutex::new(HashMap::new())),
            client,
            urls: self.urls,
        })
    }

    pub fn urls(&mut self, urls: Vec<String>) -> Self {
        self.urls = urls;
        self.clone()
    }
}