Class LockableRepositoryCollectionBase<TEntity>

Namespace

Tharga.MongoDB.Lockable

Assembly

Tharga.MongoDB.dll

public class LockableRepositoryCollectionBase<TEntity> : LockableRepositoryCollectionBase<TEntity, ObjectId>, ILockableRepositoryCollection<TEntity, ObjectId>, IRepositoryCollection<TEntity, ObjectId>, IReadOnlyRepositoryCollection<TEntity, ObjectId>, IRepositoryCollection, IReadOnlyRepositoryCollection where TEntity : LockableEntityBase

Type Parameters

TEntity

Inheritance

object

RepositoryCollectionBase

RepositoryCollectionBase<TEntity, ObjectId>

LockableRepositoryCollectionBase<TEntity, ObjectId>

LockableRepositoryCollectionBase<TEntity>

Implements

ILockableRepositoryCollection<TEntity, ObjectId>

IRepositoryCollection<TEntity, ObjectId>

IReadOnlyRepositoryCollection<TEntity, ObjectId>

IRepositoryCollection

IReadOnlyRepositoryCollection

Inherited Members

LockableRepositoryCollectionBase<TEntity, ObjectId>.LockEvent

LockableRepositoryCollectionBase<TEntity, ObjectId>.CoreIndices

LockableRepositoryCollectionBase<TEntity, ObjectId>.DefaultTimeout

LockableRepositoryCollectionBase<TEntity, ObjectId>.RequireActor

LockableRepositoryCollectionBase<TEntity, ObjectId>.AllowDelayedCommit

LockableRepositoryCollectionBase<TEntity, ObjectId>.GetAsync(Expression<Func<TEntity, bool>>, Options<TEntity>, CancellationToken)

LockableRepositoryCollectionBase<TEntity, ObjectId>.GetAsync(FilterDefinition<TEntity>, Options<TEntity>, CancellationToken)

LockableRepositoryCollectionBase<TEntity, ObjectId>.GetProjectionAsync<T>(Expression<Func<TEntity, bool>>, Options<TEntity>, CancellationToken)

LockableRepositoryCollectionBase<TEntity, ObjectId>.GetProjectionAsync<T>(FilterDefinition<TEntity>, Options<TEntity>, CancellationToken)

LockableRepositoryCollectionBase<TEntity, ObjectId>.GetManyAsync(Expression<Func<TEntity, bool>>, Options<TEntity>, CancellationToken)

LockableRepositoryCollectionBase<TEntity, ObjectId>.GetManyAsync(FilterDefinition<TEntity>, Options<TEntity>, CancellationToken)

LockableRepositoryCollectionBase<TEntity, ObjectId>.GetManyProjectionAsync<T>(Expression<Func<TEntity, bool>>, Options<TEntity>, CancellationToken)

LockableRepositoryCollectionBase<TEntity, ObjectId>.GetManyProjectionAsync<T>(FilterDefinition<TEntity>, Options<TEntity>, CancellationToken)

LockableRepositoryCollectionBase<TEntity, ObjectId>.GetOneAsync(ObjectId, CancellationToken)

LockableRepositoryCollectionBase<TEntity, ObjectId>.GetOneAsync(Expression<Func<TEntity, bool>>, OneOption<TEntity>, CancellationToken)

LockableRepositoryCollectionBase<TEntity, ObjectId>.GetOneAsync(FilterDefinition<TEntity>, OneOption<TEntity>, CancellationToken)

LockableRepositoryCollectionBase<TEntity, ObjectId>.CountAsync(Expression<Func<TEntity, bool>>, CancellationToken)

LockableRepositoryCollectionBase<TEntity, ObjectId>.CountAsync(FilterDefinition<TEntity>, CancellationToken)

LockableRepositoryCollectionBase<TEntity, ObjectId>.EstimatedCountAsync(CancellationToken)

LockableRepositoryCollectionBase<TEntity, ObjectId>.SumAsync(Expression<Func<TEntity, decimal>>, Expression<Func<TEntity, bool>>, CancellationToken)

LockableRepositoryCollectionBase<TEntity, ObjectId>.AvgAsync(Expression<Func<TEntity, decimal>>, Expression<Func<TEntity, bool>>, CancellationToken)

LockableRepositoryCollectionBase<TEntity, ObjectId>.MinAsync<TField>(Expression<Func<TEntity, TField>>, Expression<Func<TEntity, bool>>, CancellationToken)

LockableRepositoryCollectionBase<TEntity, ObjectId>.MaxAsync<TField>(Expression<Func<TEntity, TField>>, Expression<Func<TEntity, bool>>, CancellationToken)

LockableRepositoryCollectionBase<TEntity, ObjectId>.GetSizeAsync(CancellationToken)

