Struct PGRobustClientConfig 

pub struct PGRobustClientConfig<TLS> { /* private fields */ }

Implementations

impl<TLS> PGRobustClientConfig<TLS>

where TLS: MakeTlsConnect<Socket> + Clone, <TLS as MakeTlsConnect<Socket>>::Stream: Send + Sync + 'static,

pub fn new( database_url: impl Into<String>, make_tls: TLS, ) -> PGRobustClientConfig<TLS>

pub fn subscriptions( self, subscriptions: impl IntoIterator<Item = impl Into<String>>, ) -> Self

pub fn with_subscriptions( &mut self, subscriptions: impl IntoIterator<Item = impl Into<String>>, )

pub fn without_subscriptions( &mut self, subscriptions: impl IntoIterator<Item = impl Into<String>>, )

pub fn callback( self, callback: impl Fn(PGMessage) + Send + Sync + 'static, ) -> Self

pub fn with_callback( &mut self, callback: impl Fn(PGMessage) + Send + Sync + 'static, )

pub fn max_reconnect_attempts(self, max_reconnect_attempts: u32) -> Self

pub fn with_max_reconnect_attempts( &mut self, max_reconnect_attempts: Option<u32>, )

pub fn default_timeout(self, default_timeout: Duration) -> Self

pub fn with_default_timeout(&mut self, default_timeout: Option<Duration>)

pub fn connect_script(self, connect_script: impl Into<String>) -> Self

pub fn with_connect_script(&mut self, connect_script: Option<impl Into<String>>)

pub fn application_name(self, application_name: impl Into<String>) -> Self

pub fn with_application_name( &mut self, application_name: Option<impl Into<String>>, )

pub fn full_connect_script(&self) -> Option<String>

Trait Implementations

impl<TLS: Clone> Clone for PGRobustClientConfig<TLS>

fn clone(&self) -> PGRobustClientConfig<TLS>

Returns a duplicate of the value.

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

Performs copy-assignment from source.