Class UserRepositoryCollection<TUserEntity>

Namespace

Tharga.Team.MongoDB

Assembly

Tharga.Team.MongoDB.dll

MongoDB collection definition for User documents. Public so consumers can subclass it to declare per-deployment indices on their own TUserEntity shape. Register the subclass via RegisterUserRepository<TUserEntity, TCollection>().

public class UserRepositoryCollection<TUserEntity> : DiskRepositoryCollectionBase<TUserEntity>, IUserRepositoryCollection<TUserEntity>, IDiskRepositoryCollection<TUserEntity>, IDiskRepositoryCollection<TUserEntity, ObjectId>, IRepositoryCollection<TUserEntity, ObjectId>, IReadOnlyRepositoryCollection<TUserEntity, ObjectId>, IRepositoryCollection, IReadOnlyRepositoryCollection where TUserEntity : EntityBase, IUser

Type Parameters

TUserEntity

Inheritance

object

RepositoryCollectionBase

RepositoryCollectionBase<TUserEntity, ObjectId>

DiskRepositoryCollectionBase<TUserEntity, ObjectId>

DiskRepositoryCollectionBase<TUserEntity>

UserRepositoryCollection<TUserEntity>

Implements

IUserRepositoryCollection<TUserEntity>

IDiskRepositoryCollection<TUserEntity>

IDiskRepositoryCollection<TUserEntity, ObjectId>

IRepositoryCollection<TUserEntity, ObjectId>

IReadOnlyRepositoryCollection<TUserEntity, ObjectId>

IRepositoryCollection

IReadOnlyRepositoryCollection

Inherited Members

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.ExecuteAsync<T>(string, Func<IMongoCollection<TUserEntity>, IClientSessionHandle, CancellationToken, Task<(T Data, int Count)>>, Operation, CancellationToken, FilterDefinition<TUserEntity>, IClientSessionHandle)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.GetAsync(Expression<Func<TUserEntity, bool>>, Options<TUserEntity>, CancellationToken)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.GetAsync(FilterDefinition<TUserEntity>, Options<TUserEntity>, CancellationToken)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.GetProjectionAsync<T>(Expression<Func<TUserEntity, bool>>, Options<TUserEntity>, CancellationToken)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.GetProjectionAsync<T>(FilterDefinition<TUserEntity>, Options<TUserEntity>, CancellationToken)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.QueryAsync(Expression<Func<TUserEntity, bool>>, Options<TUserEntity>, CancellationToken)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.GetManyAsync(Expression<Func<TUserEntity, bool>>, Options<TUserEntity>, CancellationToken)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.QueryAsync(FilterDefinition<TUserEntity>, Options<TUserEntity>, CancellationToken)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.GetManyAsync(FilterDefinition<TUserEntity>, Options<TUserEntity>, CancellationToken)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.GetManyProjectionAsync<T>(Expression<Func<TUserEntity, bool>>, Options<TUserEntity>, CancellationToken)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.GetManyProjectionAsync<T>(FilterDefinition<TUserEntity>, Options<TUserEntity>, CancellationToken)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.GetOneAsync(ObjectId, CancellationToken)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.GetOneAsync(Expression<Func<TUserEntity, bool>>, OneOption<TUserEntity>, CancellationToken)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.GetOneAsync(FilterDefinition<TUserEntity>, OneOption<TUserEntity>, CancellationToken)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.CountAsync(Expression<Func<TUserEntity, bool>>, CancellationToken)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.CountAsync(FilterDefinition<TUserEntity>, CancellationToken)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.EstimatedCountAsync(CancellationToken)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.SumAsync(Expression<Func<TUserEntity, decimal>>, Expression<Func<TUserEntity, bool>>, CancellationToken)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.AvgAsync(Expression<Func<TUserEntity, decimal>>, Expression<Func<TUserEntity, bool>>, CancellationToken)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.MinAsync<TField>(Expression<Func<TUserEntity, TField>>, Expression<Func<TUserEntity, bool>>, CancellationToken)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.MaxAsync<TField>(Expression<Func<TUserEntity, TField>>, Expression<Func<TUserEntity, bool>>, CancellationToken)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.GetSizeAsync(CancellationToken)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.GetPageAsync(int, PagePosition, Expression<Func<TUserEntity, bool>>, Expression<Func<TUserEntity, object>>, bool, CancellationToken)

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

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.AddAsync(TUserEntity, IClientSessionHandle)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.TryAddAsync(TUserEntity, IClientSessionHandle)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.AddManyAsync(IEnumerable<TUserEntity>, IClientSessionHandle)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.AddOrReplaceAsync(TUserEntity, IClientSessionHandle)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.ReplaceOneAsync(TUserEntity, OneOption<TUserEntity>, IClientSessionHandle)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.ReplaceOneAsync(TUserEntity, FilterDefinition<TUserEntity>, OneOption<TUserEntity>, IClientSessionHandle)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.UpdateOneAsync(ObjectId, UpdateDefinition<TUserEntity>, IClientSessionHandle)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.UpdateOneAsync(Expression<Func<TUserEntity, bool>>, UpdateDefinition<TUserEntity>, OneOption<TUserEntity>, IClientSessionHandle)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.UpdateOneAsync(FilterDefinition<TUserEntity>, UpdateDefinition<TUserEntity>, OneOption<TUserEntity>, IClientSessionHandle)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.UpdateManyAsync(Expression<Func<TUserEntity, bool>>, UpdateDefinition<TUserEntity>, IClientSessionHandle)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.UpdateManyAsync(FilterDefinition<TUserEntity>, UpdateDefinition<TUserEntity>, IClientSessionHandle)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.DeleteOneAsync(ObjectId, IClientSessionHandle)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.DeleteOneAsync(Expression<Func<TUserEntity, bool>>, OneOption<TUserEntity>, IClientSessionHandle)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.DeleteOneAsync(FilterDefinition<TUserEntity>, OneOption<TUserEntity>, IClientSessionHandle)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.DeleteManyAsync(Expression<Func<TUserEntity, bool>>, IClientSessionHandle)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.DeleteManyAsync(FilterDefinition<TUserEntity>, IClientSessionHandle)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.GetCollection()

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.ExecuteAsync<T>(Func<IMongoCollection<TUserEntity>, Task<T>>, Operation)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.ExecuteAsync<T>(Func<IMongoCollection<TUserEntity>, CancellationToken, Task<T>>, Operation, CancellationToken)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.ExecuteManyAsync<T>(Func<IMongoCollection<TUserEntity>, CancellationToken, Task<IAsyncCursor<T>>>, CancellationToken)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.DropCollectionAsync()

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.GetDirtyAsync()

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.GetFailedIndices()

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.DropEmptyAsync(IMongoCollection<TUserEntity>)

