Struct ClusterCmd

pub struct ClusterCmd { /* private fields */ }

Redis::Cmd’s args field is private, but we need it to determine a slot from the command. So this is a simple wrapper around Redis::Cmd that keeps track of the args.

Implementations

impl ClusterCmd

pub fn new() -> ClusterCmd

Examples found in repository

examples/basic.rs (line 11)

fn main() {
    let startup_nodes =
        vec!["redis://127.0.0.1:7000", "redis://127.0.0.1:7001", "redis://127.0.0.1:7002"];
    let mut clus = Cluster::new(startup_nodes);
    let mut cmd = ClusterCmd::new();
    cmd.arg("SET").arg("foo").arg("bar");
    let _: () = clus.send_command(&cmd).unwrap();

    let mut cmd = ClusterCmd::new();
    cmd.arg("GET").arg("foo");
    let res: String = clus.send_command(&cmd).unwrap();
    println!("{:?}", res);
    assert_eq!(res, "bar");

    let _: () = clus.set("hey", "there").unwrap();
    let res: String = clus.get("hey").unwrap();
    println!("{:?}", res);
    assert_eq!(res, "there");
}

pub fn arg<T: ToRedisArgs>(&mut self, arg: T) -> &mut ClusterCmd

Add an arg to the command.

Examples found in repository

examples/basic.rs (line 12)

fn main() {
    let startup_nodes =
        vec!["redis://127.0.0.1:7000", "redis://127.0.0.1:7001", "redis://127.0.0.1:7002"];
    let mut clus = Cluster::new(startup_nodes);
    let mut cmd = ClusterCmd::new();
    cmd.arg("SET").arg("foo").arg("bar");
    let _: () = clus.send_command(&cmd).unwrap();

    let mut cmd = ClusterCmd::new();
    cmd.arg("GET").arg("foo");
    let res: String = clus.send_command(&cmd).unwrap();
    println!("{:?}", res);
    assert_eq!(res, "bar");

    let _: () = clus.set("hey", "there").unwrap();
    let res: String = clus.get("hey").unwrap();
    println!("{:?}", res);
    assert_eq!(res, "there");
}

pub fn query<T: FromRedisValue>(&self, conn: &Connection) -> RedisResult<T>

Execute the command, returning the result.

pub fn slot(&self) -> Option<u16>

Get the slot for this command.