Struct RedisDatastore 

pub struct RedisDatastore { /* private fields */ }

Default Redis-fronting datastore.

Stage 13 ships this as a thin marker around the supplied connection target; the actual wire protocol bridge lives in the dispatcher path of crate::cluster::dispatch. The default impl satisfies the Datastore contract for the embed surface so an embedder can construct a builder without wiring a custom backend.

Implementations

impl RedisDatastore

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

Build a new Redis-fronting datastore.

target is informational and is reported back through RedisDatastore::target.

Examples

use dynomite::embed::hooks::RedisDatastore;
let r = RedisDatastore::new("127.0.0.1:6379");
assert_eq!(r.target(), "127.0.0.1:6379");

pub fn target(&self) -> &str

Return the configured target string.

Trait Implementations

impl Clone for RedisDatastore

fn clone(&self) -> RedisDatastore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Datastore for RedisDatastore

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 RedisDatastore

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

Formats the value using the given formatter.