Skip to main content

RedisCommandQueue

Assembly: ServiceStack.Redis.dll
View Source
Declaration
public class RedisCommandQueue : RedisQueueCompletableOperation

Fields

RedisClient

View Source
Declaration
protected readonly RedisClient RedisClient

Methods

QueueCommand(Action<IRedisClient>)

View Source
Declaration
public void QueueCommand(Action<IRedisClient> command)
Parameters
TypeName
System.Action<ServiceStack.Redis.IRedisClient>command

QueueCommand(Action<IRedisClient>, Action)

View Source
Declaration
public void QueueCommand(Action<IRedisClient> command, Action onSuccessCallback)
Parameters
TypeName
System.Action<ServiceStack.Redis.IRedisClient>command
System.ActiononSuccessCallback

QueueCommand(Action<IRedisClient>, Action, Action<Exception>)

View Source
Declaration
public virtual void QueueCommand(Action<IRedisClient> command, Action onSuccessCallback, Action<Exception> onErrorCallback)
Parameters
TypeName
System.Action<ServiceStack.Redis.IRedisClient>command
System.ActiononSuccessCallback
System.Action<System.Exception>onErrorCallback

QueueCommand(Func<IRedisClient, Int32>)

View Source
Declaration
public void QueueCommand(Func<IRedisClient, int> command)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,System.Int32>command

QueueCommand(Func<IRedisClient, Int32>, Action<Int32>)

View Source
Declaration
public void QueueCommand(Func<IRedisClient, int> command, Action<int> onSuccessCallback)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,System.Int32>command
System.Action<System.Int32>onSuccessCallback

QueueCommand(Func<IRedisClient, Int32>, Action<Int32>, Action<Exception>)

View Source
Declaration
public virtual void QueueCommand(Func<IRedisClient, int> command, Action<int> onSuccessCallback, Action<Exception> onErrorCallback)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,System.Int32>command
System.Action<System.Int32>onSuccessCallback
System.Action<System.Exception>onErrorCallback

QueueCommand(Func<IRedisClient, Int64>)

View Source
Declaration
public void QueueCommand(Func<IRedisClient, long> command)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,System.Int64>command

QueueCommand(Func<IRedisClient, Int64>, Action<Int64>)

View Source
Declaration
public void QueueCommand(Func<IRedisClient, long> command, Action<long> onSuccessCallback)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,System.Int64>command
System.Action<System.Int64>onSuccessCallback

QueueCommand(Func<IRedisClient, Int64>, Action<Int64>, Action<Exception>)

View Source
Declaration
public virtual void QueueCommand(Func<IRedisClient, long> command, Action<long> onSuccessCallback, Action<Exception> onErrorCallback)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,System.Int64>command
System.Action<System.Int64>onSuccessCallback
System.Action<System.Exception>onErrorCallback

QueueCommand(Func<IRedisClient, Boolean>)

View Source
Declaration
public void QueueCommand(Func<IRedisClient, bool> command)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,System.Boolean>command

QueueCommand(Func<IRedisClient, Boolean>, Action<Boolean>)

View Source
Declaration
public void QueueCommand(Func<IRedisClient, bool> command, Action<bool> onSuccessCallback)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,System.Boolean>command
System.Action<System.Boolean>onSuccessCallback

QueueCommand(Func<IRedisClient, Boolean>, Action<Boolean>, Action<Exception>)

View Source
Declaration
public virtual void QueueCommand(Func<IRedisClient, bool> command, Action<bool> onSuccessCallback, Action<Exception> onErrorCallback)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,System.Boolean>command
System.Action<System.Boolean>onSuccessCallback
System.Action<System.Exception>onErrorCallback

QueueCommand(Func<IRedisClient, Double>)

View Source
Declaration
public void QueueCommand(Func<IRedisClient, double> command)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,System.Double>command

QueueCommand(Func<IRedisClient, Double>, Action<Double>)

View Source
Declaration
public void QueueCommand(Func<IRedisClient, double> command, Action<double> onSuccessCallback)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,System.Double>command
System.Action<System.Double>onSuccessCallback

QueueCommand(Func<IRedisClient, Double>, Action<Double>, Action<Exception>)

View Source
Declaration
public virtual void QueueCommand(Func<IRedisClient, double> command, Action<double> onSuccessCallback, Action<Exception> onErrorCallback)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,System.Double>command
System.Action<System.Double>onSuccessCallback
System.Action<System.Exception>onErrorCallback

QueueCommand(Func<IRedisClient, Byte[]>)

View Source
Declaration
public void QueueCommand(Func<IRedisClient, byte[]> command)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,System.Byte[]>command

QueueCommand(Func<IRedisClient, Byte[]>, Action<Byte[]>)

View Source
Declaration
public void QueueCommand(Func<IRedisClient, byte[]> command, Action<byte[]> onSuccessCallback)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,System.Byte[]>command
System.Action<System.Byte[]>onSuccessCallback

