Struct Connection 

pub struct Connection { /* private fields */ }

An open connection to a Redis server.

Examples

Get a value from the Redis database.

use spin_sdk::redis::Connection;

let conn = Connection::open("redis://127.0.0.1:6379")?;
let payload = conn.get("archimedes-data")?;
if let Some(data) = payload {
    println!("{}", String::from_utf8_lossy(&data));
}

Set a value in the Redis database.

use spin_sdk::redis::Connection;

let conn = Connection::open("redis://127.0.0.1:6379")?;
let payload = "Eureka!".to_owned().into_bytes();
conn.set("archimedes-data", &payload)?;

Delete a value from the Redis database.

use spin_sdk::redis::Connection;

let conn = Connection::open("redis://127.0.0.1:6379")?;
conn.del(&["archimedes-data".to_owned()])?;

Publish a message to a Redis channel.

use spin_sdk::redis::Connection;

let conn = Connection::open("redis://127.0.0.1:6379")?;

let payload = request.body().to_vec();
ensure_pet_picture(&payload)?;

conn.publish("pet-pictures", &payload)?;

Implementations

impl Connection

pub fn open(address: &str) -> Result<Connection, Error>

Open a connection to the Redis instance at address.

impl Connection

pub fn publish(&self, channel: &str, payload: &[u8]) -> Result<(), Error>

Publish a Redis message to the specified channel.

impl Connection

pub fn get(&self, key: &str) -> Result<Option<Payload>, Error>

Get the value of a key.

impl Connection

pub fn set(&self, key: &str, value: &[u8]) -> Result<(), Error>

Set key to value.

If key already holds a value, it is overwritten.

impl Connection

pub fn incr(&self, key: &str) -> Result<i64, Error>

Increments the number stored at key by one.

If the key does not exist, it is set to 0 before performing the operation. An error::type-error is returned if the key contains a value of the wrong type or contains a string that can not be represented as integer.

impl Connection

pub fn del(&self, keys: &[String]) -> Result<u32, Error>

Removes the specified keys.

A key is ignored if it does not exist. Returns the number of keys deleted.

impl Connection

pub fn sadd(&self, key: &str, values: &[String]) -> Result<u32, Error>

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

impl Connection

pub fn smembers(&self, key: &str) -> Result<Vec<String>, Error>

Retrieve the contents of the set named key.

impl Connection

pub fn srem(&self, key: &str, values: &[String]) -> Result<u32, Error>

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

impl Connection

pub fn execute( &self, command: &str, arguments: &[RedisParameter], ) -> Result<Vec<RedisResult>, Error>

Execute an arbitrary Redis command and receive the result.

Trait Implementations

impl Debug for Connection

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

Formats the value using the given formatter.