Skip to main content

RedisAllPurposePipeline

Assembly: ServiceStack.Redis.dll​
View Source​
Declaration
public class RedisAllPurposePipeline : RedisCommandQueue, IRedisPipelineAsync, IRedisPipelineSharedAsync, IRedisQueueCompletableOperationAsync, IRedisQueueableOperationAsync, IRedisPipeline, IRedisPipelineShared, IDisposable, IRedisQueueCompletableOperation, IRedisQueueableOperation

Methods​

ExecuteAsync()​

View Source​
Declaration
protected async ValueTask ExecuteAsync()
Returns​

ValueTask

Init()​

View Source​
Declaration
protected virtual void Init()

Flush()​

Flush send buffer, and read responses

View Source​
Declaration
public void Flush()

Execute()​

View Source​
Declaration
protected void Execute()

Replay()​

View Source​
Declaration
public virtual bool Replay()
Returns​

System.Boolean

ClosePipeline()​

View Source​
Declaration
protected void ClosePipeline()

Dispose()​

View Source​
Declaration
public virtual void Dispose()

Inherited 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, 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

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, 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, 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, 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, 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, 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, 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, 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, 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

Implements​