Struct tarantool::network::client::reconnect::Client

pub struct Client { /* private fields */ }

A reconnecting version of super::Client.

Does not reconnect automatically but provides a method Client::reconnect for explicit reconnection, when the user finds it necessary. Can be cloned to utilize the same connection from multiple fibers.

See super::AsClient for the full API.

Implementations

impl Client

pub fn reconnect(&self)

Request client to reconnect before executing next operation.

If one of the cloned clients (used in other fibers/places) has already reconnected, this client will use this new connection instead of trying to establish a new one.

When reconnection happens ongoing requests (processing in other fibers) will continue on the old connection, but any new request will use the new connection.

pub async fn reconnect_now(&self) -> Result<(), Error>

Force reconnection.

If one of the cloned clients (used in other fibers/places) has already reconnected, this client will use this new connection instead of trying to establish a new one.

When reconnection happens ongoing requests (processing in other fibers) will continue on the old connection, but any new request will use the new connection.

Errors

Error is returned if reconnection fails. See Error.

pub fn new(url: String, port: u16) -> Self

Creates a new client but does not yet try to establish connection to url:port. This will happen at the first call through super::AsClient methods.

Trait Implementations

impl AsClient for Client

fn send<'life0, 'life1, 'async_trait, R>( &'life0 self, request: &'life1 R ) -> Pin<Box<dyn Future<Output = Result<R::Response, Error>> + 'async_trait>>

where R: 'async_trait + Request, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Send Request and wait for response. This function yields.

fn ping<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Execute a PING command.

fn call<'life0, 'life1, 'life2, 'async_trait, T>( &'life0 self, fn_name: &'life1 str, args: &'life2 T ) -> Pin<Box<dyn Future<Output = Result<Tuple, Error>> + 'async_trait>>

where T: ToTupleBuffer + ?Sized + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Call a remote stored procedure.

fn eval<'life0, 'life1, 'life2, 'async_trait, T>( &'life0 self, expr: &'life1 str, args: &'life2 T ) -> Pin<Box<dyn Future<Output = Result<Tuple, Error>> + 'async_trait>>

where T: ToTupleBuffer + ?Sized + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Evaluates and executes the expression in Lua-string, which may be any statement or series of statements.

fn execute<'life0, 'life1, 'life2, 'async_trait, T>( &'life0 self, sql: &'life1 str, bind_params: &'life2 T, limit: Option<usize> ) -> Pin<Box<dyn Future<Output = Result<Vec<Tuple>, Error>> + 'async_trait>>

where T: ToTupleBuffer + ?Sized + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Execute sql query remotely.

impl Clone for Client

fn clone(&self) -> Client

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Client

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

Formats the value using the given formatter.