De Redis Transactions-interface geïmplementeerd door ServiceStack's C# Redis Client.
Introductie #
De transactie-interface van Redis biedt handige overbelastingen waarmee u elke IRedisTypedClient-bewerking in een enkele transactie in de wachtrij kunt plaatsen. De API biedt ondersteuning voor een callback, zodat u ook toegang heeft tot retourwaarden die als onderdeel van de transactie worden geretourneerd.
Gebruik #
Hieronder ziet u een eenvoudig voorbeeld dat laat zien hoe u toegang krijgt tot de transactie, deze gebruikt en vastlegt.
var typedClient = Redis.GetTypedClient<MyPocoType>();
using (var trans = typedClient.CreateTransaction())
{
trans.QueueCommand(r => r.Set("nosqldbs", new MyPocoType {Id = 1, Name = "Redis"));
trans.Commit();
}
Voor een transactie die werkt op tekenreekswaarden, zie IRedisTransaction.
Details #
public interface IRedisTypedTransaction<T>
: IDisposable
{
void QueueCommand(Action<IRedisTypedClient<T>> command);
void QueueCommand(Action<IRedisTypedClient<T>> command, Action onSuccessCallback);
void QueueCommand(Action<IRedisTypedClient<T>> command, Action onSuccessCallback, Action<Exception> onErrorCallback);
void QueueCommand(Func<IRedisTypedClient<T>, int> command);
void QueueCommand(Func<IRedisTypedClient<T>, int> command, Action<int> onSuccessCallback);
void QueueCommand(Func<IRedisTypedClient<T>, int> command, Action<int> onSuccessCallback, Action<Exception> onErrorCallback);
void QueueCommand(Func<IRedisTypedClient<T>, bool> command);
void QueueCommand(Func<IRedisTypedClient<T>, bool> command, Action<bool> onSuccessCallback);
void QueueCommand(Func<IRedisTypedClient<T>, bool> command, Action<bool> onSuccessCallback, Action<Exception> onErrorCallback);
void QueueCommand(Func<IRedisTypedClient<T>, double> command);
void QueueCommand(Func<IRedisTypedClient<T>, double> command, Action<double> onSuccessCallback);
void QueueCommand(Func<IRedisTypedClient<T>, double> command, Action<double> onSuccessCallback, Action<Exception> onErrorCallback);
void QueueCommand(Func<IRedisTypedClient<T>, byte[]> command);
void QueueCommand(Func<IRedisTypedClient<T>, byte[]> command, Action<byte[]> onSuccessCallback);
void QueueCommand(Func<IRedisTypedClient<T>, byte[]> command, Action<byte[]> onSuccessCallback, Action<Exception> onErrorCallback);
void QueueCommand(Func<IRedisTypedClient<T>, string> command);
void QueueCommand(Func<IRedisTypedClient<T>, string> command, Action<string> onSuccessCallback);
void QueueCommand(Func<IRedisTypedClient<T>, string> command, Action<string> onSuccessCallback, Action<Exception> onErrorCallback);
void QueueCommand(Func<IRedisTypedClient<T>, T> command);
void QueueCommand(Func<IRedisTypedClient<T>, T> command, Action<T> onSuccessCallback);
void QueueCommand(Func<IRedisTypedClient<T>, T> command, Action<T> onSuccessCallback, Action<Exception> onErrorCallback);
void QueueCommand(Func<IRedisTypedClient<T>, List<string>> command);
void QueueCommand(Func<IRedisTypedClient<T>, List<string>> command, Action<List<string>> onSuccessCallback);
void QueueCommand(Func<IRedisTypedClient<T>, List<string>> command, Action<List<string>> onSuccessCallback, Action<Exception> onErrorCallback);
void QueueCommand(Func<IRedisTypedClient<T>, List<T>> command);
void QueueCommand(Func<IRedisTypedClient<T>, List<T>> command, Action<List<T>> onSuccessCallback);
void QueueCommand(Func<IRedisTypedClient<T>, List<T>> command, Action<List<T>> onSuccessCallback, Action<Exception> onErrorCallback);
void Commit();
void Rollback();
}