Struct async_memcached::Client
source · pub struct Client { /* private fields */ }Expand description
High-level memcached client.
Client is mapped one-to-one with a given connection to a memcached server, and provides a
high-level API for executing commands on that connection.
Implementations§
source§impl Client
impl Client
sourcepub async fn new<S: AsRef<str>>(dsn: S) -> Result<Client, Error>
pub async fn new<S: AsRef<str>>(dsn: S) -> Result<Client, Error>
Creates a new Client based on the given data source string.
Currently only supports TCP connections, and as such, the DSN should be in the format of
<host of IP>:<port>.
sourcepub async fn get<K: AsRef<[u8]>>(
&mut self,
key: K
) -> Result<Option<Value>, Error>
pub async fn get<K: AsRef<[u8]>>( &mut self, key: K ) -> Result<Option<Value>, Error>
Gets the given key.
If the key is found, Some(Value) is returned, describing the metadata and data of the key.
Otherwise, Error is returned.
sourcepub async fn get_many<I, K>(&mut self, keys: I) -> Result<Vec<Value>, Error>where
I: IntoIterator<Item = K>,
K: AsRef<[u8]>,
pub async fn get_many<I, K>(&mut self, keys: I) -> Result<Vec<Value>, Error>where I: IntoIterator<Item = K>, K: AsRef<[u8]>,
sourcepub async fn set<K, V>(
&mut self,
key: K,
value: V,
ttl: Option<i64>,
flags: Option<u32>
) -> Result<(), Error>where
K: AsRef<[u8]>,
V: AsRef<[u8]>,
pub async fn set<K, V>( &mut self, key: K, value: V, ttl: Option<i64>, flags: Option<u32> ) -> Result<(), Error>where K: AsRef<[u8]>, V: AsRef<[u8]>,
Sets the given key.
If ttl or flags are not specified, they will default to 0. If the value is set
successfully, () is returned, otherwise Error is returned.
sourcepub async fn add<K, V>(
&mut self,
key: K,
value: V,
ttl: Option<i64>,
flags: Option<u32>
) -> Result<(), Error>where
K: AsRef<[u8]>,
V: AsRef<[u8]>,
pub async fn add<K, V>( &mut self, key: K, value: V, ttl: Option<i64>, flags: Option<u32> ) -> Result<(), Error>where K: AsRef<[u8]>, V: AsRef<[u8]>,
Add a key. If the value exists, Err(Protocol(NotStored)) is returned.
sourcepub async fn delete_no_reply<K>(&mut self, key: K) -> Result<(), Error>where
K: AsRef<[u8]>,
pub async fn delete_no_reply<K>(&mut self, key: K) -> Result<(), Error>where K: AsRef<[u8]>,
Delete a key but don’t wait for a reply.
sourcepub async fn delete<K>(&mut self, key: K) -> Result<(), Error>where
K: AsRef<[u8]>,
pub async fn delete<K>(&mut self, key: K) -> Result<(), Error>where K: AsRef<[u8]>,
Delete a key and wait for a reply
sourcepub async fn version(&mut self) -> Result<String, Error>
pub async fn version(&mut self) -> Result<String, Error>
Gets the version of the server.
If the version is retrieved successfully, String is returned containing the version
component e.g. 1.6.7, otherwise Error is returned.
For some setups, such as those using Twemproxy, this will return an error as those intermediate proxies do not support the version command.
sourcepub async fn dump_keys(&mut self) -> Result<MetadumpIter<'_>, Error>
pub async fn dump_keys(&mut self) -> Result<MetadumpIter<'_>, Error>
Dumps all keys from the server.
This operation scans all slab classes from tail to head, in a non-blocking fashion. Thus, not all items will be found as new items could be inserted or deleted while the crawler is still running.
MetadumpIter must be iterated over to discover whether or not the crawler successfully
started, as this call will only return Error if the command failed to be written to the
server at all.
Available as of memcached 1.4.31.
sourcepub async fn stats(&mut self) -> Result<HashMap<String, String>, Error>
pub async fn stats(&mut self) -> Result<HashMap<String, String>, Error>
Collects statistics from the server.
The statistics that may be returned are detailed in the protocol specification for memcached, but all values returned by this method are returned as strings and are not further interpreted or validated for conformity.