QueueCommand(Func<IRedisClient, Byte[]>, Action<Byte[]>, Action<Exception>)

View Source
Declaration
public virtual void QueueCommand(Func<IRedisClient, byte[]> command, Action<byte[]> onSuccessCallback, Action<Exception> onErrorCallback)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,System.Byte[]>command
System.Action<System.Byte[]>onSuccessCallback
System.Action<System.Exception>onErrorCallback

QueueCommand(Func<IRedisClient, String>)

View Source
Declaration
public void QueueCommand(Func<IRedisClient, string> command)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,System.String>command

QueueCommand(Func<IRedisClient, String>, Action<String>)

View Source
Declaration
public void QueueCommand(Func<IRedisClient, string> command, Action<string> onSuccessCallback)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,System.String>command
System.Action<System.String>onSuccessCallback

QueueCommand(Func<IRedisClient, String>, Action<String>, Action<Exception>)

View Source
Declaration
public virtual void QueueCommand(Func<IRedisClient, string> command, Action<string> onSuccessCallback, Action<Exception> onErrorCallback)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,System.String>command
System.Action<System.String>onSuccessCallback
System.Action<System.Exception>onErrorCallback

QueueCommand(Func<IRedisClient, Byte[][]>)

View Source
Declaration
public void QueueCommand(Func<IRedisClient, byte[][]> command)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,System.Byte[][]>command

QueueCommand(Func<IRedisClient, Byte[][]>, Action<Byte[][]>)

View Source
Declaration
public void QueueCommand(Func<IRedisClient, byte[][]> command, Action<byte[][]> onSuccessCallback)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,System.Byte[][]>command
System.Action<System.Byte[][]>onSuccessCallback

QueueCommand(Func<IRedisClient, Byte[][]>, Action<Byte[][]>, Action<Exception>)

View Source
Declaration
public virtual void QueueCommand(Func<IRedisClient, byte[][]> command, Action<byte[][]> onSuccessCallback, Action<Exception> onErrorCallback)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,System.Byte[][]>command
System.Action<System.Byte[][]>onSuccessCallback
System.Action<System.Exception>onErrorCallback

QueueCommand(Func<IRedisClient, List<String>>)

View Source
Declaration
public void QueueCommand(Func<IRedisClient, List<string>> command)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,System.Collections.Generic.List<System.String>>command

QueueCommand(Func<IRedisClient, List<String>>, Action<List<String>>)

View Source
Declaration
public void QueueCommand(Func<IRedisClient, List<string>> command, Action<List<string>> onSuccessCallback)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,System.Collections.Generic.List<System.String>>command
System.Action<System.Collections.Generic.List<System.String>>onSuccessCallback

QueueCommand(Func<IRedisClient, List<String>>, Action<List<String>>, Action<Exception>)

View Source
Declaration
public virtual void QueueCommand(Func<IRedisClient, List<string>> command, Action<List<string>> onSuccessCallback, Action<Exception> onErrorCallback)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,System.Collections.Generic.List<System.String>>command
System.Action<System.Collections.Generic.List<System.String>>onSuccessCallback
System.Action<System.Exception>onErrorCallback

QueueCommand(Func<IRedisClient, HashSet<String>>)

View Source
Declaration
public void QueueCommand(Func<IRedisClient, HashSet<string>> command)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,System.Collections.Generic.HashSet<System.String>>command

QueueCommand(Func<IRedisClient, HashSet<String>>, Action<HashSet<String>>)

View Source
Declaration
public void QueueCommand(Func<IRedisClient, HashSet<string>> command, Action<HashSet<string>> onSuccessCallback)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,System.Collections.Generic.HashSet<System.String>>command
System.Action<System.Collections.Generic.HashSet<System.String>>onSuccessCallback

QueueCommand(Func<IRedisClient, HashSet<String>>, Action<HashSet<String>>, Action<Exception>)

View Source
Declaration
public virtual void QueueCommand(Func<IRedisClient, HashSet<string>> command, Action<HashSet<string>> onSuccessCallback, Action<Exception> onErrorCallback)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,System.Collections.Generic.HashSet<System.String>>command
System.Action<System.Collections.Generic.HashSet<System.String>>onSuccessCallback
System.Action<System.Exception>onErrorCallback

QueueCommand(Func<IRedisClient, Dictionary<String, String>>)

View Source
Declaration
public void QueueCommand(Func<IRedisClient, Dictionary<string, string>> command)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,System.Collections.Generic.Dictionary<System.String,System.String>>command

QueueCommand(Func<IRedisClient, Dictionary<String, String>>, Action<Dictionary<String, String>>)

View Source
Declaration
public void QueueCommand(Func<IRedisClient, Dictionary<string, string>> command, Action<Dictionary<string, string>> onSuccessCallback)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,System.Collections.Generic.Dictionary<System.String,System.String>>command
System.Action<System.Collections.Generic.Dictionary<System.String,System.String>>onSuccessCallback

