Generated from cargo doc --no-deps -p nemo-relay -p nemo-relay-adaptive -p nemo-relay-ffi.
pub struct AtofEndpointConfig {
pub url: String,
pub transport: AtofEndpointTransport,
pub headers: HashMap<String, String>,
pub timeout_millis: u64,
}
Streaming destination for raw ATOF events.
url: StringEndpoint URL.
transport: AtofEndpointTransportEndpoint transport.
headers: HashMap<String, String>Headers applied to endpoint requests or handshakes.
timeout_millis: u64Per-endpoint timeout in milliseconds.
impl AtofEndpointConfigimpl AtofEndpointConfig
newpub fn new(url: impl Into<String>, transport: AtofEndpointTransport) -> Self
Create a streaming endpoint with defaults.
with_headerpub fn with_header(
self,
key: impl Into<String>,
value: impl Into<String>,
) -> Self
Add a header to this endpoint config.
with_timeout_millispub fn with_timeout_millis(self, timeout_millis: u64) -> Self
Override the endpoint timeout.
impl Clone for AtofEndpointConfigimpl Clone for AtofEndpointConfig
clonefn clone(&self) -> AtofEndpointConfig
clone_fromfn clone_from(&mut self, source: &Self)
impl Debug for AtofEndpointConfigimpl Debug for AtofEndpointConfig
fmtfn fmt(&self, f: &mut Formatter<'_>) -> Result
impl<'de> Deserialize<'de> for AtofEndpointConfigimpl<'de> Deserialize<'de> for AtofEndpointConfig
deserializefn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
impl PartialEq for AtofEndpointConfigimpl PartialEq for AtofEndpointConfig
eqfn eq(&self, other: &AtofEndpointConfig) -> bool
nefn ne(&self, other: &Rhs) -> bool
impl Serialize for AtofEndpointConfigimpl Serialize for AtofEndpointConfig
serializefn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>where
__S: Serializer,
impl Eq for AtofEndpointConfigimpl Eq for AtofEndpointConfig
impl StructuralPartialEq for AtofEndpointConfigimpl StructuralPartialEq for AtofEndpointConfig