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
use serde::{Serialize, Deserialize};
use crate::config::TlsPolicy;
#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
#[non_exhaustive]
pub struct FluvioConfig {
#[serde(alias = "addr")]
pub endpoint: String,
#[serde(default)]
pub tls: TlsPolicy,
}
impl FluvioConfig {
pub fn new<S: Into<String>>(addr: S) -> Self {
Self {
endpoint: addr.into(),
tls: TlsPolicy::Disabled,
}
}
pub fn with_tls<T: Into<TlsPolicy>>(mut self, tls: T) -> Self {
self.tls = tls.into();
self
}
}