pub struct Client { /* private fields */ }Implementations§
Source§impl Client
impl Client
pub fn new(setts: ClientSettings) -> Self
pub async fn current_selected_node(&self) -> Result<Endpoint>
pub async fn server_version(&self) -> Result<ServerInfo>
pub fn settings(&self) -> &ClientSettings
pub async fn read_gossip(&self) -> Result<Vec<MemberInfo>>
pub async fn stats(&self, options: &StatsOptions) -> Result<Stats>
pub async fn start_scavenge( &self, thread_count: usize, start_from_chunk: usize, options: &OperationalOptions, ) -> Result<ScavengeResult>
pub async fn stop_scavenge( &self, scavenge_id: impl AsRef<str>, options: &OperationalOptions, ) -> Result<ScavengeResult>
pub async fn shutdown(&self, options: &OperationalOptions) -> Result<()>
pub async fn merge_indexes(&self, options: &OperationalOptions) -> Result<()>
pub async fn resign_node(&self, options: &OperationalOptions) -> Result<()>
pub async fn set_node_priority( &self, priority: usize, options: &OperationalOptions, ) -> Result<()>
pub async fn restart_persistent_subscriptions( &self, options: &OperationalOptions, ) -> Result<()>
pub async fn create_user( &self, login: impl AsRef<str>, password: impl AsRef<str>, full_name: impl AsRef<str>, groups: Vec<String>, options: &OperationalOptions, ) -> Result<()>
pub async fn update_user( &self, login: impl AsRef<str>, password: impl AsRef<str>, full_name: impl AsRef<str>, groups: Vec<String>, options: &OperationalOptions, ) -> Result<()>
pub async fn delete_user( &self, login: impl AsRef<str>, options: &OperationalOptions, ) -> Result<()>
pub async fn enable_user( &self, login: impl AsRef<str>, options: &OperationalOptions, ) -> Result<()>
pub async fn disable_user( &self, login: impl AsRef<str>, options: &OperationalOptions, ) -> Result<()>
pub async fn user_details( &self, login: impl AsRef<str>, options: &OperationalOptions, ) -> Result<UserDetailsStream>
pub async fn change_user_password( &self, login: impl AsRef<str>, current_password: impl AsRef<str>, new_password: impl AsRef<str>, options: &OperationalOptions, ) -> Result<()>
pub async fn reset_user_password( &self, login: impl AsRef<str>, new_password: impl AsRef<str>, options: &OperationalOptions, ) -> Result<()>
Trait Implementations§
Auto Trait Implementations§
impl !Freeze for Client
impl RefUnwindSafe for Client
impl Send for Client
impl Sync for Client
impl Unpin for Client
impl UnwindSafe for Client
Blanket Implementations§
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
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request