Struct SyncGlideClusterClient 

pub struct SyncGlideClusterClient { /* private fields */ }

A blocking client for a cluster deployment.

Implementations

impl SyncGlideClusterClient

pub fn connect(config: GlideClusterClientConfiguration) -> ValkeyResult<Self>

Connect using the given cluster configuration (blocking).

pub fn async_client(&self) -> &GlideClusterClient

The underlying async client.

pub fn run<F, Fut, T>(&self, f: F) -> T

where F: FnOnce(GlideClusterClient) -> Fut, Fut: Future<Output = T>,

Run an arbitrary async operation against the client (blocking).

pub fn custom_command<A: ToValkeyArgs + Sync>( &self, args: &[A], ) -> ValkeyResult<ValkeyValue>

Run an arbitrary command (blocking escape hatch).

pub fn custom_command_with_route<A: ToValkeyArgs + Sync>( &self, args: &[A], route: Route, ) -> ValkeyResult<ValkeyValue>

Run an arbitrary command with an explicit route (blocking).

pub fn update_connection_password( &self, password: Option<String>, immediate_auth: bool, ) -> ValkeyResult<()>

Update the connection password (blocking). See GlideClusterClient::update_connection_password.

pub fn exec( &self, pipeline: &Pipeline, raise_on_error: bool, route: Option<Route>, options: &PipelineOptions, ) -> ValkeyResult<Vec<ValkeyValue>>

Execute a crate::pipeline::Pipeline with GLIDE execution options, optionally routed (blocking). See crate::GlideClusterClient::exec.

pub fn ping(&self) -> ValkeyResult<String>

Blocking PING.

Trait Implementations

impl Clone for SyncGlideClusterClient

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.