Struct RedisFactorData 

pub struct RedisFactorData(/* private fields */);

Trait Implementations

impl HasData for RedisFactorData

type Data<'a> = &'a mut InstanceState

The data associated with this trait implementation, chiefly used as a generic associated type to allow plumbing the 'a lifetime into the definition here.

impl<T: Send> HostConnectionWithStore<T> for RedisFactorData

async fn open( accessor: &Accessor<T, Self>, address: String, ) -> Result<Resource<Connection>, Error>

Open a connection to the Redis instance at address.

async fn publish( accessor: &Accessor<T, Self>, connection: Resource<Connection>, channel: String, payload: Payload, ) -> Result<(), Error>

Publish a Redis message to the specified channel.

async fn get( accessor: &Accessor<T, Self>, connection: Resource<Connection>, key: String, ) -> Result<Option<Payload>, Error>

Get the value of a key.

async fn set( accessor: &Accessor<T, Self>, connection: Resource<Connection>, key: String, value: Payload, ) -> Result<(), Error>

Set key to value.

async fn incr( accessor: &Accessor<T, Self>, connection: Resource<Connection>, key: String, ) -> Result<i64, Error>

Increments the number stored at key by one.

async fn del( accessor: &Accessor<T, Self>, connection: Resource<Connection>, keys: Vec<String>, ) -> Result<u32, Error>

Removes the specified keys.

async fn sadd( accessor: &Accessor<T, Self>, connection: Resource<Connection>, key: String, values: Vec<String>, ) -> Result<u32, Error>

Add the specified values to the set named key, returning the number of newly-added values.

async fn smembers( accessor: &Accessor<T, Self>, connection: Resource<Connection>, key: String, ) -> Result<Vec<String>, Error>

Retrieve the contents of the set named key.

async fn srem( accessor: &Accessor<T, Self>, connection: Resource<Connection>, key: String, values: Vec<String>, ) -> Result<u32, Error>

Remove the specified values from the set named key, returning the number of newly-removed values.

async fn execute( accessor: &Accessor<T, Self>, connection: Resource<Connection>, command: String, arguments: Vec<RedisParameter>, ) -> Result<Vec<RedisResult>, Error>

Execute an arbitrary Redis command and receive the result.