#[non_exhaustive]pub struct ConnectHandlers {
pub connection_listener: Option<ConnectionListener>,
pub connection_event_inbox_capacity: usize,
pub error_handler: Option<QwpWsErrorHandler>,
pub error_inbox_capacity: usize,
}Expand description
Connection pool for QWP/WebSocket ingestion and egress.
Construct with QuestDb::connect. Share the pool across threads — its
internal state is Mutex-guarded so QuestDb::borrow_sender /
QuestDb::reap_idle / Drop-driven returns are safe to interleave.
Each borrow (BorrowedSender / the internal direct sender) is not
Send — it belongs to the thread that borrowed it. To ingest in parallel,
borrow one sender per worker thread from the same QuestDb.
Optional per-pool event handlers for QuestDb::connect_with_handlers.
Fields (Non-exhaustive)§
This struct is marked as non-exhaustive
Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional
Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.connection_listener: Option<ConnectionListener>Connection lifecycle listener; see QuestDb::connect_with_listener.
connection_event_inbox_capacity: usizeListener inbox capacity; 0 selects the default (64).
error_handler: Option<QwpWsErrorHandler>Server-rejection handler; without one every rejection is logged.
error_inbox_capacity: usizeHandler inbox capacity; 0 selects the default (64).
Trait Implementations§
Source§impl Default for ConnectHandlers
impl Default for ConnectHandlers
Source§fn default() -> ConnectHandlers
fn default() -> ConnectHandlers
Returns the “default value” for a type. Read more
Auto Trait Implementations§
impl !RefUnwindSafe for ConnectHandlers
impl !UnwindSafe for ConnectHandlers
impl Freeze for ConnectHandlers
impl Send for ConnectHandlers
impl Sync for ConnectHandlers
impl Unpin for ConnectHandlers
impl UnsafeUnpin for ConnectHandlers
Blanket Implementations§
Source§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
Source§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
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> 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> ⓘ
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 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> ⓘ
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