QueueCommand(Func<IRedisClient, Dictionary<String, String>>, Action<Dictionary<String, String>>, Action<Exception>)

View Source
Declaration
public void QueueCommand(Func<IRedisClient, Dictionary<string, string>> command, Action<Dictionary<string, string>> onSuccessCallback, Action<Exception> onErrorCallback)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,System.Collections.Generic.Dictionary<System.String,System.String>>command
System.Action<System.Collections.Generic.Dictionary<System.String,System.String>>onSuccessCallback
System.Action<System.Exception>onErrorCallback

QueueCommand(Func<IRedisClient, RedisData>)

View Source
Declaration
public void QueueCommand(Func<IRedisClient, RedisData> command)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,ServiceStack.Redis.RedisData>command

QueueCommand(Func<IRedisClient, RedisData>, Action<RedisData>)

View Source
Declaration
public void QueueCommand(Func<IRedisClient, RedisData> command, Action<RedisData> onSuccessCallback)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,ServiceStack.Redis.RedisData>command
System.Action<ServiceStack.Redis.RedisData>onSuccessCallback

QueueCommand(Func<IRedisClient, RedisData>, Action<RedisData>, Action<Exception>)

View Source
Declaration
public void QueueCommand(Func<IRedisClient, RedisData> command, Action<RedisData> onSuccessCallback, Action<Exception> onErrorCallback)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,ServiceStack.Redis.RedisData>command
System.Action<ServiceStack.Redis.RedisData>onSuccessCallback
System.Action<System.Exception>onErrorCallback

QueueCommand(Func<IRedisClient, RedisText>)

View Source
Declaration
public void QueueCommand(Func<IRedisClient, RedisText> command)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,ServiceStack.Redis.RedisText>command

QueueCommand(Func<IRedisClient, RedisText>, Action<RedisText>)

View Source
Declaration
public void QueueCommand(Func<IRedisClient, RedisText> command, Action<RedisText> onSuccessCallback)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,ServiceStack.Redis.RedisText>command
System.Action<ServiceStack.Redis.RedisText>onSuccessCallback

QueueCommand(Func<IRedisClient, RedisText>, Action<RedisText>, Action<Exception>)

View Source
Declaration
public void QueueCommand(Func<IRedisClient, RedisText> command, Action<RedisText> onSuccessCallback, Action<Exception> onErrorCallback)
Parameters
TypeName
System.Func<ServiceStack.Redis.IRedisClient,ServiceStack.Redis.RedisText>command
System.Action<ServiceStack.Redis.RedisText>onSuccessCallback
System.Action<System.Exception>onErrorCallback

Inherited Methods

AddCurrentQueuedOperation()

View Source
Declaration
protected virtual void AddCurrentQueuedOperation()

CompleteBytesQueuedCommand(Func<Byte[]>)

View Source
Declaration
public virtual void CompleteBytesQueuedCommand(Func<byte[]> bytesReadCommand)
Parameters
TypeName
System.Func<System.Byte[]>bytesReadCommand

CompleteDoubleQueuedCommand(Func<Double>)

View Source
Declaration
public virtual void CompleteDoubleQueuedCommand(Func<double> doubleReadCommand)
Parameters
TypeName
System.Func<System.Double>doubleReadCommand

CompleteIntQueuedCommand(Func<Int32>)

View Source
Declaration
public virtual void CompleteIntQueuedCommand(Func<int> intReadCommand)
Parameters
TypeName
System.Func<System.Int32>intReadCommand

CompleteLongQueuedCommand(Func<Int64>)

View Source
Declaration
public virtual void CompleteLongQueuedCommand(Func<long> longReadCommand)
Parameters
TypeName
System.Func<System.Int64>longReadCommand

CompleteMultiBytesQueuedCommand(Func<Byte[][]>)

View Source
Declaration
public virtual void CompleteMultiBytesQueuedCommand(Func<byte[][]> multiBytesReadCommand)
Parameters
TypeName
System.Func<System.Byte[][]>multiBytesReadCommand

CompleteMultiStringQueuedCommand(Func<List<String>>)

View Source
Declaration
public virtual void CompleteMultiStringQueuedCommand(Func<List<string>> multiStringReadCommand)
Parameters
TypeName
System.Func<System.Collections.Generic.List<System.String>>multiStringReadCommand

CompleteRedisDataQueuedCommand(Func<RedisData>)

View Source
Declaration
public virtual void CompleteRedisDataQueuedCommand(Func<RedisData> redisDataReadCommand)
Parameters
TypeName
System.Func<ServiceStack.Redis.RedisData>redisDataReadCommand

CompleteStringQueuedCommand(Func<String>)

View Source
Declaration
public virtual void CompleteStringQueuedCommand(Func<string> stringReadCommand)
Parameters
TypeName
System.Func<System.String>stringReadCommand

CompleteVoidQueuedCommand(Action)

View Source
Declaration
public virtual void CompleteVoidQueuedCommand(Action voidReadCommand)
Parameters
TypeName
System.ActionvoidReadCommand