DiskRepositoryCollectionBase<TUserEntity, ObjectId>.FetchSize

RepositoryCollectionBase<TUserEntity, ObjectId>._mongoDbServiceFactory

RepositoryCollectionBase<TUserEntity, ObjectId>._logger

RepositoryCollectionBase<TUserEntity, ObjectId>._databaseContext

RepositoryCollectionBase<TUserEntity, ObjectId>._mongoDbService

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

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

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

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

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

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

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

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

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

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

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

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

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

RepositoryCollectionBase<TUserEntity, ObjectId>.EstimatedCountAsync(CancellationToken)

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

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

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

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

RepositoryCollectionBase<TUserEntity, ObjectId>.GetSizeAsync(CancellationToken)

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

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

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

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

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

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

RepositoryCollectionBase<TUserEntity, ObjectId>.DropCollectionAsync()

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

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

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

RepositoryCollectionBase<TUserEntity, ObjectId>.GetDirtyAsync()

RepositoryCollectionBase<TUserEntity, ObjectId>.GetFailedIndices()

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

RepositoryCollectionBase<TUserEntity, ObjectId>.ProtectedCollectionName

RepositoryCollectionBase<TUserEntity, ObjectId>.CollectionName

RepositoryCollectionBase<TUserEntity, ObjectId>.DatabasePart

RepositoryCollectionBase<TUserEntity, ObjectId>.ConfigurationName

RepositoryCollectionBase<TUserEntity, ObjectId>.AutoClean

RepositoryCollectionBase<TUserEntity, ObjectId>.CleanOnStartup

RepositoryCollectionBase<TUserEntity, ObjectId>.CreateCollectionStrategy

RepositoryCollectionBase<TUserEntity, ObjectId>.FetchSize

RepositoryCollectionBase<TUserEntity, ObjectId>.Indices

RepositoryCollectionBase<TUserEntity, ObjectId>.CoreIndices

RepositoryCollectionBase<TUserEntity, ObjectId>.Types

RepositoryCollectionBase.ConfigurationName

RepositoryCollectionBase.ActionEvent

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

UserRepositoryCollection(IMongoDbServiceFactory, ILogger<UserRepositoryCollection<TUserEntity>>, IOptions<ThargaTeamOptions>)

public UserRepositoryCollection(IMongoDbServiceFactory mongoDbServiceFactory, ILogger<UserRepositoryCollection<TUserEntity>> logger, IOptions<ThargaTeamOptions> options = null)

Parameters

mongoDbServiceFactory IMongoDbServiceFactory

logger ILogger<UserRepositoryCollection<TUserEntity>>

options IOptions<ThargaTeamOptions>

Properties

CollectionName

public override string CollectionName { get; }

Property Value

string

Indices

public override IEnumerable<CreateIndexModel<TUserEntity>> Indices { get; }

Property Value

IEnumerable<CreateIndexModel<TUserEntity>>