Struct MemcacheDatastore 

pub struct MemcacheDatastore { /* private fields */ }

Default Memcache-fronting datastore.

Mirrors RedisDatastore for the Memcache wire protocol.

Implementations

impl MemcacheDatastore

pub fn new(target: impl Into<String>) -> Self

Build a new Memcache-fronting datastore.

Examples

use dynomite::embed::hooks::MemcacheDatastore;
let m = MemcacheDatastore::new("127.0.0.1:11211");
assert_eq!(m.target(), "127.0.0.1:11211");

pub fn target(&self) -> &str

Return the configured target string.

Trait Implementations

impl Clone for MemcacheDatastore

fn clone(&self) -> MemcacheDatastore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Datastore for MemcacheDatastore

fn protocol(&self) -> Protocol

Return the wire protocol the datastore speaks.

fn dispatch(&self, req: Msg) -> BoxFuture<'_, Result<Msg, DatastoreError>>

Forward a routed request and return the response message.

fn supports(&self, _cmd: MsgType) -> bool

Predicate used by the dispatcher to short-circuit commands the backend cannot serve.

fn list_buckets_stream(&self) -> DatastoreByteStream

Stream the names of every bucket the datastore is aware of, one bytes::Bytes per bucket.

fn list_keys_stream(&self, _bucket: &[u8]) -> DatastoreByteStream

Stream every key in bucket, one bytes::Bytes per key.

fn riak_get<'a>( &'a self, _bucket: &'a [u8], _key: &'a [u8], ) -> BoxFuture<'a, Result<Option<Vec<u8>>, DatastoreError>>

Read the object stored under (bucket, key) against the Riak K/V layer.

fn riak_put<'a>( &'a self, _bucket: &'a [u8], _key: &'a [u8], _value: &'a [u8], _indexes: &'a [(Vec<u8>, Vec<u8>)], ) -> BoxFuture<'a, Result<(), DatastoreError>>

Store value under (bucket, key). indexes carries (index_name, encoded_value) pairs to associate with the object on the 2i layer.

fn riak_delete<'a>( &'a self, _bucket: &'a [u8], _key: &'a [u8], ) -> BoxFuture<'a, Result<bool, DatastoreError>>

Delete the object stored under (bucket, key). Returns true when an object was removed, false when none existed.

fn riak_index_eq<'a>( &'a self, _bucket: &'a [u8], _index_name: &'a [u8], _value: &'a [u8], ) -> BoxFuture<'a, Result<Vec<Vec<u8>>, DatastoreError>>

Equality query against the 2i layer.

fn riak_index_range<'a>( &'a self, _bucket: &'a [u8], _index_name: &'a [u8], _min: &'a [u8], _max: &'a [u8], ) -> BoxFuture<'a, Result<Vec<Vec<u8>>, DatastoreError>>

Range query against the 2i layer. min and max are inclusive bounds in the same encoding the index uses internally.

impl Debug for MemcacheDatastore

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

Formats the value using the given formatter.