Struct RedisAdapterConfig

Source
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

Source

pub fn new() -> Self

Create a new config.

Source

pub fn with_request_timeout(self, timeout: Duration) -> Self

Set the request timeout. Default is 5 seconds.

Source

pub fn with_prefix(self, prefix: impl Into<Cow<'static, str>>) -> Self

Set the prefix used for the channels. Default is “socket.io”.

Source

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.

Source

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

Source§

fn clone(&self) -> RedisAdapterConfig

Returns a copy of the value. Read more
1.0.0 · Source§

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more
Source§

impl Debug for RedisAdapterConfig

Source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more
Source§

impl Default for RedisAdapterConfig

Source§

fn default() -> Self

Returns the “default value” for a type. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts 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 more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts 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
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

impl<T> ErasedDestructor for T
where T: 'static,

Source§

impl<T> MaybeSendSync for T