pub struct RedisAdapterConfig {
pub request_timeout: Duration,
pub prefix: Cow<'static, str>,
pub ack_response_buffer: usize,
pub stream_buffer: usize,
}
Expand description
The configuration of the RedisAdapter
.
Fields§
§request_timeout: Duration
The request timeout. It is mainly used when expecting response such as when using
broadcast_with_ack
or rooms
. Default is 5 seconds.
prefix: Cow<'static, str>
The prefix used for the channels. Default is “socket.io”.
ack_response_buffer: usize
The channel size used to receive ack responses. Default is 255.
If you have a lot of servers/sockets and that you may miss acknowledgement because they arrive faster than you poll them with the returned stream, you might want to increase this value.
stream_buffer: usize
The channel size used to receive messages. Default is 1024.
If your server is under heavy load, you might want to increase this value.
Implementations§
Source§impl RedisAdapterConfig
impl RedisAdapterConfig
Sourcepub fn with_request_timeout(self, timeout: Duration) -> Self
pub fn with_request_timeout(self, timeout: Duration) -> Self
Set the request timeout. Default is 5 seconds.
Sourcepub fn with_prefix(self, prefix: impl Into<Cow<'static, str>>) -> Self
pub fn with_prefix(self, prefix: impl Into<Cow<'static, str>>) -> Self
Set the prefix used for the channels. Default is “socket.io”.
Sourcepub fn with_ack_response_buffer(self, buffer: usize) -> Self
pub fn with_ack_response_buffer(self, buffer: usize) -> Self
Set the channel size used to send ack responses. Default is 255.
If you have a lot of servers/sockets and that you may miss acknowledgement because they arrive faster than you poll them with the returned stream, you might want to increase this value.
Sourcepub fn with_stream_buffer(self, buffer: usize) -> Self
pub fn with_stream_buffer(self, buffer: usize) -> Self
Set the channel size used to receive messages. Default is 1024.
If your server is under heavy load, you might want to increase this value.
Trait Implementations§
Source§impl Clone for RedisAdapterConfig
impl Clone for RedisAdapterConfig
Source§fn clone(&self) -> RedisAdapterConfig
fn clone(&self) -> RedisAdapterConfig
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moreSource§impl Debug for RedisAdapterConfig
impl Debug for RedisAdapterConfig
Auto Trait Implementations§
impl Freeze for RedisAdapterConfig
impl RefUnwindSafe for RedisAdapterConfig
impl Send for RedisAdapterConfig
impl Sync for RedisAdapterConfig
impl Unpin for RedisAdapterConfig
impl UnwindSafe for RedisAdapterConfig
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
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
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> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read more