Pipeline

Undocumented in source.

class Pipeline : MultiKeyPipelineBase , Closeable {

void setClient(Client client);

Client getClient(string key);

Client getClient(const(ubyte)[] key);

void clear();

bool isInMulti();

void sync();

List!(Object) syncAndReturnAll();

Response!(string) discard();

Response!(List!(Object)) exec();

Response!(string) multi();

void close();

}

Members

Functions

clear void clear(): Undocumented in source. Be warned that the author may not have intended to support it.
close void close(): Undocumented in source. Be warned that the author may not have intended to support it.
discard Response!(string) discard(): Undocumented in source. Be warned that the author may not have intended to support it.
exec Response!(List!(Object)) exec(): Undocumented in source. Be warned that the author may not have intended to support it.
getClient Client getClient(string key): Undocumented in source. Be warned that the author may not have intended to support it.
getClient Client getClient(const(ubyte)[] key): Undocumented in source. Be warned that the author may not have intended to support it.
isInMulti bool isInMulti(): Undocumented in source. Be warned that the author may not have intended to support it.
multi Response!(string) multi(): Undocumented in source. Be warned that the author may not have intended to support it.
setClient void setClient(Client client): Undocumented in source. Be warned that the author may not have intended to support it.
sync void sync(): Synchronize pipeline by reading all responses. This operation close the pipeline. In order to get return values from pipelined commands, capture the different Response<?> of the commands you execute.
syncAndReturnAll List!(Object) syncAndReturnAll(): Synchronize pipeline by reading all responses. This operation close the pipeline. Whenever possible try to avoid using this version and use Pipeline.sync() as it won't go through all the responses and generate the right response type (usually it is a waste of time). @return A list of all the responses in the order you executed them.

Inherited Members

From MultiKeyPipelineBase

