diff options
Diffstat (limited to 'common/rust/src/nats.rs')
| -rw-r--r-- | common/rust/src/nats.rs | 31 |
1 files changed, 16 insertions, 15 deletions
diff --git a/common/rust/src/nats.rs b/common/rust/src/nats.rs index 1a4d349..a001dc9 100644 --- a/common/rust/src/nats.rs +++ b/common/rust/src/nats.rs @@ -2,30 +2,31 @@ use nats::{Connection, Options}; use serde::Deserialize; #[derive(Clone, Debug, Deserialize)] -struct NatsConfigurationClientCert { - cert: String, - key: String, +pub struct NatsConfigurationClientCert { + pub cert: String, + pub key: String, } + #[derive(Clone, Debug, Deserialize)] -struct NatsConfigurationTls { - mtu: Option<usize>, +pub struct NatsConfigurationTls { + pub mtu: Option<usize>, } #[derive(Clone, Debug, Deserialize)] pub struct NatsConfiguration { - client_cert: Option<NatsConfigurationClientCert>, - root_cert: Option<Vec<String>>, - jetstream_api_prefix: Option<String>, - max_reconnects: Option<usize>, - reconnect_buffer_size: Option<usize>, - tls: Option<NatsConfigurationTls>, - client_name: Option<String>, - tls_required: Option<bool>, - host: String, + pub client_cert: Option<NatsConfigurationClientCert>, + pub root_cert: Option<Vec<String>>, + pub jetstream_api_prefix: Option<String>, + pub max_reconnects: Option<usize>, + pub reconnect_buffer_size: Option<usize>, + pub tls: Option<NatsConfigurationTls>, + pub client_name: Option<String>, + pub tls_required: Option<bool>, + pub host: String, } // todo: Prefer From since it automatically gives a free Into implementation -/// +// Allows the configuration to directly create a nats connection impl Into<Connection> for NatsConfiguration { fn into(self) -> Connection { let mut options = Options::new(); |
