RedisNativeClient
This class contains all the common operations for the RedisClient.
The client contains a 1:1 mapping of c# methods to redis operations of the same name.
Not threadsafe, use a pooled manager!
All redis calls on a single instances write to the same Socket.
If used in multiple threads (or async Tasks) at the same time you will find
that commands are not executed properly by redis and Servicestack wont be able to (json) serialize
the data that comes back.
Assembly: ServiceStack.Redis.dll
Declaration
public class RedisNativeClient : IRedisNativeClientAsync, IRedisNativeClient, IDisposable
Properties
DeactivatedAt
Declaration
public DateTime? DeactivatedAt { get; set; }
HadExceptions
Declaration
public bool HadExceptions { get; }
LastConnectedSecs
Declaration
public long LastConnectedSecs { get; }
Declaration
public long Id { get; set; }
Host
Declaration
public string Host { get; }
Port
Ssl
SslProtocols
Declaration
public SslProtocols? SslProtocols { get; }
NamespacePrefix
Gets or sets object key prefix.
Declaration
public string NamespacePrefix { get; set; }
ConnectTimeout
Declaration
public int ConnectTimeout { get; set; }
RetryTimeout
Declaration
public int RetryTimeout { get; set; }
RetryCount
Declaration
public int RetryCount { get; set; }
SendTimeout
Declaration
public int SendTimeout { get; set; }
ReceiveTimeout
Declaration
public int ReceiveTimeout { get; set; }
Username
ACL Username
Declaration
public string Username { get; set; }
Password
Declaration
public string Password { get; set; }
Client
Declaration
public string Client { get; set; }
IdleTimeOutSecs
Declaration
public int IdleTimeOutSecs { get; set; }
ConnectionFilter
Declaration
public Action<IRedisNativeClient> ConnectionFilter { get; set; }
Declaration
public long Db { get; set; }
DbSize
Declaration
public long DbSize { get; }
LastSave
Declaration
public DateTime LastSave { get; }
Info
Declaration
public Dictionary<string, string> Info { get; }
ServerVersion
Declaration
public string ServerVersion { get; }
IsManagedClient
Declaration
public bool IsManagedClient { get; }
RequestsPerHour
Declaration
public static int RequestsPerHour { get; }
ServerVersionNumber
Declaration
public static int ServerVersionNumber { get; set; }
ClientId
Declaration
public long ClientId { get; }
HasConnected
Declaration
public bool HasConnected { get; }
OnBeforeFlush
Declaration
public Action OnBeforeFlush { get; set; }
Fields
socket
Bstream
Declaration
[Obsolete("The direct stream is no longer directly available", true)]
protected BufferedStream Bstream
sslStream
Declaration
protected SslStream sslStream
ErrorConnect
Declaration
public static string ErrorConnect
Methods
RawCommandAsync(CancellationToken, Object[])
Declaration
protected ValueTask<RedisData> RawCommandAsync(CancellationToken token, params object[] cmdWithArgs)
Returns
ValueTask<ServiceStack.Redis.RedisData>
Parameters
Type | Name |
---|
System.Threading.CancellationToken | token |
System.Object[] | cmdWithArgs |
ChangeDb(Int64)
Declaration
public void ChangeDb(long db)
Parameters
RawCommand(Object[])
Declaration
public RedisData RawCommand(params object[] cmdWithArgs)
Returns
ServiceStack.Redis.RedisData
Parameters
Type | Name |
---|
System.Object[] | cmdWithArgs |
RawCommand(Byte[][])
Declaration
public RedisData RawCommand(params byte[][] cmdWithBinaryArgs)
Returns
ServiceStack.Redis.RedisData
Parameters
Type | Name |
---|
System.Byte[][] | cmdWithBinaryArgs |
Ping()
Returns
System.Boolean
Echo(String)
Declaration
public string Echo(string text)
Returns
System.String
Parameters
Type | Name |
---|
System.String | text |
SlaveOf(String, Int32)
Declaration
public void SlaveOf(string hostname, int port)
Parameters
Type | Name |
---|
System.String | hostname |
System.Int32 | port |
SlaveOfNoOne()
Declaration
public void SlaveOfNoOne()
ConfigGet(String)
Declaration
public byte[][] ConfigGet(string pattern)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String | pattern |
ConfigSet(String, Byte[])
Declaration
public void ConfigSet(string item, byte[] value)
Parameters
Type | Name |
---|
System.String | item |
System.Byte[] | value |
ConfigResetStat()
Declaration
public void ConfigResetStat()
ConfigRewrite()
Declaration
public void ConfigRewrite()
Time()
Returns
System.Byte[][]
DebugSegfault()
Declaration
public void DebugSegfault()
DebugSleep(Double)
Declaration
public void DebugSleep(double durationSecs)
Parameters
Type | Name |
---|
System.Double | durationSecs |
Dump(String)
Declaration
public byte[] Dump(string key)
Returns
System.Byte[]
Parameters
Restore(String, Int64, Byte[])
Declaration
public byte[] Restore(string key, long expireMs, byte[] dumpValue)
Returns
System.Byte[]
Parameters
Type | Name |
---|
System.String | key |
System.Int64 | expireMs |
System.Byte[] | dumpValue |
Migrate(String, Int32, String, Int32, Int64)
Declaration
public void Migrate(string host, int port, string key, int destinationDb, long timeoutMs)
Parameters
Type | Name |
---|
System.String | host |
System.Int32 | port |
System.String | key |
System.Int32 | destinationDb |
System.Int64 | timeoutMs |
Move(String, Int32)
Declaration
public bool Move(string key, int db)
Returns
System.Boolean
Parameters
Type | Name |
---|
System.String | key |
System.Int32 | db |
ObjectIdleTime(String)
Declaration
public long ObjectIdleTime(string key)
Returns
System.Int64
Parameters
Type(String)
Declaration
public string Type(string key)
Returns
System.String
Parameters
GetEntryType(String)
Declaration
public RedisKeyType GetEntryType(string key)
Returns
ServiceStack.Redis.RedisKeyType
Parameters
StrLen(String)
Declaration
public long StrLen(string key)
Returns
System.Int64
Parameters
Set(String, Byte[])
Declaration
public void Set(string key, byte[] value)
Parameters
Type | Name |
---|
System.String | key |
System.Byte[] | value |
Set(String, Byte[], Int32, Int64)
Declaration
public void Set(string key, byte[] value, int expirySeconds, long expiryMs = 0L)
Parameters
Type | Name |
---|
System.String | key |
System.Byte[] | value |
System.Int32 | expirySeconds |
System.Int64 | expiryMs |
Set(Byte[], Byte[], Int32, Int64)
Declaration
public void Set(byte[] key, byte[] value, int expirySeconds, long expiryMs = 0L)
Parameters
Type | Name |
---|
System.Byte[] | key |
System.Byte[] | value |
System.Int32 | expirySeconds |
System.Int64 | expiryMs |
Set(String, Byte[], Boolean, Int32, Int64)
Declaration
public bool Set(string key, byte[] value, bool exists, int expirySeconds = 0, long expiryMs = 0L)
Returns
System.Boolean
Parameters
Type | Name |
---|
System.String | key |
System.Byte[] | value |
System.Boolean | exists |
System.Int32 | expirySeconds |
System.Int64 | expiryMs |
SetEx(String, Int32, Byte[])
Declaration
public void SetEx(string key, int expireInSeconds, byte[] value)
Parameters
Type | Name |
---|
System.String | key |
System.Int32 | expireInSeconds |
System.Byte[] | value |
SetEx(Byte[], Int32, Byte[])
Declaration
public void SetEx(byte[] key, int expireInSeconds, byte[] value)
Parameters
Type | Name |
---|
System.Byte[] | key |
System.Int32 | expireInSeconds |
System.Byte[] | value |
Persist(String)
Declaration
public bool Persist(string key)
Returns
System.Boolean
Parameters
PSetEx(String, Int64, Byte[])
Declaration
public void PSetEx(string key, long expireInMs, byte[] value)
Parameters
Type | Name |
---|
System.String | key |
System.Int64 | expireInMs |
System.Byte[] | value |
SetNX(String, Byte[])
Declaration
public long SetNX(string key, byte[] value)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | key |
System.Byte[] | value |
MSet(Byte[][], Byte[][])
Declaration
public void MSet(byte[][] keys, byte[][] values)
Parameters
Type | Name |
---|
System.Byte[][] | keys |
System.Byte[][] | values |
MSet(String[], Byte[][])
Declaration
public void MSet(string[] keys, byte[][] values)
Parameters
Type | Name |
---|
System.String[] | keys |
System.Byte[][] | values |
MSetNx(Byte[][], Byte[][])
Declaration
public bool MSetNx(byte[][] keys, byte[][] values)
Returns
System.Boolean
Parameters
Type | Name |
---|
System.Byte[][] | keys |
System.Byte[][] | values |
MSetNx(String[], Byte[][])
Declaration
public bool MSetNx(string[] keys, byte[][] values)
Returns
System.Boolean
Parameters
Type | Name |
---|
System.String[] | keys |
System.Byte[][] | values |
Get(String)
Declaration
public byte[] Get(string key)
Returns
System.Byte[]
Parameters
Get(Byte[])
Declaration
public byte[] Get(byte[] key)
Returns
System.Byte[]
Parameters
Slowlog(Nullable<Int32>)
Declaration
public object[] Slowlog(int? top)
Returns
System.Object[]
Parameters
Type | Name |
---|
System.Nullable<System.Int32> | top |
SlowlogReset()
Declaration
public void SlowlogReset()
GetBytes(String)
Declaration
public byte[] GetBytes(string key)
Returns
System.Byte[]
Parameters
GetSet(String, Byte[])
Declaration
public byte[] GetSet(string key, byte[] value)
Returns
System.Byte[]
Parameters
Type | Name |
---|
System.String | key |
System.Byte[] | value |
Exists(String)
Declaration
public long Exists(string key)
Returns
System.Int64
Parameters
Del(String)
Declaration
public long Del(string key)
Returns
System.Int64
Parameters
Del(Byte[])
Declaration
public long Del(byte[] key)
Returns
System.Int64
Parameters
Del(String[])
Declaration
public long Del(params string[] keys)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String[] | keys |
Incr(String)
Declaration
public long Incr(string key)
Returns
System.Int64
Parameters
IncrBy(String, Int32)
Declaration
public long IncrBy(string key, int count)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | key |
System.Int32 | count |
IncrBy(String, Int64)
Declaration
public long IncrBy(string key, long count)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | key |
System.Int64 | count |
IncrByFloat(String, Double)
Declaration
public double IncrByFloat(string key, double incrBy)
Returns
System.Double
Parameters
Type | Name |
---|
System.String | key |
System.Double | incrBy |
Decr(String)
Declaration
public long Decr(string key)
Returns
System.Int64
Parameters
DecrBy(String, Int32)
Declaration
public long DecrBy(string key, int count)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | key |
System.Int32 | count |
Append(String, Byte[])
Declaration
public long Append(string key, byte[] value)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | key |
System.Byte[] | value |
GetRange(String, Int32, Int32)
Declaration
public byte[] GetRange(string key, int fromIndex, int toIndex)
Returns
System.Byte[]
Parameters
Type | Name |
---|
System.String | key |
System.Int32 | fromIndex |
System.Int32 | toIndex |
SetRange(String, Int32, Byte[])
Declaration
public long SetRange(string key, int offset, byte[] value)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | key |
System.Int32 | offset |
System.Byte[] | value |
GetBit(String, Int32)
Declaration
public long GetBit(string key, int offset)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | key |
System.Int32 | offset |
SetBit(String, Int32, Int32)
Declaration
public long SetBit(string key, int offset, int value)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | key |
System.Int32 | offset |
System.Int32 | value |
BitCount(String)
Declaration
public long BitCount(string key)
Returns
System.Int64
Parameters
RandomKey()
Declaration
public string RandomKey()
Returns
System.String
Rename(String, String)
Declaration
public void Rename(string oldKeyName, string newKeyName)
Parameters
Type | Name |
---|
System.String | oldKeyName |
System.String | newKeyName |
RenameNx(String, String)
Declaration
public bool RenameNx(string oldKeyName, string newKeyName)
Returns
System.Boolean
Parameters
Type | Name |
---|
System.String | oldKeyName |
System.String | newKeyName |
Expire(String, Int32)
Declaration
public bool Expire(string key, int seconds)
Returns
System.Boolean
Parameters
Type | Name |
---|
System.String | key |
System.Int32 | seconds |
Expire(Byte[], Int32)
Declaration
public bool Expire(byte[] key, int seconds)
Returns
System.Boolean
Parameters
Type | Name |
---|
System.Byte[] | key |
System.Int32 | seconds |
PExpire(String, Int64)
Declaration
public bool PExpire(string key, long ttlMs)
Returns
System.Boolean
Parameters
Type | Name |
---|
System.String | key |
System.Int64 | ttlMs |
PExpire(Byte[], Int64)
Declaration
public bool PExpire(byte[] key, long ttlMs)
Returns
System.Boolean
Parameters
Type | Name |
---|
System.Byte[] | key |
System.Int64 | ttlMs |
ExpireAt(String, Int64)
Declaration
public bool ExpireAt(string key, long unixTime)
Returns
System.Boolean
Parameters
Type | Name |
---|
System.String | key |
System.Int64 | unixTime |
PExpireAt(String, Int64)
Declaration
public bool PExpireAt(string key, long unixTimeMs)
Returns
System.Boolean
Parameters
Type | Name |
---|
System.String | key |
System.Int64 | unixTimeMs |
Ttl(String)
Declaration
public long Ttl(string key)
Returns
System.Int64
Parameters
PTtl(String)
Declaration
public long PTtl(string key)
Returns
System.Int64
Parameters
Save()
SaveAsync()
BgSave()
Shutdown()
ShutdownNoSave()
Declaration
public void ShutdownNoSave()
BgRewriteAof()
Declaration
public void BgRewriteAof()
Quit()
FlushDb()
FlushAll()
Role()
Returns
ServiceStack.Redis.RedisText
ClientGetName()
Declaration
public string ClientGetName()
Returns
System.String
ClientSetName(String)
Declaration
public void ClientSetName(string name)
Parameters
Type | Name |
---|
System.String | name |
ClientPause(Int32)
Declaration
public void ClientPause(int timeOutMs)
Parameters
Type | Name |
---|
System.Int32 | timeOutMs |
ClientList()
Declaration
public byte[] ClientList()
Returns
System.Byte[]
ClientKill(String)
Declaration
public void ClientKill(string clientAddr)
Parameters
Type | Name |
---|
System.String | clientAddr |
ClientKill(String, String, String, String)
Declaration
public long ClientKill(string addr = null, string id = null, string type = null, string skipMe = null)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | addr |
System.String | id |
System.String | type |
System.String | skipMe |
Keys(String)
Declaration
public byte[][] Keys(string pattern)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String | pattern |
MGet(Byte[][])
Declaration
public byte[][] MGet(params byte[][] keys)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.Byte[][] | keys |
MGet(String[])
Declaration
public byte[][] MGet(params string[] keys)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String[] | keys |
Watch(String[])
Declaration
public void Watch(params string[] keys)
Parameters
Type | Name |
---|
System.String[] | keys |
UnWatch()
Scan(UInt64, Int32, String)
Declaration
public ScanResult Scan(ulong cursor, int count = 10, string match = null)
Returns
ServiceStack.Redis.ScanResult
Parameters
Type | Name |
---|
System.UInt64 | cursor |
System.Int32 | count |
System.String | match |
SScan(String, UInt64, Int32, String)
Declaration
public ScanResult SScan(string setId, ulong cursor, int count = 10, string match = null)
Returns
ServiceStack.Redis.ScanResult
Parameters
Type | Name |
---|
System.String | setId |
System.UInt64 | cursor |
System.Int32 | count |
System.String | match |
ZScan(String, UInt64, Int32, String)
Declaration
public ScanResult ZScan(string setId, ulong cursor, int count = 10, string match = null)
Returns
ServiceStack.Redis.ScanResult
Parameters
Type | Name |
---|
System.String | setId |
System.UInt64 | cursor |
System.Int32 | count |
System.String | match |
HScan(String, UInt64, Int32, String)
Declaration
public ScanResult HScan(string hashId, ulong cursor, int count = 10, string match = null)
Returns
ServiceStack.Redis.ScanResult
Parameters
Type | Name |
---|
System.String | hashId |
System.UInt64 | cursor |
System.Int32 | count |
System.String | match |
PfAdd(String, Byte[][])
Declaration
public bool PfAdd(string key, params byte[][] elements)
Returns
System.Boolean
Parameters
Type | Name |
---|
System.String | key |
System.Byte[][] | elements |
PfCount(String)
Declaration
public long PfCount(string key)
Returns
System.Int64
Parameters
PfMerge(String, String[])
Declaration
public void PfMerge(string toKeyId, params string[] fromKeys)
Parameters
Type | Name |
---|
System.String | toKeyId |
System.String[] | fromKeys |
Declaration
public byte[][] SMembers(string setId)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String | setId |
SAdd(String, Byte[])
Declaration
public long SAdd(string setId, byte[] value)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | setId |
System.Byte[] | value |
SAdd(String, Byte[][])
Declaration
public long SAdd(string setId, byte[][] values)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | setId |
System.Byte[][] | values |
SRem(String, Byte[])
Declaration
public long SRem(string setId, byte[] value)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | setId |
System.Byte[] | value |
SRem(String, Byte[][])
Declaration
public long SRem(string setId, byte[][] values)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | setId |
System.Byte[][] | values |
SPop(String)
Declaration
public byte[] SPop(string setId)
Returns
System.Byte[]
Parameters
Type | Name |
---|
System.String | setId |
SPop(String, Int32)
Declaration
public byte[][] SPop(string setId, int count)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String | setId |
System.Int32 | count |
SMove(String, String, Byte[])
Declaration
public void SMove(string fromSetId, string toSetId, byte[] value)
Parameters
Type | Name |
---|
System.String | fromSetId |
System.String | toSetId |
System.Byte[] | value |
SCard(String)
Declaration
public long SCard(string setId)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | setId |
SIsMember(String, Byte[])
Declaration
public long SIsMember(string setId, byte[] value)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | setId |
System.Byte[] | value |
SInter(String[])
Declaration
public byte[][] SInter(params string[] setIds)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String[] | setIds |
SInterStore(String, String[])
Declaration
public void SInterStore(string intoSetId, params string[] setIds)
Parameters
Type | Name |
---|
System.String | intoSetId |
System.String[] | setIds |
SUnion(String[])
Declaration
public byte[][] SUnion(params string[] setIds)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String[] | setIds |
SUnionStore(String, String[])
Declaration
public void SUnionStore(string intoSetId, params string[] setIds)
Parameters
Type | Name |
---|
System.String | intoSetId |
System.String[] | setIds |
SDiff(String, String[])
Declaration
public byte[][] SDiff(string fromSetId, params string[] withSetIds)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String | fromSetId |
System.String[] | withSetIds |
SDiffStore(String, String, String[])
Declaration
public void SDiffStore(string intoSetId, string fromSetId, params string[] withSetIds)
Parameters
Type | Name |
---|
System.String | intoSetId |
System.String | fromSetId |
System.String[] | withSetIds |
SRandMember(String)
Declaration
public byte[] SRandMember(string setId)
Returns
System.Byte[]
Parameters
Type | Name |
---|
System.String | setId |
SRandMember(String, Int32)
Declaration
public byte[][] SRandMember(string setId, int count)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String | setId |
System.Int32 | count |
LRange(String, Int32, Int32)
Declaration
public byte[][] LRange(string listId, int startingFrom, int endingAt)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String | listId |
System.Int32 | startingFrom |
System.Int32 | endingAt |
Sort(String, SortOptions)
Declaration
public byte[][] Sort(string listOrSetId, SortOptions sortOptions)
Returns
System.Byte[][]
Parameters
RPush(String, Byte[])
Declaration
public long RPush(string listId, byte[] value)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | listId |
System.Byte[] | value |
RPush(String, Byte[][])
Declaration
public long RPush(string listId, byte[][] values)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | listId |
System.Byte[][] | values |
RPushX(String, Byte[])
Declaration
public long RPushX(string listId, byte[] value)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | listId |
System.Byte[] | value |
LPush(String, Byte[])
Declaration
public long LPush(string listId, byte[] value)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | listId |
System.Byte[] | value |
LPush(String, Byte[][])
Declaration
public long LPush(string listId, byte[][] values)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | listId |
System.Byte[][] | values |
LPushX(String, Byte[])
Declaration
public long LPushX(string listId, byte[] value)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | listId |
System.Byte[] | value |
LTrim(String, Int32, Int32)
Declaration
public void LTrim(string listId, int keepStartingFrom, int keepEndingAt)
Parameters
Type | Name |
---|
System.String | listId |
System.Int32 | keepStartingFrom |
System.Int32 | keepEndingAt |
LRem(String, Int32, Byte[])
Declaration
public long LRem(string listId, int removeNoOfMatches, byte[] value)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | listId |
System.Int32 | removeNoOfMatches |
System.Byte[] | value |
LLen(String)
Declaration
public long LLen(string listId)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | listId |
LIndex(String, Int32)
Declaration
public byte[] LIndex(string listId, int listIndex)
Returns
System.Byte[]
Parameters
Type | Name |
---|
System.String | listId |
System.Int32 | listIndex |
LInsert(String, Boolean, Byte[], Byte[])
Declaration
public void LInsert(string listId, bool insertBefore, byte[] pivot, byte[] value)
Parameters
Type | Name |
---|
System.String | listId |
System.Boolean | insertBefore |
System.Byte[] | pivot |
System.Byte[] | value |
LSet(String, Int32, Byte[])
Declaration
public void LSet(string listId, int listIndex, byte[] value)
Parameters
Type | Name |
---|
System.String | listId |
System.Int32 | listIndex |
System.Byte[] | value |
LPop(String)
Declaration
public byte[] LPop(string listId)
Returns
System.Byte[]
Parameters
Type | Name |
---|
System.String | listId |
RPop(String)
Declaration
public byte[] RPop(string listId)
Returns
System.Byte[]
Parameters
Type | Name |
---|
System.String | listId |
BLPop(String, Int32)
Declaration
public byte[][] BLPop(string listId, int timeOutSecs)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String | listId |
System.Int32 | timeOutSecs |
BLPop(String[], Int32)
Declaration
public byte[][] BLPop(string[] listIds, int timeOutSecs)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String[] | listIds |
System.Int32 | timeOutSecs |
BLPopValue(String, Int32)
Declaration
public byte[] BLPopValue(string listId, int timeOutSecs)
Returns
System.Byte[]
Parameters
Type | Name |
---|
System.String | listId |
System.Int32 | timeOutSecs |
BLPopValue(String[], Int32)
Declaration
public byte[][] BLPopValue(string[] listIds, int timeOutSecs)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String[] | listIds |
System.Int32 | timeOutSecs |
BRPop(String, Int32)
Declaration
public byte[][] BRPop(string listId, int timeOutSecs)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String | listId |
System.Int32 | timeOutSecs |
BRPop(String[], Int32)
Declaration
public byte[][] BRPop(string[] listIds, int timeOutSecs)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String[] | listIds |
System.Int32 | timeOutSecs |
BRPopValue(String, Int32)
Declaration
public byte[] BRPopValue(string listId, int timeOutSecs)
Returns
System.Byte[]
Parameters
Type | Name |
---|
System.String | listId |
System.Int32 | timeOutSecs |
BRPopValue(String[], Int32)
Declaration
public byte[][] BRPopValue(string[] listIds, int timeOutSecs)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String[] | listIds |
System.Int32 | timeOutSecs |
RPopLPush(String, String)
Declaration
public byte[] RPopLPush(string fromListId, string toListId)
Returns
System.Byte[]
Parameters
Type | Name |
---|
System.String | fromListId |
System.String | toListId |
BRPopLPush(String, String, Int32)
Declaration
public byte[] BRPopLPush(string fromListId, string toListId, int timeOutSecs)
Returns
System.Byte[]
Parameters
Type | Name |
---|
System.String | fromListId |
System.String | toListId |
System.Int32 | timeOutSecs |
SentinelMasters()
Declaration
public List<Dictionary<string, string>> SentinelMasters()
Returns
System.Collections.Generic.List<System.Collections.Generic.Dictionary<System.String,System.String>>
SentinelMaster(String)
Declaration
public Dictionary<string, string> SentinelMaster(string masterName)
Returns
System.Collections.Generic.Dictionary<System.String,System.String>
Parameters
Type | Name |
---|
System.String | masterName |
SentinelSentinels(String)
Declaration
public List<Dictionary<string, string>> SentinelSentinels(string masterName)
Returns
System.Collections.Generic.List<System.Collections.Generic.Dictionary<System.String,System.String>>
Parameters
Type | Name |
---|
System.String | masterName |
SentinelSlaves(String)
Declaration
public List<Dictionary<string, string>> SentinelSlaves(string masterName)
Returns
System.Collections.Generic.List<System.Collections.Generic.Dictionary<System.String,System.String>>
Parameters
Type | Name |
---|
System.String | masterName |
SentinelGetMasterAddrByName(String)
Declaration
public List<string> SentinelGetMasterAddrByName(string masterName)
Returns
System.Collections.Generic.List<System.String>
Parameters
Type | Name |
---|
System.String | masterName |
SentinelFailover(String)
Declaration
public void SentinelFailover(string masterName)
Parameters
Type | Name |
---|
System.String | masterName |
ZAdd(String, Double, Byte[])
Declaration
public long ZAdd(string setId, double score, byte[] value)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | setId |
System.Double | score |
System.Byte[] | value |
ZAdd(String, Int64, Byte[])
Declaration
public long ZAdd(string setId, long score, byte[] value)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | setId |
System.Int64 | score |
System.Byte[] | value |
ZAdd(String, List<KeyValuePair<Byte[], Double>>)
Declaration
public long ZAdd(string setId, List<KeyValuePair<byte[], double>> pairs)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | setId |
System.Collections.Generic.List<System.Collections.Generic.KeyValuePair<System.Byte[],System.Double>> | pairs |
ZAdd(String, List<KeyValuePair<Byte[], Int64>>)
Declaration
public long ZAdd(string setId, List<KeyValuePair<byte[], long>> pairs)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | setId |
System.Collections.Generic.List<System.Collections.Generic.KeyValuePair<System.Byte[],System.Int64>> | pairs |
ZRem(String, Byte[])
Declaration
public long ZRem(string setId, byte[] value)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | setId |
System.Byte[] | value |
ZRem(String, Byte[][])
Declaration
public long ZRem(string setId, byte[][] values)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | setId |
System.Byte[][] | values |
ZIncrBy(String, Double, Byte[])
Declaration
public double ZIncrBy(string setId, double incrBy, byte[] value)
Returns
System.Double
Parameters
Type | Name |
---|
System.String | setId |
System.Double | incrBy |
System.Byte[] | value |
ZIncrBy(String, Int64, Byte[])
Declaration
public double ZIncrBy(string setId, long incrBy, byte[] value)
Returns
System.Double
Parameters
Type | Name |
---|
System.String | setId |
System.Int64 | incrBy |
System.Byte[] | value |
ZRank(String, Byte[])
Declaration
public long ZRank(string setId, byte[] value)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | setId |
System.Byte[] | value |
ZRevRank(String, Byte[])
Declaration
public long ZRevRank(string setId, byte[] value)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | setId |
System.Byte[] | value |
ZRange(String, Int32, Int32)
Declaration
public byte[][] ZRange(string setId, int min, int max)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String | setId |
System.Int32 | min |
System.Int32 | max |
ZRangeWithScores(String, Int32, Int32)
Declaration
public byte[][] ZRangeWithScores(string setId, int min, int max)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String | setId |
System.Int32 | min |
System.Int32 | max |
ZRevRange(String, Int32, Int32)
Declaration
public byte[][] ZRevRange(string setId, int min, int max)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String | setId |
System.Int32 | min |
System.Int32 | max |
ZRevRangeWithScores(String, Int32, Int32)
Declaration
public byte[][] ZRevRangeWithScores(string setId, int min, int max)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String | setId |
System.Int32 | min |
System.Int32 | max |
ZRangeByScore(String, Double, Double, Nullable<Int32>, Nullable<Int32>)
Declaration
public byte[][] ZRangeByScore(string setId, double min, double max, int? skip, int? take)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String | setId |
System.Double | min |
System.Double | max |
System.Nullable<System.Int32> | skip |
System.Nullable<System.Int32> | take |
ZRangeByScore(String, Int64, Int64, Nullable<Int32>, Nullable<Int32>)
Declaration
public byte[][] ZRangeByScore(string setId, long min, long max, int? skip, int? take)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String | setId |
System.Int64 | min |
System.Int64 | max |
System.Nullable<System.Int32> | skip |
System.Nullable<System.Int32> | take |
ZRangeByScoreWithScores(String, Double, Double, Nullable<Int32>, Nullable<Int32>)
Declaration
public byte[][] ZRangeByScoreWithScores(string setId, double min, double max, int? skip, int? take)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String | setId |
System.Double | min |
System.Double | max |
System.Nullable<System.Int32> | skip |
System.Nullable<System.Int32> | take |
ZRangeByScoreWithScores(String, Int64, Int64, Nullable<Int32>, Nullable<Int32>)
Declaration
public byte[][] ZRangeByScoreWithScores(string setId, long min, long max, int? skip, int? take)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String | setId |
System.Int64 | min |
System.Int64 | max |
System.Nullable<System.Int32> | skip |
System.Nullable<System.Int32> | take |
ZRevRangeByScore(String, Double, Double, Nullable<Int32>, Nullable<Int32>)
Declaration
public byte[][] ZRevRangeByScore(string setId, double min, double max, int? skip, int? take)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String | setId |
System.Double | min |
System.Double | max |
System.Nullable<System.Int32> | skip |
System.Nullable<System.Int32> | take |
ZRevRangeByScore(String, Int64, Int64, Nullable<Int32>, Nullable<Int32>)
Declaration
public byte[][] ZRevRangeByScore(string setId, long min, long max, int? skip, int? take)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String | setId |
System.Int64 | min |
System.Int64 | max |
System.Nullable<System.Int32> | skip |
System.Nullable<System.Int32> | take |
ZRevRangeByScoreWithScores(String, Double, Double, Nullable<Int32>, Nullable<Int32>)
Declaration
public byte[][] ZRevRangeByScoreWithScores(string setId, double min, double max, int? skip, int? take)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String | setId |
System.Double | min |
System.Double | max |
System.Nullable<System.Int32> | skip |
System.Nullable<System.Int32> | take |
ZRevRangeByScoreWithScores(String, Int64, Int64, Nullable<Int32>, Nullable<Int32>)
Declaration
public byte[][] ZRevRangeByScoreWithScores(string setId, long min, long max, int? skip, int? take)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String | setId |
System.Int64 | min |
System.Int64 | max |
System.Nullable<System.Int32> | skip |
System.Nullable<System.Int32> | take |
ZRemRangeByRank(String, Int32, Int32)
Declaration
public long ZRemRangeByRank(string setId, int min, int max)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | setId |
System.Int32 | min |
System.Int32 | max |
ZRemRangeByScore(String, Double, Double)
Declaration
public long ZRemRangeByScore(string setId, double fromScore, double toScore)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | setId |
System.Double | fromScore |
System.Double | toScore |
ZRemRangeByScore(String, Int64, Int64)
Declaration
public long ZRemRangeByScore(string setId, long fromScore, long toScore)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | setId |
System.Int64 | fromScore |
System.Int64 | toScore |
ZCard(String)
Declaration
public long ZCard(string setId)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | setId |
ZCount(String, Double, Double)
Declaration
public long ZCount(string setId, double min, double max)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | setId |
System.Double | min |
System.Double | max |
ZCount(String, Int64, Int64)
Declaration
public long ZCount(string setId, long min, long max)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | setId |
System.Int64 | min |
System.Int64 | max |
ZScore(String, Byte[])
Declaration
public double ZScore(string setId, byte[] value)
Returns
System.Double
Parameters
Type | Name |
---|
System.String | setId |
System.Byte[] | value |
ZUnionStore(String, String[])
Declaration
public long ZUnionStore(string intoSetId, params string[] setIds)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | intoSetId |
System.String[] | setIds |
ZUnionStore(String, String[], String[])
Declaration
public long ZUnionStore(string intoSetId, string[] setIds, string[] args)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | intoSetId |
System.String[] | setIds |
System.String[] | args |
ZInterStore(String, String[])
Declaration
public long ZInterStore(string intoSetId, params string[] setIds)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | intoSetId |
System.String[] | setIds |
ZInterStore(String, String[], String[])
Declaration
public long ZInterStore(string intoSetId, string[] setIds, string[] args)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | intoSetId |
System.String[] | setIds |
System.String[] | args |
ZRangeByLex(String, String, String, Nullable<Int32>, Nullable<Int32>)
Declaration
public byte[][] ZRangeByLex(string setId, string min, string max, int? skip = null, int? take = null)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String | setId |
System.String | min |
System.String | max |
System.Nullable<System.Int32> | skip |
System.Nullable<System.Int32> | take |
ZLexCount(String, String, String)
Declaration
public long ZLexCount(string setId, string min, string max)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | setId |
System.String | min |
System.String | max |
ZRemRangeByLex(String, String, String)
Declaration
public long ZRemRangeByLex(string setId, string min, string max)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | setId |
System.String | min |
System.String | max |
HSet(String, Byte[], Byte[])
Declaration
public long HSet(string hashId, byte[] key, byte[] value)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | hashId |
System.Byte[] | key |
System.Byte[] | value |
HSet(Byte[], Byte[], Byte[])
Declaration
public long HSet(byte[] hashId, byte[] key, byte[] value)
Returns
System.Int64
Parameters
Type | Name |
---|
System.Byte[] | hashId |
System.Byte[] | key |
System.Byte[] | value |
HSetNX(String, Byte[], Byte[])
Declaration
public long HSetNX(string hashId, byte[] key, byte[] value)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | hashId |
System.Byte[] | key |
System.Byte[] | value |
HMSet(String, Byte[][], Byte[][])
Declaration
public void HMSet(string hashId, byte[][] keys, byte[][] values)
Parameters
Type | Name |
---|
System.String | hashId |
System.Byte[][] | keys |
System.Byte[][] | values |
HIncrby(String, Byte[], Int32)
Declaration
public long HIncrby(string hashId, byte[] key, int incrementBy)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | hashId |
System.Byte[] | key |
System.Int32 | incrementBy |
HIncrby(String, Byte[], Int64)
Declaration
public long HIncrby(string hashId, byte[] key, long incrementBy)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | hashId |
System.Byte[] | key |
System.Int64 | incrementBy |
HIncrbyFloat(String, Byte[], Double)
Declaration
public double HIncrbyFloat(string hashId, byte[] key, double incrementBy)
Returns
System.Double
Parameters
Type | Name |
---|
System.String | hashId |
System.Byte[] | key |
System.Double | incrementBy |
HGet(String, Byte[])
Declaration
public byte[] HGet(string hashId, byte[] key)
Returns
System.Byte[]
Parameters
Type | Name |
---|
System.String | hashId |
System.Byte[] | key |
HGet(Byte[], Byte[])
Declaration
public byte[] HGet(byte[] hashId, byte[] key)
Returns
System.Byte[]
Parameters
Type | Name |
---|
System.Byte[] | hashId |
System.Byte[] | key |
HMGet(String, Byte[][])
Declaration
public byte[][] HMGet(string hashId, params byte[][] keys)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String | hashId |
System.Byte[][] | keys |
HDel(String, Byte[])
Declaration
public long HDel(string hashId, byte[] key)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | hashId |
System.Byte[] | key |
HDel(Byte[], Byte[])
Declaration
public long HDel(byte[] hashId, byte[] key)
Returns
System.Int64
Parameters
Type | Name |
---|
System.Byte[] | hashId |
System.Byte[] | key |
HDel(String, Byte[][])
Declaration
public long HDel(string hashId, byte[][] keys)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | hashId |
System.Byte[][] | keys |
HExists(String, Byte[])
Declaration
public long HExists(string hashId, byte[] key)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | hashId |
System.Byte[] | key |
HLen(String)
Declaration
public long HLen(string hashId)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | hashId |
HKeys(String)
Declaration
public byte[][] HKeys(string hashId)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String | hashId |
HVals(String)
Declaration
public byte[][] HVals(string hashId)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String | hashId |
HGetAll(String)
Declaration
public byte[][] HGetAll(string hashId)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String | hashId |
Publish(String, Byte[])
Declaration
public long Publish(string toChannel, byte[] message)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | toChannel |
System.Byte[] | message |
ReceiveMessages()
Declaration
public byte[][] ReceiveMessages()
Returns
System.Byte[][]
CreateSubscription()
Declaration
public virtual IRedisSubscription CreateSubscription()
Returns
ServiceStack.Redis.IRedisSubscription
Subscribe(String[])
Declaration
public byte[][] Subscribe(params string[] toChannels)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String[] | toChannels |
UnSubscribe(String[])
Declaration
public byte[][] UnSubscribe(params string[] fromChannels)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String[] | fromChannels |
PSubscribe(String[])
Declaration
public byte[][] PSubscribe(params string[] toChannelsMatchingPatterns)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String[] | toChannelsMatchingPatterns |
PUnSubscribe(String[])
Declaration
public byte[][] PUnSubscribe(params string[] fromChannelsMatchingPatterns)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String[] | fromChannelsMatchingPatterns |
CreatePipelineCommand()
Declaration
public RedisPipelineCommand CreatePipelineCommand()
Returns
ServiceStack.Redis.Pipeline.RedisPipelineCommand
GeoAdd(String, Double, Double, String)
Declaration
public long GeoAdd(string key, double longitude, double latitude, string member)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | key |
System.Double | longitude |
System.Double | latitude |
System.String | member |
GeoAdd(String, RedisGeo[])
Declaration
public long GeoAdd(string key, params RedisGeo[] geoPoints)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | key |
ServiceStack.Redis.RedisGeo[] | geoPoints |
GeoDist(String, String, String, String)
Declaration
public double GeoDist(string key, string fromMember, string toMember, string unit = null)
Returns
System.Double
Parameters
Type | Name |
---|
System.String | key |
System.String | fromMember |
System.String | toMember |
System.String | unit |
GeoHash(String, String[])
Declaration
public string[] GeoHash(string key, params string[] members)
Returns
System.String[]
Parameters
Type | Name |
---|
System.String | key |
System.String[] | members |
GeoPos(String, String[])
Declaration
public List<RedisGeo> GeoPos(string key, params string[] members)
Returns
System.Collections.Generic.List<ServiceStack.Redis.RedisGeo>
Parameters
Type | Name |
---|
System.String | key |
System.String[] | members |
GeoRadius(String, Double, Double, Double, String, Boolean, Boolean, Boolean, Nullable<Int32>, Nullable<Boolean>)
Declaration
public List<RedisGeoResult> GeoRadius(string key, double longitude, double latitude, double radius, string unit, bool withCoords = false, bool withDist = false, bool withHash = false, int? count = null, bool? asc = null)
Returns
System.Collections.Generic.List<ServiceStack.Redis.RedisGeoResult>
Parameters
Type | Name |
---|
System.String | key |
System.Double | longitude |
System.Double | latitude |
System.Double | radius |
System.String | unit |
System.Boolean | withCoords |
System.Boolean | withDist |
System.Boolean | withHash |
System.Nullable<System.Int32> | count |
System.Nullable<System.Boolean> | asc |
GeoRadiusByMember(String, String, Double, String, Boolean, Boolean, Boolean, Nullable<Int32>, Nullable<Boolean>)
Declaration
public List<RedisGeoResult> GeoRadiusByMember(string key, string member, double radius, string unit, bool withCoords = false, bool withDist = false, bool withHash = false, int? count = null, bool? asc = null)
Returns
System.Collections.Generic.List<ServiceStack.Redis.RedisGeoResult>
Parameters
Type | Name |
---|
System.String | key |
System.String | member |
System.Double | radius |
System.String | unit |
System.Boolean | withCoords |
System.Boolean | withDist |
System.Boolean | withHash |
System.Nullable<System.Int32> | count |
System.Nullable<System.Boolean> | asc |
Dispose()
Declaration
public virtual void Dispose()
Finalize()
Declaration
protected void Finalize()
Dispose(Boolean)
Declaration
protected virtual void Dispose(bool disposing)
Parameters
Type | Name |
---|
System.Boolean | disposing |
SendWithoutReadAsync(CancellationToken, Byte[][])
Declaration
protected ValueTask SendWithoutReadAsync(CancellationToken token, params byte[][] cmdWithBinaryArgs)
Returns
ValueTask
Parameters
Type | Name |
---|
System.Threading.CancellationToken | token |
System.Byte[][] | cmdWithBinaryArgs |
SendExpectStringAsync(CancellationToken, Byte[][])
Declaration
protected ValueTask<string> SendExpectStringAsync(CancellationToken token, params byte[][] cmdWithBinaryArgs)
Returns
ValueTask<System.String>
Parameters
Type | Name |
---|
System.Threading.CancellationToken | token |
System.Byte[][] | cmdWithBinaryArgs |
SendExpectComplexResponseAsync(CancellationToken, Byte[][])
Declaration
protected ValueTask<RedisData> SendExpectComplexResponseAsync(CancellationToken token, params byte[][] cmdWithBinaryArgs)
Returns
ValueTask<ServiceStack.Redis.RedisData>
Parameters
Type | Name |
---|
System.Threading.CancellationToken | token |
System.Byte[][] | cmdWithBinaryArgs |
AssertServerVersionNumber()
Declaration
public int AssertServerVersionNumber()
Returns
System.Int32
DisposeTimers()
Declaration
public static void DisposeTimers()
OnConnected()
Declaration
public virtual void OnConnected()
ReadLine()
Declaration
protected string ReadLine()
Returns
System.String
IsSocketConnected()
Declaration
public bool IsSocketConnected()
Returns
System.Boolean
WriteCommandToSendBuffer(Byte[][])
Command to set multiple binary safe arguments
Declaration
protected void WriteCommandToSendBuffer(params byte[][] cmdWithBinaryArgs)
Parameters
Type | Name |
---|
System.Byte[][] | cmdWithBinaryArgs |
SendUnmanagedExpectSuccess(Byte[][])
Send command outside of managed Write Buffer
Declaration
protected void SendUnmanagedExpectSuccess(params byte[][] cmdWithBinaryArgs)
Parameters
Type | Name |
---|
System.Byte[][] | cmdWithBinaryArgs |
WriteAllToSendBuffer(Byte[][])
Declaration
public void WriteAllToSendBuffer(params byte[][] cmdWithBinaryArgs)
Parameters
Type | Name |
---|
System.Byte[][] | cmdWithBinaryArgs |
WriteToSendBuffer(Byte[])
Declaration
public void WriteToSendBuffer(byte[] cmdBytes)
Parameters
Type | Name |
---|
System.Byte[] | cmdBytes |
ResetSendBuffer()
reset buffer index in send buffer
Declaration
public void ResetSendBuffer()
SendReceive<T>(Byte[][], Func<T>, Action<Func<T>>, Boolean, String)
Declaration
protected T SendReceive<T>(byte[][] cmdWithBinaryArgs, Func<T> fn, Action<Func<T>> completePipelineFn = null, bool sendWithoutRead = false, string operation = "")
Returns
<T>
Parameters
Type | Name |
---|
System.Byte[][] | cmdWithBinaryArgs |
System.Func<<T>> | fn |
System.Action<System.Func<<T>>> | completePipelineFn |
System.Boolean | sendWithoutRead |
System.String | operation |
Type Parameters
SendWithoutRead(Byte[][])
Declaration
protected void SendWithoutRead(params byte[][] cmdWithBinaryArgs)
Parameters
Type | Name |
---|
System.Byte[][] | cmdWithBinaryArgs |
SendExpectSuccess(Byte[][])
Declaration
protected void SendExpectSuccess(params byte[][] cmdWithBinaryArgs)
Parameters
Type | Name |
---|
System.Byte[][] | cmdWithBinaryArgs |
SendExpectLong(Byte[][])
Declaration
protected long SendExpectLong(params byte[][] cmdWithBinaryArgs)
Returns
System.Int64
Parameters
Type | Name |
---|
System.Byte[][] | cmdWithBinaryArgs |
SendExpectData(Byte[][])
Declaration
protected byte[] SendExpectData(params byte[][] cmdWithBinaryArgs)
Returns
System.Byte[]
Parameters
Type | Name |
---|
System.Byte[][] | cmdWithBinaryArgs |
SendExpectDouble(Byte[][])
Declaration
protected double SendExpectDouble(params byte[][] cmdWithBinaryArgs)
Returns
System.Double
Parameters
Type | Name |
---|
System.Byte[][] | cmdWithBinaryArgs |
SendExpectCode(Byte[][])
Declaration
protected string SendExpectCode(params byte[][] cmdWithBinaryArgs)
Returns
System.String
Parameters
Type | Name |
---|
System.Byte[][] | cmdWithBinaryArgs |
SendExpectMultiData(Byte[][])
Declaration
protected byte[][] SendExpectMultiData(params byte[][] cmdWithBinaryArgs)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.Byte[][] | cmdWithBinaryArgs |
SendExpectDeeplyNestedMultiData(Byte[][])
Declaration
protected object[] SendExpectDeeplyNestedMultiData(params byte[][] cmdWithBinaryArgs)
Returns
System.Object[]
Parameters
Type | Name |
---|
System.Byte[][] | cmdWithBinaryArgs |
SendExpectComplexResponse(Byte[][])
Declaration
protected RedisData SendExpectComplexResponse(params byte[][] cmdWithBinaryArgs)
Returns
ServiceStack.Redis.RedisData
Parameters
Type | Name |
---|
System.Byte[][] | cmdWithBinaryArgs |
SendExpectStringDictionaryList(Byte[][])
Declaration
protected List<Dictionary<string, string>> SendExpectStringDictionaryList(params byte[][] cmdWithBinaryArgs)
Returns
System.Collections.Generic.List<System.Collections.Generic.Dictionary<System.String,System.String>>
Parameters
Type | Name |
---|
System.Byte[][] | cmdWithBinaryArgs |
SendExpectString(Byte[][])
Declaration
protected string SendExpectString(params byte[][] cmdWithBinaryArgs)
Returns
System.String
Parameters
Type | Name |
---|
System.Byte[][] | cmdWithBinaryArgs |
Log(String, Object[])
Declaration
protected void Log(string fmt, params object[] args)
Parameters
Type | Name |
---|
System.String | fmt |
System.Object[] | args |
CmdLog(Byte[][])
Declaration
protected void CmdLog(byte[][] args)
Parameters
Type | Name |
---|
System.Byte[][] | args |
ExpectSuccessFn()
Declaration
protected long ExpectSuccessFn()
Returns
System.Int64
ExpectSuccess()
Declaration
protected void ExpectSuccess()
ReadLong()
Returns
System.Int64
ReadDouble()
Declaration
public double ReadDouble()
Returns
System.Double
ParseDouble(Byte[])
Declaration
public static double ParseDouble(byte[] doubleBytes)
Returns
System.Double
Parameters
Type | Name |
---|
System.Byte[] | doubleBytes |
ConvertToBytes(String[])
Declaration
protected byte[][] ConvertToBytes(string[] keys)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String[] | keys |
MergeAndConvertToBytes(String[], String[])
Declaration
protected byte[][] MergeAndConvertToBytes(string[] keys, string[] args)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String[] | keys |
System.String[] | args |
EvalInt(String, Int32, Byte[][])
Declaration
public long EvalInt(string luaBody, int numberKeysInArgs, params byte[][] keys)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | luaBody |
System.Int32 | numberKeysInArgs |
System.Byte[][] | keys |
EvalShaInt(String, Int32, Byte[][])
Declaration
public long EvalShaInt(string sha1, int numberKeysInArgs, params byte[][] keys)
Returns
System.Int64
Parameters
Type | Name |
---|
System.String | sha1 |
System.Int32 | numberKeysInArgs |
System.Byte[][] | keys |
EvalStr(String, Int32, Byte[][])
Declaration
public string EvalStr(string luaBody, int numberKeysInArgs, params byte[][] keys)
Returns
System.String
Parameters
Type | Name |
---|
System.String | luaBody |
System.Int32 | numberKeysInArgs |
System.Byte[][] | keys |
EvalShaStr(String, Int32, Byte[][])
Declaration
public string EvalShaStr(string sha1, int numberKeysInArgs, params byte[][] keys)
Returns
System.String
Parameters
Type | Name |
---|
System.String | sha1 |
System.Int32 | numberKeysInArgs |
System.Byte[][] | keys |
Eval(String, Int32, Byte[][])
Declaration
public byte[][] Eval(string luaBody, int numberKeysInArgs, params byte[][] keys)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String | luaBody |
System.Int32 | numberKeysInArgs |
System.Byte[][] | keys |
EvalSha(String, Int32, Byte[][])
Declaration
public byte[][] EvalSha(string sha1, int numberKeysInArgs, params byte[][] keys)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.String | sha1 |
System.Int32 | numberKeysInArgs |
System.Byte[][] | keys |
EvalCommand(String, Int32, Byte[][])
Declaration
public RedisData EvalCommand(string luaBody, int numberKeysInArgs, params byte[][] keys)
Returns
ServiceStack.Redis.RedisData
Parameters
Type | Name |
---|
System.String | luaBody |
System.Int32 | numberKeysInArgs |
System.Byte[][] | keys |
EvalShaCommand(String, Int32, Byte[][])
Declaration
public RedisData EvalShaCommand(string sha1, int numberKeysInArgs, params byte[][] keys)
Returns
ServiceStack.Redis.RedisData
Parameters
Type | Name |
---|
System.String | sha1 |
System.Int32 | numberKeysInArgs |
System.Byte[][] | keys |
CalculateSha1(String)
Declaration
public string CalculateSha1(string luaBody)
Returns
System.String
Parameters
Type | Name |
---|
System.String | luaBody |
ScriptLoad(String)
Declaration
public byte[] ScriptLoad(string luaBody)
Returns
System.Byte[]
Parameters
Type | Name |
---|
System.String | luaBody |
ScriptExists(Byte[][])
Declaration
public byte[][] ScriptExists(params byte[][] sha1Refs)
Returns
System.Byte[][]
Parameters
Type | Name |
---|
System.Byte[][] | sha1Refs |
ScriptFlush()
Declaration
public void ScriptFlush()
ScriptKill()
Implements