client Client client;: Undocumented in source.
brpop Response!(List!(string)) brpop(string[] args): Undocumented in source. Be warned that the author may not have intended to support it.
brpop alias brpop = PipelineBase.brpop: Undocumented in source.
brpop Response!(List!(string)) brpop(int timeout, string[] keys): Undocumented in source. Be warned that the author may not have intended to support it.
blpop Response!(List!(string)) blpop(string[] args): Undocumented in source. Be warned that the author may not have intended to support it.
blpop alias blpop = PipelineBase.blpop: Undocumented in source.
blpop Response!(List!(string)) blpop(int timeout, string[] keys): Undocumented in source. Be warned that the author may not have intended to support it.
blpopMap Response!(Map!(string, string)) blpopMap(int timeout, string[] keys): Undocumented in source. Be warned that the author may not have intended to support it.
brpop Response!(List!(const(ubyte)[])) brpop(const(ubyte)[][] args): Undocumented in source. Be warned that the author may not have intended to support it.
brpop Response!(List!(string)) brpop(int timeout, const(ubyte)[][] keys): Undocumented in source. Be warned that the author may not have intended to support it.
brpopMap Response!(Map!(string, string)) brpopMap(int timeout, string[] keys): Undocumented in source. Be warned that the author may not have intended to support it.
blpop Response!(List!(const(ubyte)[])) blpop(const(ubyte)[][] args): Undocumented in source. Be warned that the author may not have intended to support it.
blpop Response!(List!(string)) blpop(int timeout, const(ubyte)[][] keys): Undocumented in source. Be warned that the author may not have intended to support it.
del Response!(Long) del(string[] keys): Undocumented in source. Be warned that the author may not have intended to support it.
del alias del = PipelineBase.del: Undocumented in source.
del Response!(Long) del(const(ubyte)[][] keys): Undocumented in source. Be warned that the author may not have intended to support it.
unlink Response!(Long) unlink(string[] keys): Undocumented in source. Be warned that the author may not have intended to support it.
unlink alias unlink = PipelineBase.unlink: Undocumented in source.
unlink Response!(Long) unlink(const(ubyte)[][] keys): Undocumented in source. Be warned that the author may not have intended to support it.
exists Response!(Long) exists(string[] keys): Undocumented in source. Be warned that the author may not have intended to support it.
exists alias exists = PipelineBase.exists: Undocumented in source.
exists Response!(Long) exists(const(ubyte)[][] keys): Undocumented in source. Be warned that the author may not have intended to support it.
keys Response!(Set!(string)) keys(string pattern): Undocumented in source. Be warned that the author may not have intended to support it.
keys Response!(Set!(const(ubyte)[])) keys(const(ubyte)[] pattern): Undocumented in source. Be warned that the author may not have intended to support it.
mget Response!(List!(string)) mget(string[] keys): Undocumented in source. Be warned that the author may not have intended to support it.
mget Response!(List!(const(ubyte)[])) mget(const(ubyte)[][] keys): Undocumented in source. Be warned that the author may not have intended to support it.
mset Response!(string) mset(string[] keysvalues): Undocumented in source. Be warned that the author may not have intended to support it.
mset Response!(string) mset(const(ubyte)[][] keysvalues): Undocumented in source. Be warned that the author may not have intended to support it.
msetnx Response!(Long) msetnx(string[] keysvalues): Undocumented in source. Be warned that the author may not have intended to support it.
msetnx Response!(Long) msetnx(const(ubyte)[][] keysvalues): Undocumented in source. Be warned that the author may not have intended to support it.
rename Response!(string) rename(string oldkey, string newkey): Undocumented in source. Be warned that the author may not have intended to support it.
rename Response!(string) rename(const(ubyte)[] oldkey, const(ubyte)[] newkey): Undocumented in source. Be warned that the author may not have intended to support it.
renamenx Response!(Long) renamenx(string oldkey, string newkey): Undocumented in source. Be warned that the author may not have intended to support it.
renamenx Response!(Long) renamenx(const(ubyte)[] oldkey, const(ubyte)[] newkey): Undocumented in source. Be warned that the author may not have intended to support it.
rpoplpush Response!(string) rpoplpush(string srckey, string dstkey): Undocumented in source. Be warned that the author may not have intended to support it.
rpoplpush Response!(const(ubyte)[]) rpoplpush(const(ubyte)[] srckey, const(ubyte)[] dstkey): Undocumented in source. Be warned that the author may not have intended to support it.
sdiff Response!(Set!(string)) sdiff(string[] keys): Undocumented in source. Be warned that the author may not have intended to support it.
sdiff Response!(Set!(const(ubyte)[])) sdiff(const(ubyte)[][] keys): Undocumented in source. Be warned that the author may not have intended to support it.
sdiffstore Response!(Long) sdiffstore(string dstkey, string[] keys): Undocumented in source. Be warned that the author may not have intended to support it.
sdiffstore Response!(Long) sdiffstore(const(ubyte)[] dstkey, const(ubyte)[][] keys): Undocumented in source. Be warned that the author may not have intended to support it.
sinter Response!(Set!(string)) sinter(string[] keys): Undocumented in source. Be warned that the author may not have intended to support it.
sinter Response!(Set!(const(ubyte)[])) sinter(const(ubyte)[][] keys): Undocumented in source. Be warned that the author may not have intended to support it.
sinterstore Response!(Long) sinterstore(string dstkey, string[] keys): Undocumented in source. Be warned that the author may not have intended to support it.
sinterstore Response!(Long) sinterstore(const(ubyte)[] dstkey, const(ubyte)[][] keys): Undocumented in source. Be warned that the author may not have intended to support it.
smove Response!(Long) smove(string srckey, string dstkey, string member): Undocumented in source. Be warned that the author may not have intended to support it.
smove Response!(Long) smove(const(ubyte)[] srckey, const(ubyte)[] dstkey, const(ubyte)[] member): Undocumented in source. Be warned that the author may not have intended to support it.
sort Response!(Long) sort(string key, SortingParams sortingParameters, string dstkey): Undocumented in source. Be warned that the author may not have intended to support it.
sort Response!(Long) sort(const(ubyte)[] key, SortingParams sortingParameters, const(ubyte)[] dstkey): Undocumented in source. Be warned that the author may not have intended to support it.
sort Response!(Long) sort(string key, string dstkey): Undocumented in source. Be warned that the author may not have intended to support it.
sort Response!(Long) sort(const(ubyte)[] key, const(ubyte)[] dstkey): Undocumented in source. Be warned that the author may not have intended to support it.
sunion Response!(Set!(string)) sunion(string[] keys): Undocumented in source. Be warned that the author may not have intended to support it.
sunion Response!(Set!(const(ubyte)[])) sunion(const(ubyte)[][] keys): Undocumented in source. Be warned that the author may not have intended to support it.
sunionstore Response!(Long) sunionstore(string dstkey, string[] keys): Undocumented in source. Be warned that the author may not have intended to support it.
sunionstore Response!(Long) sunionstore(const(ubyte)[] dstkey, const(ubyte)[][] keys): Undocumented in source. Be warned that the author may not have intended to support it.
watch Response!(string) watch(string[] keys): Undocumented in source. Be warned that the author may not have intended to support it.
watch Response!(string) watch(const(ubyte)[][] keys): Undocumented in source. Be warned that the author may not have intended to support it.
zinterstore Response!(Long) zinterstore(string dstkey, string[] sets): Undocumented in source. Be warned that the author may not have intended to support it.
zinterstore Response!(Long) zinterstore(const(ubyte)[] dstkey, const(ubyte)[][] sets): Undocumented in source. Be warned that the author may not have intended to support it.
zinterstore Response!(Long) zinterstore(string dstkey, ZParams params, string[] sets): Undocumented in source. Be warned that the author may not have intended to support it.
zinterstore Response!(Long) zinterstore(const(ubyte)[] dstkey, ZParams params, const(ubyte)[][] sets): Undocumented in source. Be warned that the author may not have intended to support it.
zunionstore Response!(Long) zunionstore(string dstkey, string[] sets): Undocumented in source. Be warned that the author may not have intended to support it.
zunionstore Response!(Long) zunionstore(const(ubyte)[] dstkey, const(ubyte)[][] sets): Undocumented in source. Be warned that the author may not have intended to support it.
zunionstore Response!(Long) zunionstore(string dstkey, ZParams params, string[] sets): Undocumented in source. Be warned that the author may not have intended to support it.
zunionstore Response!(Long) zunionstore(const(ubyte)[] dstkey, ZParams params, const(ubyte)[][] sets): Undocumented in source. Be warned that the author may not have intended to support it.
bgrewriteaof Response!(string) bgrewriteaof(): Undocumented in source. Be warned that the author may not have intended to support it.
bgsave Response!(string) bgsave(): Undocumented in source. Be warned that the author may not have intended to support it.
configGet Response!(List!(string)) configGet(string pattern): Undocumented in source. Be warned that the author may not have intended to support it.
configSet Response!(string) configSet(string parameter, string value): Undocumented in source. Be warned that the author may not have intended to support it.
brpoplpush Response!(string) brpoplpush(string source, string destination, int timeout): Undocumented in source. Be warned that the author may not have intended to support it.
brpoplpush Response!(const(ubyte)[]) brpoplpush(const(ubyte)[] source, const(ubyte)[] destination, int timeout): Undocumented in source. Be warned that the author may not have intended to support it.
configResetStat Response!(string) configResetStat(): Undocumented in source. Be warned that the author may not have intended to support it.
save Response!(string) save(): Undocumented in source. Be warned that the author may not have intended to support it.
lastsave Response!(Long) lastsave(): Undocumented in source. Be warned that the author may not have intended to support it.
publish Response!(Long) publish(string channel, string message): Undocumented in source. Be warned that the author may not have intended to support it.
publish Response!(Long) publish(const(ubyte)[] channel, const(ubyte)[] message): Undocumented in source. Be warned that the author may not have intended to support it.
randomKey Response!(string) randomKey(): Undocumented in source. Be warned that the author may not have intended to support it.
randomKeyBinary Response!(const(ubyte)[]) randomKeyBinary(): Undocumented in source. Be warned that the author may not have intended to support it.
flushDB Response!(string) flushDB(): Undocumented in source. Be warned that the author may not have intended to support it.
flushAll Response!(string) flushAll(): Undocumented in source. Be warned that the author may not have intended to support it.
info Response!(string) info(): Undocumented in source. Be warned that the author may not have intended to support it.
info Response!(string) info(string section): Undocumented in source. Be warned that the author may not have intended to support it.
dbSize Response!(Long) dbSize(): Undocumented in source. Be warned that the author may not have intended to support it.
shutdown Response!(string) shutdown(): Undocumented in source. Be warned that the author may not have intended to support it.
ping Response!(string) ping(): Undocumented in source. Be warned that the author may not have intended to support it.
select Response!(string) select(int index): Undocumented in source. Be warned that the author may not have intended to support it.
swapDB Response!(string) swapDB(int index1, int index2): Undocumented in source. Be warned that the author may not have intended to support it.
bitop Response!(Long) bitop(BitOP op, const(ubyte)[] destKey, const(ubyte)[][] srcKeys): Undocumented in source. Be warned that the author may not have intended to support it.
bitop Response!(Long) bitop(BitOP op, string destKey, string[] srcKeys): Undocumented in source. Be warned that the author may not have intended to support it.
clusterNodes Response!(string) clusterNodes(): Undocumented in source. Be warned that the author may not have intended to support it.
clusterMeet Response!(string) clusterMeet(string ip, int port): Undocumented in source. Be warned that the author may not have intended to support it.
clusterAddSlots Response!(string) clusterAddSlots(int[] slots): Undocumented in source. Be warned that the author may not have intended to support it.
clusterDelSlots Response!(string) clusterDelSlots(int[] slots): Undocumented in source. Be warned that the author may not have intended to support it.
clusterInfo Response!(string) clusterInfo(): Undocumented in source. Be warned that the author may not have intended to support it.
clusterGetKeysInSlot Response!(List!(string)) clusterGetKeysInSlot(int slot, int count): Undocumented in source. Be warned that the author may not have intended to support it.
clusterSetSlotNode Response!(string) clusterSetSlotNode(int slot, string nodeId): Undocumented in source. Be warned that the author may not have intended to support it.
clusterSetSlotMigrating Response!(string) clusterSetSlotMigrating(int slot, string nodeId): Undocumented in source. Be warned that the author may not have intended to support it.
clusterSetSlotImporting Response!(string) clusterSetSlotImporting(int slot, string nodeId): Undocumented in source. Be warned that the author may not have intended to support it.
eval Response!(Object) eval(string script): Undocumented in source. Be warned that the author may not have intended to support it.
eval Response!(Object) eval(string script, List!(string) keys, List!(string) args): Undocumented in source. Be warned that the author may not have intended to support it.
eval Response!(Object) eval(string script, int keyCount, string[] params): Undocumented in source. Be warned that the author may not have intended to support it.
evalsha Response!(Object) evalsha(string sha1): Undocumented in source. Be warned that the author may not have intended to support it.
evalsha Response!(Object) evalsha(string sha1, List!(string) keys, List!(string) args): Undocumented in source. Be warned that the author may not have intended to support it.
evalsha Response!(Object) evalsha(string sha1, int keyCount, string[] params): Undocumented in source. Be warned that the author may not have intended to support it.
eval Response!(Object) eval(const(ubyte)[] script): Undocumented in source. Be warned that the author may not have intended to support it.
eval Response!(Object) eval(const(ubyte)[] script, const(ubyte)[] keyCount, const(ubyte)[][] params): Undocumented in source. Be warned that the author may not have intended to support it.
eval Response!(Object) eval(const(ubyte)[] script, List!(const(ubyte)[]) keys, List!(const(ubyte)[]) args): Undocumented in source. Be warned that the author may not have intended to support it.
eval Response!(Object) eval(const(ubyte)[] script, int keyCount, const(ubyte)[][] params): Undocumented in source. Be warned that the author may not have intended to support it.
evalsha Response!(Object) evalsha(const(ubyte)[] sha1): Undocumented in source. Be warned that the author may not have intended to support it.
evalsha Response!(Object) evalsha(const(ubyte)[] sha1, List!(const(ubyte)[]) keys, List!(const(ubyte)[]) args): Undocumented in source. Be warned that the author may not have intended to support it.
evalsha Response!(Object) evalsha(const(ubyte)[] sha1, int keyCount, const(ubyte)[][] params): Undocumented in source. Be warned that the author may not have intended to support it.
pfcount Response!(Long) pfcount(string[] keys): Undocumented in source. Be warned that the author may not have intended to support it.
pfcount alias pfcount = PipelineBase.pfcount: Undocumented in source.
pfcount Response!(Long) pfcount(const(ubyte)[][] keys): Undocumented in source. Be warned that the author may not have intended to support it.
pfmerge Response!(string) pfmerge(const(ubyte)[] destkey, const(ubyte)[][] sourcekeys): Undocumented in source. Be warned that the author may not have intended to support it.
pfmerge Response!(string) pfmerge(string destkey, string[] sourcekeys): Undocumented in source. Be warned that the author may not have intended to support it.
time Response!(List!(string)) time(): Undocumented in source. Be warned that the author may not have intended to support it.
touch Response!(Long) touch(string[] keys): Undocumented in source. Be warned that the author may not have intended to support it.
touch alias touch = PipelineBase.touch: Undocumented in source.
touch Response!(Long) touch(const(ubyte)[][] keys): Undocumented in source. Be warned that the author may not have intended to support it.
moduleUnload Response!(string) moduleUnload(string name): Undocumented in source. Be warned that the author may not have intended to support it.
moduleList Response!(List!(Module)) moduleList(): Undocumented in source. Be warned that the author may not have intended to support it.
moduleLoad Response!(string) moduleLoad(string path): Undocumented in source. Be warned that the author may not have intended to support it.
migrate Response!(string) migrate(string host, int port, int destinationDB, int timeout, MigrateParams params, string[] keys): Undocumented in source. Be warned that the author may not have intended to support it.
migrate alias migrate = PipelineBase.migrate: Undocumented in source.
migrate Response!(string) migrate(string host, int port, int destinationDB, int timeout, MigrateParams params, const(ubyte)[][] keys): Undocumented in source. Be warned that the author may not have intended to support it.
migrate Response!string migrate(string host, int port, string key, int destinationDB, int timeout): Undocumented in source. Be warned that the author may not have intended to support it.
sendCommand Response!(Object) sendCommand(ProtocolCommand cmd, string[] args): Undocumented in source. Be warned that the author may not have intended to support it.

Pipeline

Members

Functions

Inherited Members

From MultiKeyPipelineBase

Meta

Source