LockableRepositoryCollectionBase<TEntity, ObjectId>.GetPageAsync(int, PagePosition, Expression<Func<TEntity, bool>>, Expression<Func<TEntity, object>>, bool, CancellationToken)

LockableRepositoryCollectionBase<TEntity, ObjectId>.GetPageProjectionAsync<T>(int, PagePosition, Expression<Func<TEntity, T>>, Expression<Func<TEntity, bool>>, Expression<Func<TEntity, object>>, bool, CancellationToken)

LockableRepositoryCollectionBase<TEntity, ObjectId>.AddAsync(TEntity, IClientSessionHandle)

LockableRepositoryCollectionBase<TEntity, ObjectId>.TryAddAsync(TEntity, IClientSessionHandle)

LockableRepositoryCollectionBase<TEntity, ObjectId>.AddManyAsync(IEnumerable<TEntity>, IClientSessionHandle)

LockableRepositoryCollectionBase<TEntity, ObjectId>.UpdateUnlockedAsync(Expression<Func<TEntity, bool>>, UpdateDefinition<TEntity>)

LockableRepositoryCollectionBase<TEntity, ObjectId>.UpdateUnlockedAsync(FilterDefinition<TEntity>, UpdateDefinition<TEntity>)

LockableRepositoryCollectionBase<TEntity, ObjectId>.DeleteOneAsync(ObjectId, IClientSessionHandle)

LockableRepositoryCollectionBase<TEntity, ObjectId>.DeleteOneUnlockedAsync(Expression<Func<TEntity, bool>>, OneOption<TEntity>)

LockableRepositoryCollectionBase<TEntity, ObjectId>.DeleteOneUnlockedAsync(FilterDefinition<TEntity>, OneOption<TEntity>)

LockableRepositoryCollectionBase<TEntity, ObjectId>.DeleteManyUnlockedAsync(Expression<Func<TEntity, bool>>)

LockableRepositoryCollectionBase<TEntity, ObjectId>.DeleteManyUnlockedAsync(FilterDefinition<TEntity>)

LockableRepositoryCollectionBase<TEntity, ObjectId>.DeleteManyAsync(DeleteMode, Expression<Func<TEntity, bool>>)

LockableRepositoryCollectionBase<TEntity, ObjectId>.DropCollectionAsync()

LockableRepositoryCollectionBase<TEntity, ObjectId>.ExecuteAsync<T>(Func<IMongoCollection<TEntity>, Task<T>>, Operation)

LockableRepositoryCollectionBase<TEntity, ObjectId>.ExecuteAsync<T>(Func<IMongoCollection<TEntity>, CancellationToken, Task<T>>, Operation, CancellationToken)

LockableRepositoryCollectionBase<TEntity, ObjectId>.ExecuteManyAsync<T>(Func<IMongoCollection<TEntity>, CancellationToken, Task<IAsyncCursor<T>>>, CancellationToken)

LockableRepositoryCollectionBase<TEntity, ObjectId>.GetDirtyAsync()

LockableRepositoryCollectionBase<TEntity, ObjectId>.GetFailedIndices()

LockableRepositoryCollectionBase<TEntity, ObjectId>.UnlockedOrExpiredFilter

LockableRepositoryCollectionBase<TEntity, ObjectId>.LockedOrExceptionFilter

LockableRepositoryCollectionBase<TEntity, ObjectId>.ExceptionFilter

LockableRepositoryCollectionBase<TEntity, ObjectId>.LockedFilter

LockableRepositoryCollectionBase<TEntity, ObjectId>.GetUnlockedAsync(Expression<Func<TEntity, bool>>, Options<TEntity>, CancellationToken)

LockableRepositoryCollectionBase<TEntity, ObjectId>.GetUnlockedAsync(FilterDefinition<TEntity>, Options<TEntity>, CancellationToken)

LockableRepositoryCollectionBase<TEntity, ObjectId>.PickForUpdateAsync(ObjectId, TimeSpan?, string, Func<CallbackResult<TEntity>, Task>, IClientSessionHandle)

LockableRepositoryCollectionBase<TEntity, ObjectId>.PickForUpdateAsync(FilterDefinition<TEntity>, TimeSpan?, string, Func<CallbackResult<TEntity>, Task>, IClientSessionHandle)

LockableRepositoryCollectionBase<TEntity, ObjectId>.PickForUpdateAsync(Expression<Func<TEntity, bool>>, TimeSpan?, string, Func<CallbackResult<TEntity>, Task>, IClientSessionHandle)

LockableRepositoryCollectionBase<TEntity, ObjectId>.PickForDeleteAsync(ObjectId, TimeSpan?, string, Func<CallbackResult<TEntity>, Task>, IClientSessionHandle)

