[−][src]Struct eventstore::ConnectionBuilder
Helps constructing a connection to the server.
Fields
settings: Settings
Methods
impl ConnectionBuilder
[src]
pub fn heartbeat_delay(self, delay: Duration) -> Self
[src]
Maximum delay of inactivity before the client sends a heartbeat request.
pub fn heartbeat_timeout(self, timeout: Duration) -> Self
[src]
Maximum delay the server has to issue a heartbeat response.
pub fn operation_timeout(self, timeout: Duration) -> Self
[src]
Delay in which an operation will be retried if no response arrived.
pub fn operation_retry(self, strategy: Retry) -> Self
[src]
Retry strategy when an operation has timeout.
pub fn connection_retry(self, strategy: Retry) -> Self
[src]
Retry strategy when failing to connect.
pub fn with_default_user(self, user: Credentials) -> Self
[src]
'Credentials' to use if other Credentials
are not explicitly supplied
when issuing commands.
pub fn with_connection_name(self, name: String) -> Self
[src]
Default connection name.
pub fn operation_check_period(self, period: Duration) -> Self
[src]
The period used to check pending command. Those checks include if the the connection has timeout or if the command was issued with a different connection.
pub fn start<A>(self, addrs: A) -> Result<Connection> where
A: ToSocketAddrs,
[src]
A: ToSocketAddrs,
Creates a connection to an EventStore server. The connection will
start right away. This method will pick the first SocketAddr
it
has resolved.
pub fn start_with_runtime<A>(
self,
addrs: A,
runtime: &mut Runtime
) -> Result<Connection> where
A: ToSocketAddrs,
[src]
self,
addrs: A,
runtime: &mut Runtime
) -> Result<Connection> where
A: ToSocketAddrs,
Creates a connection to an EventStore server. The connection will
start right away. This method will pick the first SocketAddr
it
has resolved.
Auto Trait Implementations
impl Send for ConnectionBuilder
impl Sync for ConnectionBuilder
Blanket Implementations
impl<T, U> Into for T where
U: From<T>,
[src]
U: From<T>,
impl<T> From for T
[src]
impl<T, U> TryFrom for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T> Borrow for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T, U> TryInto for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,