pub struct WsEndpointConfig {Show 21 fields
pub scheme: String,
pub host: String,
pub port: u16,
pub path: String,
pub max_connections: u32,
pub max_message_size: u32,
pub send_to_all: bool,
pub heartbeat_interval: Duration,
pub idle_timeout: Duration,
pub connect_timeout: Duration,
pub response_timeout: Duration,
pub allow_origin: String,
pub tls_cert: Option<String>,
pub tls_key: Option<String>,
pub reconnect: bool,
pub reconnect_max_attempts: u32,
pub reconnect_delay_ms: u64,
pub send_timeout: Duration,
pub binary_payload: bool,
pub subprotocols: Vec<String>,
pub reconnect_policy: NetworkRetryPolicy,
}Fields§
§scheme: String§host: String§port: u16§path: String§max_connections: u32§max_message_size: u32§send_to_all: bool§heartbeat_interval: Duration§idle_timeout: Duration§connect_timeout: Duration§response_timeout: Duration§allow_origin: String§tls_cert: Option<String>§tls_key: Option<String>§reconnect: bool§reconnect_max_attempts: u32§reconnect_delay_ms: u64§send_timeout: Duration§binary_payload: bool§subprotocols: Vec<String>§reconnect_policy: NetworkRetryPolicyStructured reconnection policy, replacing the flat reconnect/
reconnect_max_attempts/reconnect_delay_ms fields for new config.
The flat fields remain as a backward-compat shim and are bridged into
this policy during from_uri() construction.
Implementations§
Source§impl WsEndpointConfig
impl WsEndpointConfig
pub fn from_uri(uri: &str) -> Result<Self, CamelError>
pub fn server_config(&self) -> WsServerConfig
pub fn client_config(&self) -> WsClientConfig
pub fn canonical_host(&self) -> String
Trait Implementations§
Source§impl Clone for WsEndpointConfig
impl Clone for WsEndpointConfig
Source§fn clone(&self) -> WsEndpointConfig
fn clone(&self) -> WsEndpointConfig
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for WsEndpointConfig
impl Debug for WsEndpointConfig
Auto Trait Implementations§
impl Freeze for WsEndpointConfig
impl RefUnwindSafe for WsEndpointConfig
impl Send for WsEndpointConfig
impl Sync for WsEndpointConfig
impl Unpin for WsEndpointConfig
impl UnsafeUnpin for WsEndpointConfig
impl UnwindSafe for WsEndpointConfig
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> ErasedDestructor for Twhere
T: 'static,
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request