LockableRepositoryCollectionBase<TEntity, ObjectId>.PickForDeleteAsync(FilterDefinition<TEntity>, TimeSpan?, string, Func<CallbackResult<TEntity>, Task>, IClientSessionHandle)

LockableRepositoryCollectionBase<TEntity, ObjectId>.PickForDeleteAsync(Expression<Func<TEntity, bool>>, TimeSpan?, string, Func<CallbackResult<TEntity>, Task>, IClientSessionHandle)

LockableRepositoryCollectionBase<TEntity, ObjectId>.WaitForUpdateAsync(ObjectId, TimeSpan?, TimeSpan?, string, Func<CallbackResult<TEntity>, Task>, CancellationToken)

LockableRepositoryCollectionBase<TEntity, ObjectId>.WaitForDeleteAsync(ObjectId, TimeSpan?, TimeSpan?, string, Func<CallbackResult<TEntity>, Task>, CancellationToken)

LockableRepositoryCollectionBase<TEntity, ObjectId>.LockAsync(ObjectId, TimeSpan?, string, Func<CallbackResult<TEntity>, Task>, IClientSessionHandle)

LockableRepositoryCollectionBase<TEntity, ObjectId>.LockAsync(FilterDefinition<TEntity>, TimeSpan?, string, Func<CallbackResult<TEntity>, Task>, IClientSessionHandle)

LockableRepositoryCollectionBase<TEntity, ObjectId>.LockAsync(Expression<Func<TEntity, bool>>, TimeSpan?, string, Func<CallbackResult<TEntity>, Task>, IClientSessionHandle)

LockableRepositoryCollectionBase<TEntity, ObjectId>.LockManyAsync(IEnumerable<ObjectId>, TimeSpan?, string, CancellationToken, IClientSessionHandle)

LockableRepositoryCollectionBase<TEntity, ObjectId>.LockManyAsync(FilterDefinition<TEntity>, TimeSpan?, string, CancellationToken, IClientSessionHandle)

LockableRepositoryCollectionBase<TEntity, ObjectId>.LockManyAsync(Expression<Func<TEntity, bool>>, TimeSpan?, string, CancellationToken, IClientSessionHandle)

LockableRepositoryCollectionBase<TEntity, ObjectId>.GetWithLockInfoAsync(FilterDefinition<TEntity>, Options<TEntity>, CancellationToken)

LockableRepositoryCollectionBase<TEntity, ObjectId>.GetLockedAsync(LockMode, FilterDefinition<TEntity>, Options<TEntity>, CancellationToken)

LockableRepositoryCollectionBase<TEntity, ObjectId>.GetExpiredAsync(FilterDefinition<TEntity>, Options<TEntity>, CancellationToken)

LockableRepositoryCollectionBase<TEntity, ObjectId>.ReleaseOneAsync(ObjectId, ReleaseMode)

LockableRepositoryCollectionBase<TEntity, ObjectId>.ReleaseManyAsync(ReleaseMode)

RepositoryCollectionBase<TEntity, ObjectId>._mongoDbServiceFactory

RepositoryCollectionBase<TEntity, ObjectId>._logger

RepositoryCollectionBase<TEntity, ObjectId>._databaseContext

RepositoryCollectionBase<TEntity, ObjectId>._mongoDbService

RepositoryCollectionBase<TEntity, ObjectId>.ProtectedCollectionName

RepositoryCollectionBase<TEntity, ObjectId>.CollectionName

RepositoryCollectionBase<TEntity, ObjectId>.DatabasePart

RepositoryCollectionBase<TEntity, ObjectId>.ConfigurationName

RepositoryCollectionBase<TEntity, ObjectId>.AutoClean

RepositoryCollectionBase<TEntity, ObjectId>.CleanOnStartup

RepositoryCollectionBase<TEntity, ObjectId>.CreateCollectionStrategy

RepositoryCollectionBase<TEntity, ObjectId>.FetchSize

RepositoryCollectionBase<TEntity, ObjectId>.Indices

RepositoryCollectionBase<TEntity, ObjectId>.CoreIndices

RepositoryCollectionBase<TEntity, ObjectId>.Types

RepositoryCollectionBase<TEntity, ObjectId>.GetAsync(Expression<Func<TEntity, bool>>, Options<TEntity>, CancellationToken)

RepositoryCollectionBase<TEntity, ObjectId>.GetAsync(FilterDefinition<TEntity>, Options<TEntity>, CancellationToken)

RepositoryCollectionBase<TEntity, ObjectId>.GetProjectionAsync<T>(Expression<Func<TEntity, bool>>, Options<TEntity>, CancellationToken)

RepositoryCollectionBase<TEntity, ObjectId>.GetProjectionAsync<T>(FilterDefinition<TEntity>, Options<TEntity>, CancellationToken)

