pub struct Cluster { /* private fields */ }
Implementations§
Source§impl Cluster
impl Cluster
Sourcepub fn new() -> Cluster
pub fn new() -> Cluster
Examples found in repository?
examples/cluster.rs (line 7)
6fn test_cluster() -> redis::RedisResult<()> {
7 let mut cluster = redis::Cluster::new();
8 for i in 7000 .. 7001 {
9 try!(cluster.add(&format!("redis://192.168.1.135:{}/", i)[..]));
10 }
11 let mut cmd = redis::cmd("set");
12 cmd.arg("foo11232").arg(02);
13 try!(cluster.query_cmd(&cmd));
14 let mut cmd = redis::cmd("get");
15 cmd.arg("foo11232");
16 let value : i32 = try!(cluster.query_cmd(&cmd));
17 println!("value = {:?}", value);
18 try!(redis::cmd("set").arg("xxoo1").arg("ooxx").query_cluster(&mut cluster));
19 assert_eq!(redis::cmd("get").arg("xxoo1").query_cluster(&mut cluster), Ok("ooxx".to_string()));
20
21 println!("ok {:?}", 11);
22
23 try!(redis::cmd("SET").arg("key1").arg(b"foo").query_cluster(&mut cluster));
24 println!("1111111111");
25 try!(redis::cmd("SET").arg(&["key5", "bar"]).query_cluster(&mut cluster));
26 println!("222222222");
27 let xx : redis::RedisResult<(String, String)> = redis::cmd("MGET").arg(&["key1", "key1"]).query_cluster(&mut cluster);
28 println!("33333333333 = {:?}", xx);
29
30 let (xx, xx1) : (String, String) = try!(redis::cmd("MGET").arg(&["key1", "key5"]).query_cluster(&mut cluster));
31 println!("xx = {:?}", xx);
32 Ok(())
33}
Sourcepub fn add(&mut self, info: &str) -> RedisResult<()>
pub fn add(&mut self, info: &str) -> RedisResult<()>
Examples found in repository?
examples/cluster.rs (line 9)
6fn test_cluster() -> redis::RedisResult<()> {
7 let mut cluster = redis::Cluster::new();
8 for i in 7000 .. 7001 {
9 try!(cluster.add(&format!("redis://192.168.1.135:{}/", i)[..]));
10 }
11 let mut cmd = redis::cmd("set");
12 cmd.arg("foo11232").arg(02);
13 try!(cluster.query_cmd(&cmd));
14 let mut cmd = redis::cmd("get");
15 cmd.arg("foo11232");
16 let value : i32 = try!(cluster.query_cmd(&cmd));
17 println!("value = {:?}", value);
18 try!(redis::cmd("set").arg("xxoo1").arg("ooxx").query_cluster(&mut cluster));
19 assert_eq!(redis::cmd("get").arg("xxoo1").query_cluster(&mut cluster), Ok("ooxx".to_string()));
20
21 println!("ok {:?}", 11);
22
23 try!(redis::cmd("SET").arg("key1").arg(b"foo").query_cluster(&mut cluster));
24 println!("1111111111");
25 try!(redis::cmd("SET").arg(&["key5", "bar"]).query_cluster(&mut cluster));
26 println!("222222222");
27 let xx : redis::RedisResult<(String, String)> = redis::cmd("MGET").arg(&["key1", "key1"]).query_cluster(&mut cluster);
28 println!("33333333333 = {:?}", xx);
29
30 let (xx, xx1) : (String, String) = try!(redis::cmd("MGET").arg(&["key1", "key5"]).query_cluster(&mut cluster));
31 println!("xx = {:?}", xx);
32 Ok(())
33}
Sourcepub fn get_pubsub(&self) -> RedisResult<PubSub>
pub fn get_pubsub(&self) -> RedisResult<PubSub>
Returns a PubSub connection. A pubsub connection can be used to listen to messages coming in through the redis publish/subscribe system.
Note that redis’ pubsub operates across all databases.
pub fn get_connection( &mut self, addr: Option<String>, ) -> RedisResult<&Connection>
pub fn get_connection_by_name( &mut self, slot: String, ) -> RedisResult<&Connection>
pub fn get_connection_by_slot(&mut self, slot: u16) -> RedisResult<&Connection>
Sourcepub fn query_cmd<T: FromRedisValue>(&mut self, cmd: &Cmd) -> RedisResult<T>
pub fn query_cmd<T: FromRedisValue>(&mut self, cmd: &Cmd) -> RedisResult<T>
Examples found in repository?
examples/cluster.rs (line 13)
6fn test_cluster() -> redis::RedisResult<()> {
7 let mut cluster = redis::Cluster::new();
8 for i in 7000 .. 7001 {
9 try!(cluster.add(&format!("redis://192.168.1.135:{}/", i)[..]));
10 }
11 let mut cmd = redis::cmd("set");
12 cmd.arg("foo11232").arg(02);
13 try!(cluster.query_cmd(&cmd));
14 let mut cmd = redis::cmd("get");
15 cmd.arg("foo11232");
16 let value : i32 = try!(cluster.query_cmd(&cmd));
17 println!("value = {:?}", value);
18 try!(redis::cmd("set").arg("xxoo1").arg("ooxx").query_cluster(&mut cluster));
19 assert_eq!(redis::cmd("get").arg("xxoo1").query_cluster(&mut cluster), Ok("ooxx".to_string()));
20
21 println!("ok {:?}", 11);
22
23 try!(redis::cmd("SET").arg("key1").arg(b"foo").query_cluster(&mut cluster));
24 println!("1111111111");
25 try!(redis::cmd("SET").arg(&["key5", "bar"]).query_cluster(&mut cluster));
26 println!("222222222");
27 let xx : redis::RedisResult<(String, String)> = redis::cmd("MGET").arg(&["key1", "key1"]).query_cluster(&mut cluster);
28 println!("33333333333 = {:?}", xx);
29
30 let (xx, xx1) : (String, String) = try!(redis::cmd("MGET").arg(&["key1", "key5"]).query_cluster(&mut cluster));
31 println!("xx = {:?}", xx);
32 Ok(())
33}
pub fn query_pipe<T: FromRedisValue>( &mut self, pipe: &Pipeline, ) -> RedisResult<T>
Auto Trait Implementations§
impl Freeze for Cluster
impl !RefUnwindSafe for Cluster
impl Send for Cluster
impl !Sync for Cluster
impl Unpin for Cluster
impl UnwindSafe for Cluster
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more