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 HostConnectionWithStore for RedisFactorData

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

Open a connection to the Redis instance at address.

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

Publish a Redis message to the specified channel.

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

Get the value of a key.

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

Set key to value.

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

Increments the number stored at key by one.

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

Removes the specified keys.

async fn sadd<T: Send>( 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<T: Send>( accessor: &Accessor<T, Self>, connection: Resource<Connection>, key: String, ) -> Result<Vec<String>, Error>

Retrieve the contents of the set named key.

async fn srem<T: Send>( 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<T: Send>( 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.