RepositoryCollectionBase<TEntity, ObjectId>.GetManyAsync(Expression<Func<TEntity, bool>>, Options<TEntity>, CancellationToken)

RepositoryCollectionBase<TEntity, ObjectId>.GetManyAsync(FilterDefinition<TEntity>, Options<TEntity>, CancellationToken)

RepositoryCollectionBase<TEntity, ObjectId>.GetManyProjectionAsync<T>(Expression<Func<TEntity, bool>>, Options<TEntity>, CancellationToken)

RepositoryCollectionBase<TEntity, ObjectId>.GetManyProjectionAsync<T>(FilterDefinition<TEntity>, Options<TEntity>, CancellationToken)

RepositoryCollectionBase<TEntity, ObjectId>.GetOneAsync(ObjectId, CancellationToken)

RepositoryCollectionBase<TEntity, ObjectId>.GetOneAsync(Expression<Func<TEntity, bool>>, OneOption<TEntity>, CancellationToken)

RepositoryCollectionBase<TEntity, ObjectId>.GetOneAsync(FilterDefinition<TEntity>, OneOption<TEntity>, CancellationToken)

RepositoryCollectionBase<TEntity, ObjectId>.CountAsync(Expression<Func<TEntity, bool>>, CancellationToken)

RepositoryCollectionBase<TEntity, ObjectId>.CountAsync(FilterDefinition<TEntity>, CancellationToken)

RepositoryCollectionBase<TEntity, ObjectId>.EstimatedCountAsync(CancellationToken)

RepositoryCollectionBase<TEntity, ObjectId>.SumAsync(Expression<Func<TEntity, decimal>>, Expression<Func<TEntity, bool>>, CancellationToken)

RepositoryCollectionBase<TEntity, ObjectId>.AvgAsync(Expression<Func<TEntity, decimal>>, Expression<Func<TEntity, bool>>, CancellationToken)

RepositoryCollectionBase<TEntity, ObjectId>.MinAsync<TField>(Expression<Func<TEntity, TField>>, Expression<Func<TEntity, bool>>, CancellationToken)

RepositoryCollectionBase<TEntity, ObjectId>.MaxAsync<TField>(Expression<Func<TEntity, TField>>, Expression<Func<TEntity, bool>>, CancellationToken)

RepositoryCollectionBase<TEntity, ObjectId>.GetSizeAsync(CancellationToken)

RepositoryCollectionBase<TEntity, ObjectId>.GetPageAsync(int, PagePosition, Expression<Func<TEntity, bool>>, Expression<Func<TEntity, object>>, bool, CancellationToken)

RepositoryCollectionBase<TEntity, ObjectId>.GetPageProjectionAsync<T>(int, PagePosition, Expression<Func<TEntity, T>>, Expression<Func<TEntity, bool>>, Expression<Func<TEntity, object>>, bool, CancellationToken)

RepositoryCollectionBase<TEntity, ObjectId>.AddAsync(TEntity, IClientSessionHandle)

RepositoryCollectionBase<TEntity, ObjectId>.TryAddAsync(TEntity, IClientSessionHandle)

RepositoryCollectionBase<TEntity, ObjectId>.AddManyAsync(IEnumerable<TEntity>, IClientSessionHandle)

RepositoryCollectionBase<TEntity, ObjectId>.DeleteOneAsync(ObjectId, IClientSessionHandle)

RepositoryCollectionBase<TEntity, ObjectId>.DropCollectionAsync()

RepositoryCollectionBase<TEntity, ObjectId>.ExecuteAsync<T>(Func<IMongoCollection<TEntity>, Task<T>>, Operation)

RepositoryCollectionBase<TEntity, ObjectId>.ExecuteAsync<T>(Func<IMongoCollection<TEntity>, CancellationToken, Task<T>>, Operation, CancellationToken)

RepositoryCollectionBase<TEntity, ObjectId>.ExecuteManyAsync<T>(Func<IMongoCollection<TEntity>, CancellationToken, Task<IAsyncCursor<T>>>, CancellationToken)

RepositoryCollectionBase<TEntity, ObjectId>.GetDirtyAsync()

RepositoryCollectionBase<TEntity, ObjectId>.GetFailedIndices()

RepositoryCollectionBase<TEntity, ObjectId>.InitAsync(IMongoCollection<TEntity>)

RepositoryCollectionBase.ActionEvent

RepositoryCollectionBase.CollectionName

RepositoryCollectionBase.ConfigurationName

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

LockableRepositoryCollectionBase(IMongoDbServiceFactory, ILogger, DatabaseContext)

protected LockableRepositoryCollectionBase(IMongoDbServiceFactory mongoDbServiceFactory, ILogger logger = null, DatabaseContext databaseContext = null)

Parameters

mongoDbServiceFactory IMongoDbServiceFactory

logger ILogger

databaseContext DatabaseContext