adding support for bit manipulation in to pipeline
This commit is contained in:
committed by
Jonathan Leibiusky
parent
430601f31e
commit
b7eb51f75c
@@ -1,9 +1,9 @@
|
|||||||
package redis.clients.jedis;
|
package redis.clients.jedis;
|
||||||
|
|
||||||
import java.util.Map;
|
|
||||||
|
|
||||||
import redis.clients.jedis.BinaryClient.LIST_POSITION;
|
import redis.clients.jedis.BinaryClient.LIST_POSITION;
|
||||||
|
|
||||||
|
import java.util.Map;
|
||||||
|
|
||||||
public interface Commands {
|
public interface Commands {
|
||||||
|
|
||||||
public void set(final String key, final String value);
|
public void set(final String key, final String value);
|
||||||
@@ -28,6 +28,14 @@ public interface Commands {
|
|||||||
|
|
||||||
public void ttl(final String key);
|
public void ttl(final String key);
|
||||||
|
|
||||||
|
public void setbit(String key, long offset, boolean value);
|
||||||
|
|
||||||
|
public void getbit(String key, long offset);
|
||||||
|
|
||||||
|
public void setrange(String key, long offset, String value);
|
||||||
|
|
||||||
|
public void getrange(String key, long startOffset, long endOffset);
|
||||||
|
|
||||||
public void move(final String key, final int dbIndex);
|
public void move(final String key, final int dbIndex);
|
||||||
|
|
||||||
public void getSet(final String key, final String value);
|
public void getSet(final String key, final String value);
|
||||||
|
|||||||
@@ -1,10 +1,10 @@
|
|||||||
package redis.clients.jedis;
|
package redis.clients.jedis;
|
||||||
|
|
||||||
|
import redis.clients.jedis.BinaryClient.LIST_POSITION;
|
||||||
|
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
|
||||||
import redis.clients.jedis.BinaryClient.LIST_POSITION;
|
|
||||||
|
|
||||||
public class Pipeline implements Commands {
|
public class Pipeline implements Commands {
|
||||||
private Client client;
|
private Client client;
|
||||||
|
|
||||||
@@ -100,6 +100,14 @@ public class Pipeline implements Commands {
|
|||||||
client.get(key);
|
client.get(key);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public void getbit(String key, long offset) {
|
||||||
|
client.getbit(key, offset);
|
||||||
|
}
|
||||||
|
|
||||||
|
public void getrange(String key, long startOffset, long endOffset) {
|
||||||
|
client.getrange(key, startOffset, endOffset);
|
||||||
|
}
|
||||||
|
|
||||||
public void getSet(String key, String value) {
|
public void getSet(String key, String value) {
|
||||||
client.getSet(key, value);
|
client.getSet(key, value);
|
||||||
}
|
}
|
||||||
@@ -438,6 +446,10 @@ public class Pipeline implements Commands {
|
|||||||
client.set(key, value);
|
client.set(key, value);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public void setbit(String key, long offset, boolean value) {
|
||||||
|
client.setbit(key, offset, value);
|
||||||
|
}
|
||||||
|
|
||||||
public void setex(String key, int seconds, String value) {
|
public void setex(String key, int seconds, String value) {
|
||||||
client.setex(key, seconds, value);
|
client.setex(key, seconds, value);
|
||||||
}
|
}
|
||||||
@@ -454,6 +466,10 @@ public class Pipeline implements Commands {
|
|||||||
client.setnx(key, value);
|
client.setnx(key, value);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public void setrange(String key, long offset, String value) {
|
||||||
|
client.setrange(key, offset, value);
|
||||||
|
}
|
||||||
|
|
||||||
public void sinter(String... keys) {
|
public void sinter(String... keys) {
|
||||||
client.sinter(keys);
|
client.sinter(keys);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,9 +1,9 @@
|
|||||||
package redis.clients.jedis;
|
package redis.clients.jedis;
|
||||||
|
|
||||||
import java.util.Map;
|
|
||||||
|
|
||||||
import redis.clients.jedis.BinaryClient.LIST_POSITION;
|
import redis.clients.jedis.BinaryClient.LIST_POSITION;
|
||||||
|
|
||||||
|
import java.util.Map;
|
||||||
|
|
||||||
public abstract class PipelineBlock implements Commands {
|
public abstract class PipelineBlock implements Commands {
|
||||||
private Client client;
|
private Client client;
|
||||||
|
|
||||||
@@ -55,6 +55,14 @@ public abstract class PipelineBlock implements Commands {
|
|||||||
client.get(key);
|
client.get(key);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public void getbit(String key, long offset) {
|
||||||
|
client.getbit(key, offset);
|
||||||
|
}
|
||||||
|
|
||||||
|
public void getrange(String key, long startOffset, long endOffset) {
|
||||||
|
client.getrange(key, startOffset, endOffset);
|
||||||
|
}
|
||||||
|
|
||||||
public void getSet(String key, String value) {
|
public void getSet(String key, String value) {
|
||||||
client.getSet(key, value);
|
client.getSet(key, value);
|
||||||
}
|
}
|
||||||
@@ -224,6 +232,10 @@ public abstract class PipelineBlock implements Commands {
|
|||||||
client.set(key, value);
|
client.set(key, value);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public void setbit(String key, long offset, boolean value) {
|
||||||
|
client.setbit(key, offset, value);
|
||||||
|
}
|
||||||
|
|
||||||
public void setex(String key, int seconds, String value) {
|
public void setex(String key, int seconds, String value) {
|
||||||
client.setex(key, seconds, value);
|
client.setex(key, seconds, value);
|
||||||
}
|
}
|
||||||
@@ -232,6 +244,10 @@ public abstract class PipelineBlock implements Commands {
|
|||||||
client.setnx(key, value);
|
client.setnx(key, value);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public void setrange(String key, long offset, String value) {
|
||||||
|
client.setrange(key, offset, value);
|
||||||
|
}
|
||||||
|
|
||||||
public void sinter(String... keys) {
|
public void sinter(String... keys) {
|
||||||
client.sinter(keys);
|
client.sinter(keys);
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user