/
vshmidt
/
masstransit
Обзор
Документация
Войти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
develop
src/Persistence/MassTransit.MongoDbIntegration/MongoDbIntegration/MongoDbCollectionContext.cs
24 строки
976 B
Chris Patterson
Fixed outbox to ensure a session is available, and a transaction is started if an existing transaction is not already in progress.
30 июн 2022, 22:54
30 июн 2022, 22:54
3440e2d
Код
Авторство
О чём код?
#nullable enable namespace MassTransit.MongoDbIntegration { using System.Threading; using System.Threading.Tasks; using MongoDB.Driver; /// <summary> /// Encapsulates <see cref="IMongoCollection{T}" /> so that it can be including an existing session/transaction /// </summary> /// <typeparam name="T"></typeparam> public interface MongoDbCollectionContext<T> { Task InsertOne(T instance, CancellationToken cancellationToken); Task<T> FindOneAndReplace(FilterDefinition<T> filter, T instance, CancellationToken cancellationToken); Task<DeleteResult> DeleteOne(FilterDefinition<T> filter, CancellationToken cancellationToken); Task<DeleteResult> DeleteMany(FilterDefinition<T> filter, CancellationToken cancellationToken); Task<T> Lock(FilterDefinition<T> filter, UpdateDefinition<T> update, CancellationToken cancellationToken); IFindFluent<T, T> Find(FilterDefinition<T> filter); } }