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