API Diff between 20.26.0 and 8.4.0
461 Additions
126 Removals
MongoDB.Entities
-
public class AsObjectIdAttribute : BsonSerializerAttribute
-
public sealed delegate AsyncEventHandler<TEventArgs> : MulticastDelegate
-
public static class AsyncEventHandlerExtensions
-
public class CollectionAttribute : Attribute
-
public class Coordinates2D
-
public class DatabaseAttribute : Attribute
-
public class DataStreamer
- public Task DeleteBinaryChunks(IClientSessionHandle session = null, CancellationToken cancellation = default)
- public Task DownloadAsync(Stream stream, int batchSize = 1, CancellationToken cancellation = default, IClientSessionHandle session = null)
- public Task DownloadWithTimeoutAsync(Stream stream, int timeOutSeconds, int batchSize = 1, IClientSessionHandle session = null)
- public Task UploadAsync(Stream stream, int chunkSizeKB = 256, CancellationToken cancellation = default, IClientSessionHandle session = null)
- public Task UploadWithTimeoutAsync(Stream stream, int timeOutSeconds, int chunkSizeKB = 256, IClientSessionHandle session = null)
-
public class Date
-
public static class DB
- public string DbName { get; }
- public DB(string database, string host = "127.0.0.1", int port = 27017)
- public DB(MongoClientSettings settings, string database)
- public static IMongoCollection<T> Collection<T>(string db = null)
- public static void Delete<T>(string ID, IClientSessionHandle session = null, string db = null) where T : Entity
- public static void Delete<T>(Expression<Func<T, bool>> expression, IClientSessionHandle session = null, string db = null) where T : Entity
- public static void Delete<T>(IEnumerable<string> IDs, IClientSessionHandle session = null, string db = null) where T : Entity
- public static Task DeleteAsync<T>(string ID, IClientSessionHandle session = null, string db = null) where T : Entity
- public static Task DeleteAsync<T>(Expression<Func<T, bool>> expression, IClientSessionHandle session = null, string db = null) where T : Entity
- public static Task DeleteAsync<T>(IEnumerable<string> IDs, IClientSessionHandle session = null, string db = null) where T : Entity
- public static Task<IEnumerable<string>> AllDatabaseNamesAsync(string host = "127.0.0.1", int port = 27017)
- public static Task<IEnumerable<string>> AllDatabaseNamesAsync(MongoClientSettings settings)
- public static void ChangeDefaultDatabase(string name)
- public static IMongoCollection<T> Collection<T>() where T : IEntity
- public static string CollectionName<T>() where T : IEntity
- public static Task<long> CountAsync<T>(Expression<Func<T, bool>> expression, IClientSessionHandle session = null, CancellationToken cancellation = default, CountOptions options = null) where T : IEntity
- public static Task<long> CountAsync<T>(FilterDefinition<T> filter, IClientSessionHandle session = null, CancellationToken cancellation = default, CountOptions options = null) where T : IEntity
- public static Task<long> CountAsync<T>(Func<FilterDefinitionBuilder<T>, FilterDefinition<T>> filter, IClientSessionHandle session = null, CancellationToken cancellation = default, CountOptions options = null) where T : IEntity
- public static Task<long> CountAsync<T>(IClientSessionHandle session = null, CancellationToken cancellation = default) where T : IEntity
- public static Task<long> CountEstimatedAsync<T>(CancellationToken cancellation = default) where T : IEntity
- public static Task CreateCollectionAsync<T>(Action<CreateCollectionOptions<T>> options, CancellationToken cancellation = default, IClientSessionHandle session = null) where T : IEntity
- public static IMongoDatabase Database<T>() where T : IEntity
- public static IMongoDatabase Database(string name)
- public static void DatabaseFor<T>(string database) where T : IEntity
- public static string DatabaseName<T>() where T : IEntity
- public static Task<DeleteResult> DeleteAsync<T>(string ID, IClientSessionHandle session = null, CancellationToken cancellation = default) where T : IEntity
- public static Task<DeleteResult> DeleteAsync<T>(IEnumerable<string> IDs, IClientSessionHandle session = null, CancellationToken cancellation = default) where T : IEntity
- public static Task<DeleteResult> DeleteAsync<T>(Expression<Func<T, bool>> expression, IClientSessionHandle session = null, CancellationToken cancellation = default, Collation collation = null) where T : IEntity
- public static Task<DeleteResult> DeleteAsync<T>(Func<FilterDefinitionBuilder<T>, FilterDefinition<T>> filter, IClientSessionHandle session = null, CancellationToken cancellation = default, Collation collation = null) where T : IEntity
- public static Task<DeleteResult> DeleteAsync<T>(FilterDefinition<T> filter, IClientSessionHandle session = null, CancellationToken cancellation = default, Collation collation = null) where T : IEntity
- public static Distinct<T, TProperty> Distinct<T, TProperty>(IClientSessionHandle session = null) where T : IEntity
- public static Task DropCollectionAsync<T>(IClientSessionHandle session = null) where T : IEntity
- public static T Entity<T>(string ID) where T : IEntity
- public static DataStreamer File<T>(string ID) where T : FileEntity
- public static Find<T> Find<T>(string db = null) where T : Entity
- public static Find<T, TProjection> Find<T, TProjection>(string db = null) where T : Entity
- public static IAggregateFluent<T> Fluent<T>(AggregateOptions options = null, IClientSessionHandle session = null, string db = null)
- public static IAggregateFluent<T> GeoNear<T>(Coordinates2D NearCoordinates, Expression<Func<T, object>> DistanceField, bool Spherical = true, int? MaxDistance = default, int? MinDistance = default, int? Limit = default, BsonDocument Query = null, int? DistanceMultiplier = default, Expression<Func<T, object>> IncludeLocations = null, string IndexKey = null, AggregateOptions options = null, IClientSessionHandle session = null, string db = null) where T : Entity
- public static DB GetInstance(string database)
- public static Index<T> Index<T>(string db = null) where T : Entity
- public static void Migrate()
- public static IMongoQueryable<T> Queryable<T>(AggregateOptions options = null, string db = null)
- public static void Save<T>(T entity, IClientSessionHandle session = null, string db = null) where T : Entity
- public static void Save<T>(IEnumerable<T> entities, IClientSessionHandle session = null, string db = null) where T : Entity
- public static Task SaveAsync<T>(T entity, IClientSessionHandle session = null, string db = null) where T : Entity
- public static Task SaveAsync<T>(IEnumerable<T> entities, IClientSessionHandle session = null, string db = null) where T : Entity
- public static List<T> SearchText<T>(string searchTerm, bool caseSensitive = false, FindOptions<T, T> options = null, IClientSessionHandle session = null, string db = null)
- public static Task<List<T>> SearchTextAsync<T>(string searchTerm, bool caseSensitive = false, FindOptions<T, T> options = null, IClientSessionHandle session = null, string db = null)
- public static IAggregateFluent<T> SearchTextFluent<T>(string searchTerm, bool caseSensitive = false, AggregateOptions options = null, IClientSessionHandle session = null, string db = null)
- public static Update<T> Update<T>(string db = null) where T : Entity
- public IMongoCollection<T> Collection<T>()
- public void Delete<T>(string ID, IClientSessionHandle session = null) where T : Entity
- public void Delete<T>(Expression<Func<T, bool>> expression, IClientSessionHandle session = null) where T : Entity
- public void Delete<T>(IEnumerable<string> IDs, IClientSessionHandle session = null) where T : Entity
- public Task DeleteAsync<T>(string ID, IClientSessionHandle session = null) where T : Entity
- public Task DeleteAsync<T>(Expression<Func<T, bool>> expression, IClientSessionHandle session = null) where T : Entity
- public Task DeleteAsync<T>(IEnumerable<string> IDs, IClientSessionHandle session = null) where T : Entity
- public Find<T> Find<T>() where T : Entity
- public Find<T, TProjection> Find<T, TProjection>() where T : Entity
- public static Find<T> Find<T>(IClientSessionHandle session = null) where T : IEntity
- public static Find<T, TProjection> Find<T, TProjection>(IClientSessionHandle session = null) where T : IEntity
- public IAggregateFluent<T> GeoNear<T>(Coordinates2D NearCoordinates, Expression<Func<T, object>> DistanceField, bool Spherical = true, int? MaxDistance = default, int? MinDistance = default, int? Limit = default, BsonDocument Query = null, int? DistanceMultiplier = default, Expression<Func<T, object>> IncludeLocations = null, string IndexKey = null, AggregateOptions options = null, IClientSessionHandle session = null) where T : Entity
- public static IAggregateFluent<T> FluentGeoNear<T>(Coordinates2D NearCoordinates, Expression<Func<T, object>> DistanceField, bool Spherical = true, double? MaxDistance = default, double? MinDistance = default, int? Limit = default, BsonDocument Query = null, double? DistanceMultiplier = default, Expression<Func<T, object>> IncludeLocations = null, string IndexKey = null, AggregateOptions options = null, IClientSessionHandle session = null) where T : IEntity
- public static IAggregateFluent<T> FluentTextSearch<T>(Search searchType, string searchTerm, bool caseSensitive = false, bool diacriticSensitive = false, string language = null, AggregateOptions options = null, IClientSessionHandle session = null) where T : IEntity
- public IMongoQueryable<T> Queryable<T>(AggregateOptions options = null)
- public void Save<T>(T entity, IClientSessionHandle session = null) where T : Entity
- public void Save<T>(IEnumerable<T> entities, IClientSessionHandle session = null) where T : Entity
- public Task SaveAsync<T>(T entity, IClientSessionHandle session = null) where T : Entity
- public List<T> SearchText<T>(string searchTerm, bool caseSensitive = false, FindOptions<T, T> options = null, IClientSessionHandle session = null)
- public Task<List<T>> SearchTextAsync<T>(string searchTerm, bool caseSensitive = false, FindOptions<T, T> options = null, IClientSessionHandle session = null)
- public IAggregateFluent<T> SearchTextFluent<T>(string searchTerm, bool caseSensitive = false, AggregateOptions options = null, IClientSessionHandle session = null)
- public Update<T> Update<T>() where T : Entity
- public static Task InitAsync(string database, string host = "127.0.0.1", int port = 27017)
- public static Task InitAsync(string database, MongoClientSettings settings)
- public static Task InsertAsync<T>(T entity, IClientSessionHandle session = null, CancellationToken cancellation = default) where T : IEntity
- public static Task<BulkWriteResult<T>> InsertAsync<T>(IEnumerable<T> entities, IClientSessionHandle session = null, CancellationToken cancellation = default) where T : IEntity
- public static Task MigrateAsync<T>()
- public static Task MigrateAsync()
- public static Task MigrationsAsync(IEnumerable<IMigration> migrations)
- public static Task<ulong> NextSequentialNumberAsync<T>(CancellationToken cancellation = default) where T : IEntity
- public static Task<ulong> NextSequentialNumberAsync(string sequenceName, CancellationToken cancellation = default)
- public static PagedSearch<T> PagedSearch<T>(IClientSessionHandle session = null) where T : IEntity
- public static PagedSearch<T, TProjection> PagedSearch<T, TProjection>(IClientSessionHandle session = null) where T : IEntity
- public static Task<List<TResult>> PipelineAsync<T, TResult>(Template<T, TResult> template, AggregateOptions options = null, IClientSessionHandle session = null, CancellationToken cancellation = default) where T : IEntity
- public static Task<IAsyncCursor<TResult>> PipelineCursorAsync<T, TResult>(Template<T, TResult> template, AggregateOptions options = null, IClientSessionHandle session = null, CancellationToken cancellation = default) where T : IEntity
- public static Task<TResult> PipelineFirstAsync<T, TResult>(Template<T, TResult> template, AggregateOptions options = null, IClientSessionHandle session = null, CancellationToken cancellation = default) where T : IEntity
- public static Task<TResult> PipelineSingleAsync<T, TResult>(Template<T, TResult> template, AggregateOptions options = null, IClientSessionHandle session = null, CancellationToken cancellation = default) where T : IEntity
- public static ProjectionDefinitionBuilder<T> Projection<T>() where T : IEntity
- public static IMongoQueryable<T> Queryable<T>(AggregateOptions options = null, IClientSessionHandle session = null) where T : IEntity
- public static Replace<T> Replace<T>(IClientSessionHandle session = null) where T : IEntity
- public static Task SaveAsync<T>(T entity, IClientSessionHandle session = null, CancellationToken cancellation = default) where T : IEntity
- public static Task<BulkWriteResult<T>> SaveAsync<T>(IEnumerable<T> entities, IClientSessionHandle session = null, CancellationToken cancellation = default) where T : IEntity
- public static Task<UpdateResult> SaveExceptAsync<T>(T entity, Expression<Func<T, object>> members, IClientSessionHandle session = null, CancellationToken cancellation = default) where T : IEntity
- public static Task<BulkWriteResult<T>> SaveExceptAsync<T>(IEnumerable<T> entities, Expression<Func<T, object>> members, IClientSessionHandle session = null, CancellationToken cancellation = default) where T : IEntity
- public static Task<UpdateResult> SaveOnlyAsync<T>(T entity, Expression<Func<T, object>> members, IClientSessionHandle session = null, CancellationToken cancellation = default) where T : IEntity
- public static Task<BulkWriteResult<T>> SaveOnlyAsync<T>(IEnumerable<T> entities, Expression<Func<T, object>> members, IClientSessionHandle session = null, CancellationToken cancellation = default) where T : IEntity
- public static Task<UpdateResult> SavePreservingAsync<T>(T entity, IClientSessionHandle session = null, CancellationToken cancellation = default) where T : IEntity
- public static SortDefinitionBuilder<T> Sort<T>() where T : IEntity
- public static Transaction Transaction(string database = null, ClientSessionOptions options = null, ModifiedBy modifiedBy = null)
- public static Transaction Transaction<T>(ClientSessionOptions options = null, ModifiedBy modifiedBy = null) where T : IEntity
- public static Update<T> Update<T>(IClientSessionHandle session = null) where T : IEntity
- public static UpdateAndGet<T, TProjection> UpdateAndGet<T, TProjection>(IClientSessionHandle session = null) where T : IEntity
- public static UpdateAndGet<T> UpdateAndGet<T>(IClientSessionHandle session = null) where T : IEntity
- public static Watcher<T> Watcher<T>(string name) where T : IEntity
- public static IEnumerable<Watcher<T>> Watchers<T>() where T : IEntity
-
public class DBContext
- public ModifiedBy ModifiedBy { get; set; }
- public IClientSessionHandle Session { get; protected set; }
- public DBContext(string database, string host = "127.0.0.1", int port = 27017, ModifiedBy modifiedBy = null)
- public DBContext(string database, MongoClientSettings settings, ModifiedBy modifiedBy = null)
- public DBContext(ModifiedBy modifiedBy = null)
- public Task AbortAsync(CancellationToken cancellation = default)
- public Task CommitAsync(CancellationToken cancellation = default)
- public Task<long> CountAsync<T>(Expression<Func<T, bool>> expression, CancellationToken cancellation = default, CountOptions options = null, bool ignoreGlobalFilters = false) where T : IEntity
- public Task<long> CountAsync<T>(CancellationToken cancellation = default) where T : IEntity
- public Task<long> CountAsync<T>(FilterDefinition<T> filter, CancellationToken cancellation = default, CountOptions options = null, bool ignoreGlobalFilters = false) where T : IEntity
- public Task<long> CountAsync<T>(Func<FilterDefinitionBuilder<T>, FilterDefinition<T>> filter, CancellationToken cancellation = default, CountOptions options = null, bool ignoreGlobalFilters = false) where T : IEntity
- public Task<long> CountEstimatedAsync<T>(CancellationToken cancellation = default) where T : IEntity
- public Task CreateCollectionAsync<T>(Action<CreateCollectionOptions<T>> options, CancellationToken cancellation = default) where T : IEntity
- public Task<DeleteResult> DeleteAsync<T>(string ID, CancellationToken cancellation = default, bool ignoreGlobalFilters = false) where T : IEntity
- public Task<DeleteResult> DeleteAsync<T>(IEnumerable<string> IDs, CancellationToken cancellation = default, bool ignoreGlobalFilters = false) where T : IEntity
- public Task<DeleteResult> DeleteAsync<T>(Expression<Func<T, bool>> expression, CancellationToken cancellation = default, Collation collation = null, bool ignoreGlobalFilters = false) where T : IEntity
- public Task<DeleteResult> DeleteAsync<T>(Func<FilterDefinitionBuilder<T>, FilterDefinition<T>> filter, CancellationToken cancellation = default, Collation collation = null, bool ignoreGlobalFilters = false) where T : IEntity
- public Task<DeleteResult> DeleteAsync<T>(FilterDefinition<T> filter, CancellationToken cancellation = default, Collation collation = null, bool ignoreGlobalFilters = false) where T : IEntity
- public Distinct<T, TProperty> Distinct<T, TProperty>() where T : IEntity
- public Task DropCollectionAsync<T>() where T : IEntity
- public Find<T> Find<T>() where T : IEntity
- public Find<T, TProjection> Find<T, TProjection>() where T : IEntity
- public IAggregateFluent<T> Fluent<T>(AggregateOptions options = null, bool ignoreGlobalFilters = false) where T : IEntity
- public IAggregateFluent<T> FluentTextSearch<T>(Search searchType, string searchTerm, bool caseSensitive = false, bool diacriticSensitive = false, string language = null, AggregateOptions options = null, bool ignoreGlobalFilters = false) where T : IEntity
- public IAggregateFluent<T> GeoNear<T>(Coordinates2D NearCoordinates, Expression<Func<T, object>> DistanceField, bool Spherical = true, int? MaxDistance = default, int? MinDistance = default, int? Limit = default, BsonDocument Query = null, int? DistanceMultiplier = default, Expression<Func<T, object>> IncludeLocations = null, string IndexKey = null, AggregateOptions options = null, bool ignoreGlobalFilters = false) where T : IEntity
- public Task InsertAsync<T>(T entity, CancellationToken cancellation = default) where T : IEntity
- public Task<BulkWriteResult<T>> InsertAsync<T>(IEnumerable<T> entities, CancellationToken cancellation = default) where T : IEntity
- protected virtual Action<T> OnBeforeSave<T>() where T : IEntity
- protected virtual Action<UpdateBase<T>> OnBeforeUpdate<T>() where T : IEntity
- public PagedSearch<T> PagedSearch<T>() where T : IEntity
- public PagedSearch<T, TProjection> PagedSearch<T, TProjection>() where T : IEntity
- public Task<List<TResult>> PipelineAsync<T, TResult>(Template<T, TResult> template, AggregateOptions options = null, CancellationToken cancellation = default, bool ignoreGlobalFilters = false) where T : IEntity
- public Task<IAsyncCursor<TResult>> PipelineCursorAsync<T, TResult>(Template<T, TResult> template, AggregateOptions options = null, CancellationToken cancellation = default, bool ignoreGlobalFilters = false) where T : IEntity
- public Task<TResult> PipelineFirstAsync<T, TResult>(Template<T, TResult> template, AggregateOptions options = null, CancellationToken cancellation = default, bool ignoreGlobalFilters = false) where T : IEntity
- public Task<TResult> PipelineSingleAsync<T, TResult>(Template<T, TResult> template, AggregateOptions options = null, CancellationToken cancellation = default, bool ignoreGlobalFilters = false) where T : IEntity
- public IMongoQueryable<T> Queryable<T>(AggregateOptions options = null, bool ignoreGlobalFilters = false) where T : IEntity
- public Replace<T> Replace<T>() where T : IEntity
- public Task SaveAsync<T>(T entity, CancellationToken cancellation = default) where T : IEntity
- public Task<BulkWriteResult<T>> SaveAsync<T>(IEnumerable<T> entities, CancellationToken cancellation = default) where T : IEntity
- public Task<UpdateResult> SaveExceptAsync<T>(T entity, Expression<Func<T, object>> members, CancellationToken cancellation = default) where T : IEntity
- public Task<BulkWriteResult<T>> SaveExceptAsync<T>(IEnumerable<T> entities, Expression<Func<T, object>> members, CancellationToken cancellation = default) where T : IEntity
- public Task<UpdateResult> SaveOnlyAsync<T>(T entity, Expression<Func<T, object>> members, CancellationToken cancellation = default) where T : IEntity
- public Task<BulkWriteResult<T>> SaveOnlyAsync<T>(IEnumerable<T> entities, Expression<Func<T, object>> members, CancellationToken cancellation = default) where T : IEntity
- public Task<UpdateResult> SavePreservingAsync<T>(T entity, CancellationToken cancellation = default) where T : IEntity
- protected void SetGlobalFilter<T>(Expression<Func<T, bool>> filter, bool prepend = false) where T : IEntity
- protected void SetGlobalFilter<T>(Func<FilterDefinitionBuilder<T>, FilterDefinition<T>> filter, bool prepend = false) where T : IEntity
- protected void SetGlobalFilter<T>(FilterDefinition<T> filter, bool prepend = false) where T : IEntity
- protected void SetGlobalFilter(Type type, string jsonString, bool prepend = false)
- protected void SetGlobalFilterForBaseClass<TBase>(Expression<Func<TBase, bool>> filter, bool prepend = false) where TBase : IEntity
- protected void SetGlobalFilterForBaseClass<TBase>(Func<FilterDefinitionBuilder<TBase>, FilterDefinition<TBase>> filter, bool prepend = false) where TBase : IEntity
- protected void SetGlobalFilterForBaseClass<TBase>(FilterDefinition<TBase> filter, bool prepend = false) where TBase : IEntity
- protected void SetGlobalFilterForInterface<TInterface>(string jsonString, bool prepend = false)
- public IClientSessionHandle Transaction(string database = null, ClientSessionOptions options = null)
- public IClientSessionHandle Transaction<T>(ClientSessionOptions options = null) where T : IEntity
- public Update<T> Update<T>() where T : IEntity
- public UpdateAndGet<T, T> UpdateAndGet<T>() where T : IEntity
- public UpdateAndGet<T, TProjection> UpdateAndGet<T, TProjection>() where T : IEntity
-
public class Distinct<T, TProperty> where T : IEntity
- public Task<List<TProperty>> ExecuteAsync(CancellationToken cancellation = default)
- public Task<IAsyncCursor<TProperty>> ExecuteCursorAsync(CancellationToken cancellation = default)
- public Distinct<T, TProperty> IgnoreGlobalFilters()
- public Distinct<T, TProperty> Match(Func<FilterDefinitionBuilder<T>, FilterDefinition<T>> filter)
- public Distinct<T, TProperty> Match(Expression<Func<T, bool>> expression)
- public Distinct<T, TProperty> Match(Template template)
- public Distinct<T, TProperty> Match(Search searchType, string searchTerm, bool caseSensitive = false, bool diacriticSensitive = false, string language = null)
- public Distinct<T, TProperty> Match(Expression<Func<T, object>> coordinatesProperty, Coordinates2D nearCoordinates, double? maxDistance = default, double? minDistance = default)
- public Distinct<T, TProperty> MatchExpression(string expression)
- public Distinct<T, TProperty> MatchExpression(Template template)
- public Distinct<T, TProperty> MatchString(string jsonString)
- public Distinct<T, TProperty> Option(Action<DistinctOptions> option)
- public Distinct<T, TProperty> Property(string property)
- public Distinct<T, TProperty> Property(Expression<Func<T, object>> property)
-
public class DontPreserveAttribute : Attribute
-
public abstract class Entity : IEntity
-
public enum EventType
-
public static class Extensions
- public static IServiceCollection AddMongoDBEntities(this IServiceCollection services, string Database, string Host = "127.0.0.1", int Port = 27017)
- public static IServiceCollection AddMongoDBEntities(this IServiceCollection services, MongoClientSettings Settings, string Database)
- public static string Database(this Entity entity)
- public static void Delete<T>(this T entity) where T : Entity
- public static void DeleteAll<T>(this IEnumerable<T> entities) where T : Entity
- public static Task DeleteAllAsync<T>(this IEnumerable<T> entities) where T : Entity
- public static Task DeleteAsync<T>(this T entity) where T : Entity
- public static string CollectionName<T>(this T _) where T : IEntity
- public static IMongoDatabase Database<T>(this T _) where T : IEntity
- public static string DatabaseName<T>(this T _) where T : IEntity
- public static Task<DeleteResult> DeleteAllAsync<T>(this IEnumerable<T> entities, IClientSessionHandle session = null, CancellationToken cancellation = default) where T : IEntity
- public static Task<DeleteResult> DeleteAsync<T>(this T entity, IClientSessionHandle session = null, CancellationToken cancellation = default) where T : IEntity
- public static Task DropAsync(this IMongoCollection<JoinRecord> collection)
- public static Task<bool> ExistsAsync(this IMongoDatabase db, int timeoutSeconds = 5)
- public static void InitManyToMany<TChild>(this Entity parent, Expression<Func<Many<TChild>>> propertyToInit, Expression<Func<TChild, object>> propertyOtherSide) where TChild : Entity
- public static void InitOneToMany<TChild>(this Entity parent, Expression<Func<Many<TChild>>> propertyToInit) where TChild : Entity
- public static void InitManyToMany<TChild>(this IEntity parent, Expression<Func<Many<TChild>>> propertyToInit, Expression<Func<TChild, object>> propertyOtherSide) where TChild : IEntity
- public static void InitOneToMany<TChild>(this IEntity parent, Expression<Func<Many<TChild>>> propertyToInit) where TChild : IEntity
- public static Task InsertAsync<T>(this T entity, IClientSessionHandle session = null, CancellationToken cancellation = default) where T : IEntity
- public static Task<BulkWriteResult<T>> InsertAsync<T>(this IEnumerable<T> entities, IClientSessionHandle session = null, CancellationToken cancellation = default) where T : IEntity
- public static Task<bool> IsAccessibleAsync(this IMongoDatabase db, int timeoutSeconds = 5)
- public static Task<ulong> NextSequentialNumberAsync<T>(this T _, CancellationToken cancellation = default) where T : IEntity
- public static PagedSearch<T, TProjection> PagedSearch<T, TProjection>(this IAggregateFluent<T> aggregate) where T : IEntity
- public static PagedSearch<T, T> PagedSearch<T>(this IAggregateFluent<T> aggregate) where T : IEntity
- public static void Save<T>(this T entity) where T : Entity
- public static void Save<T>(this IEnumerable<T> entities) where T : Entity
- public static Task SaveAsync<T>(this T entity) where T : Entity
- public static Task SaveAsync<T>(this IEnumerable<T> entities) where T : Entity
- public static Task SaveAsync<T>(this T entity, IClientSessionHandle session = null, CancellationToken cancellation = default) where T : IEntity
- public static Task<BulkWriteResult<T>> SaveAsync<T>(this IEnumerable<T> entities, IClientSessionHandle session = null, CancellationToken cancellation = default) where T : IEntity
- public static Task<UpdateResult> SaveExceptAsync<T>(this T entity, Expression<Func<T, object>> members, IClientSessionHandle session = null, CancellationToken cancellation = default) where T : IEntity
- public static Task<BulkWriteResult<T>> SaveExceptAsync<T>(this IEnumerable<T> entities, Expression<Func<T, object>> members, IClientSessionHandle session = null, CancellationToken cancellation = default) where T : IEntity
- public static Task<UpdateResult> SaveOnlyAsync<T>(this T entity, Expression<Func<T, object>> members, IClientSessionHandle session = null, CancellationToken cancellation = default) where T : IEntity
- public static Task<BulkWriteResult<T>> SaveOnlyAsync<T>(this IEnumerable<T> entities, Expression<Func<T, object>> members, IClientSessionHandle session = null, CancellationToken cancellation = default) where T : IEntity
- public static Task<UpdateResult> SavePreservingAsync<T>(this T entity, IClientSessionHandle session = null, CancellationToken cancellation = default) where T : IEntity
- public static IEnumerable<T> SortByRelevance<T>(this IEnumerable<T> objects, string searchTerm, Func<T, string> propertyToSortBy, int? maxDistance = default)
- public static IEnumerable<IEnumerable<T>> ToBatches<T>(this IEnumerable<T> collection, int batchSize = 100)
- public static string ToDoubleMetaphoneHash(this string term)
-
public class FieldAttribute : BsonElementAttribute
-
public abstract class FileEntity : Entity
-
public class Find<T, TProjection> where T : IEntity
- public List<TProjection> Execute()
- public Task<List<TProjection>> ExecuteAsync()
- public Task<bool> ExecuteAnyAsync(CancellationToken cancellation = default)
- public Task<List<TProjection>> ExecuteAsync(CancellationToken cancellation = default)
- public Task<IAsyncCursor<TProjection>> ExecuteCursorAsync(CancellationToken cancellation = default)
- public Task<TProjection> ExecuteFirstAsync(CancellationToken cancellation = default)
- public Task<TProjection> ExecuteSingleAsync(CancellationToken cancellation = default)
- public Find<T, TProjection> IgnoreGlobalFilters()
- public Find<T, TProjection> IncludeRequiredProps()
- public List<TProjection> Many(Expression<Func<T, bool>> expression)
- public List<TProjection> Many(Func<FilterDefinitionBuilder<T>, FilterDefinition<T>> filter)
- public Task<List<TProjection>> ManyAsync(Expression<Func<T, bool>> expression)
- public Task<List<TProjection>> ManyAsync(Func<FilterDefinitionBuilder<T>, FilterDefinition<T>> filter)
- public Task<List<TProjection>> ManyAsync(Expression<Func<T, bool>> expression, CancellationToken cancellation = default)
- public Task<List<TProjection>> ManyAsync(Func<FilterDefinitionBuilder<T>, FilterDefinition<T>> filter, CancellationToken cancellation = default)
- public Find<T, TProjection> Match(FilterDefinition<T> filterDefinition)
- public Find<T, TProjection> Match(Template template)
- public Find<T, TProjection> Match(Search searchType, string searchTerm, bool caseSensitive = false, bool diacriticSensitive = false, string language = null)
- public Find<T, TProjection> Match(Expression<Func<T, object>> coordinatesProperty, Coordinates2D nearCoordinates, double? maxDistance = default, double? minDistance = default)
- public TProjection One(string ID)
- public Task<TProjection> OneAsync(string ID)
- public Find<T, TProjection> MatchExpression(Template template)
- public Find<T, TProjection> MatchID(string ID)
- public Find<T, TProjection> MatchString(string jsonString)
- public Task<TProjection> OneAsync(string ID, CancellationToken cancellation = default)
- public Find<T, TProjection> ProjectExcluding(Expression<Func<T, object>> exclusion)
- public Find<T, TProjection> Sort(Func<SortDefinitionBuilder<T>, SortDefinition<T>> sortFunction)
- public Find<T, TProjection> SortByTextScore()
- public Find<T, TProjection> SortByTextScore(Expression<Func<T, object>> scoreProperty)
-
public class FuzzyString
-
public class GeoNear<T> where T : IEntity
-
public interface ICreatedOn
-
public interface IEntity
-
public class IgnoreDefaultAttribute : BsonIgnoreIfDefaultAttribute
-
public interface IMigration
-
public interface IModifiedOn
-
public class Index<T> where T : IEntity
-
public enum KeyType
-
public sealed class Many<TChild> : ManyBase, IEnumerable<TChild>, IEnumerable where TChild : IEntity
- public class Joined<TChild, T> : JoinRecord where TChild : Entity
- public void Add(TChild child, IClientSessionHandle session = null)
- public Task AddAsync(TChild child, IClientSessionHandle session = null)
- public Many()
- public Task AddAsync(TChild child, IClientSessionHandle session = null, CancellationToken cancellation = default)
- public Task AddAsync(IEnumerable<TChild> children, IClientSessionHandle session = null, CancellationToken cancellation = default)
- public Task AddAsync(string childID, IClientSessionHandle session = null, CancellationToken cancellation = default)
- public Task AddAsync(IEnumerable<string> childIDs, IClientSessionHandle session = null, CancellationToken cancellation = default)
- public Task<long> ChildrenCountAsync(IClientSessionHandle session = null, CountOptions options = null, CancellationToken cancellation = default)
- public IMongoQueryable<TChild> ChildrenQueryable(AggregateOptions options = null)
- public IMongoQueryable<TChild> ChildrenQueryable(IClientSessionHandle session = null, AggregateOptions options = null)
- public IEnumerator<TChild> GetEnumerator()
- public IMongoQueryable<JoinRecord> JoinQueryable(AggregateOptions options = null)
- public IMongoQueryable<JoinRecord> JoinQueryable(IClientSessionHandle session = null, AggregateOptions options = null)
- public IAggregateFluent<TParent> ParentsFluent<TParent>(string childID, IClientSessionHandle session = null) where TParent : Entity
- public IAggregateFluent<TParent> ParentsFluent<TParent>(string childID, IClientSessionHandle session = null, AggregateOptions options = null) where TParent : IEntity
- public IMongoQueryable<TParent> ParentsQueryable<TParent>(string childID, AggregateOptions options = null) where TParent : Entity
- public IMongoQueryable<TParent> ParentsQueryable<TParent>(IEnumerable<string> childIDs, AggregateOptions options = null) where TParent : Entity
- public IMongoQueryable<TParent> ParentsQueryable<TParent>(IMongoQueryable<TChild> children, AggregateOptions options = null) where TParent : Entity
- public void Remove(TChild child, IClientSessionHandle session = null)
- public Task RemoveAsync(TChild child, IClientSessionHandle session = null)
- public IMongoQueryable<TParent> ParentsQueryable<TParent>(string childID, IClientSessionHandle session = null, AggregateOptions options = null) where TParent : IEntity
- public IMongoQueryable<TParent> ParentsQueryable<TParent>(IEnumerable<string> childIDs, IClientSessionHandle session = null, AggregateOptions options = null) where TParent : IEntity
- public IMongoQueryable<TParent> ParentsQueryable<TParent>(IMongoQueryable<TChild> children, IClientSessionHandle session = null, AggregateOptions options = null) where TParent : IEntity
- public Task RemoveAsync(TChild child, IClientSessionHandle session = null, CancellationToken cancellation = default)
- public Task RemoveAsync(string childID, IClientSessionHandle session = null, CancellationToken cancellation = default)
- public Task RemoveAsync(IEnumerable<TChild> children, IClientSessionHandle session = null, CancellationToken cancellation = default)
- public Task RemoveAsync(IEnumerable<string> childIDs, IClientSessionHandle session = null, CancellationToken cancellation = default)
- public void VB_InitManyToMany<TParent>(TParent parent, Expression<Func<TParent, object>> propertyParent, Expression<Func<TChild, object>> propertyChild, bool isInverse) where TParent : IEntity
- public void VB_InitOneToMany<TParent>(TParent parent, Expression<Func<TParent, object>> property) where TParent : IEntity
-
public class ModifiedBy
-
public class NameAttribute : CollectionAttribute
- public string Name { get; }
-
public class ObjectIdAttribute : BsonRepresentationAttribute
-
public class One<T> where T : IEntity
- public T ToEntity(IClientSessionHandle session = null)
- public T ToEntity(Expression<Func<T, T>> projection, IClientSessionHandle session = null)
- public T ToEntity(Func<ProjectionDefinitionBuilder<T>, ProjectionDefinition<T, T>> projection, IClientSessionHandle session = null)
- public Task<T> ToEntityAsync(IClientSessionHandle session = null)
- public Task<T> ToEntityAsync(Expression<Func<T, T>> projection, IClientSessionHandle session = null)
- public Task<T> ToEntityAsync(Func<ProjectionDefinitionBuilder<T>, ProjectionDefinition<T, T>> projection, IClientSessionHandle session = null)
- public static One<T> op_Implicit(string id)
- public static One<T> op_Implicit(T entity)
- public Task<T> ToEntityAsync(IClientSessionHandle session = null, CancellationToken cancellation = default)
- public Task<T> ToEntityAsync(Expression<Func<T, T>> projection, IClientSessionHandle session = null, CancellationToken cancellation = default)
- public Task<T> ToEntityAsync(Func<ProjectionDefinitionBuilder<T>, ProjectionDefinition<T, T>> projection, IClientSessionHandle session = null, CancellationToken cancellation = default)
-
public class PagedSearch<T> : PagedSearch<T, T> where T : IEntity
-
public class PagedSearch<T, TProjection> where T : IEntity
- public Task<ValueTuple<IReadOnlyList<TProjection>, long, int>> ExecuteAsync(CancellationToken cancellation = default)
- public PagedSearch<T, TProjection> IgnoreGlobalFilters()
- public PagedSearch<T, TProjection> Match(Expression<Func<T, bool>> expression)
- public PagedSearch<T, TProjection> Match(Func<FilterDefinitionBuilder<T>, FilterDefinition<T>> filter)
- public PagedSearch<T, TProjection> Match(FilterDefinition<T> filterDefinition)
- public PagedSearch<T, TProjection> Match(Template template)
- public PagedSearch<T, TProjection> Match(Search searchType, string searchTerm, bool caseSensitive = false, bool diacriticSensitive = false, string language = null)
- public PagedSearch<T, TProjection> Match(Expression<Func<T, object>> coordinatesProperty, Coordinates2D nearCoordinates, double? maxDistance = default, double? minDistance = default)
- public PagedSearch<T, TProjection> MatchExpression(string expression)
- public PagedSearch<T, TProjection> MatchExpression(Template template)
- public PagedSearch<T, TProjection> MatchString(string jsonString)
- public PagedSearch<T, TProjection> Option(Action<AggregateOptions> option)
- public PagedSearch<T, TProjection> PageNumber(int pageNumber)
- public PagedSearch<T, TProjection> PageSize(int pageSize)
- public PagedSearch<T, TProjection> Project(Expression<Func<T, TProjection>> expression)
- public PagedSearch<T, TProjection> Project(Func<ProjectionDefinitionBuilder<T>, ProjectionDefinition<T, TProjection>> projection)
- public PagedSearch<T, TProjection> ProjectExcluding(Expression<Func<T, object>> exclusion)
- public PagedSearch<T, TProjection> Sort(Expression<Func<T, object>> propertyToSortBy, Order sortOrder)
- public PagedSearch<T, TProjection> Sort(Func<SortDefinitionBuilder<T>, SortDefinition<T>> sortFunction)
- public PagedSearch<T, TProjection> SortByTextScore()
- public PagedSearch<T, TProjection> SortByTextScore(Expression<Func<T, object>> scoreProperty)
- public PagedSearch<T, TProjection> WithFluent<TFluent>(TFluent fluentPipeline) where TFluent : IAggregateFluent<T>
-
public class PreserveAttribute : Attribute
-
public static class Prop
-
public class Replace<T> where T : IEntity
- public Replace<T> AddToQueue()
- public Task<ReplaceOneResult> ExecuteAsync(CancellationToken cancellation = default)
- public Replace<T> IgnoreGlobalFilters()
- public Replace<T> Match(Expression<Func<T, bool>> expression)
- public Replace<T> Match(Func<FilterDefinitionBuilder<T>, FilterDefinition<T>> filter)
- public Replace<T> Match(FilterDefinition<T> filterDefinition)
- public Replace<T> Match(Template template)
- public Replace<T> Match(Search searchType, string searchTerm, bool caseSensitive = false, bool diacriticSensitive = false, string language = null)
- public Replace<T> Match(Expression<Func<T, object>> coordinatesProperty, Coordinates2D nearCoordinates, double? maxDistance = default, double? minDistance = default)
- public Replace<T> MatchExpression(string expression)
- public Replace<T> MatchExpression(Template template)
- public Replace<T> MatchID(string ID)
- public Replace<T> MatchString(string jsonString)
- public Replace<T> Option(Action<ReplaceOptions> option)
- public Replace<T> WithEntity(T entity)
-
public enum Search
-
public class Template
- public Template(string template)
- public void AppendStage(string pipelineStageString)
- public Template Collection<TEntity>() where TEntity : IEntity
- public Template Elements<T>(Expression<Func<T, object>> expression)
- public Template Elements<T>(int index, Expression<Func<T, object>> expression)
- public Template Path<T>(Expression<Func<T, object>> expression)
- public Template Paths<T>(Expression<Func<T, object>> expression)
- public Template PosAll<T>(Expression<Func<T, object>> expression)
- public Template PosFiltered<T>(Expression<Func<T, object>> expression)
- public Template PosFirst<T>(Expression<Func<T, object>> expression)
- public Template Properties<T>(Expression<Func<T, object>> expression)
- public Template Property<T>(Expression<Func<T, object>> expression)
- public string RenderToString()
- public Template Tag(string tagName, string replacementValue)
- public IEnumerable<ArrayFilterDefinition> ToArrayFilters<T>()
- public PipelineDefinition<TInput, TOutput> ToPipeline<TInput, TOutput>()
- public IEnumerable<BsonDocument> ToStages()
- public string ToString()
-
public class Template<T> : Template<T, T> where T : IEntity
-
public class Template<TInput, TResult> : Template where TInput : IEntity
- public Template(string template)
- public Template<TInput, TResult> Collection<TEntity>() where TEntity : IEntity
- public Template<TInput, TResult> Elements(Expression<Func<TInput, object>> expression)
- public Template<TInput, TResult> Elements<TOther>(Expression<Func<TOther, object>> expression)
- public Template<TInput, TResult> Elements(int index, Expression<Func<TInput, object>> expression)
- public Template<TInput, TResult> Elements<TOther>(int index, Expression<Func<TOther, object>> expression)
- public Template<TInput, TResult> ElementsOfResult(Expression<Func<TResult, object>> expression)
- public Template<TInput, TResult> ElementsOfResult(int index, Expression<Func<TResult, object>> expression)
- public Template<TInput, TResult> Path(Expression<Func<TInput, object>> expression)
- public Template<TInput, TResult> Path<TOther>(Expression<Func<TOther, object>> expression)
- public Template<TInput, TResult> PathOfResult(Expression<Func<TResult, object>> expression)
- public Template<TInput, TResult> Paths(Expression<Func<TInput, object>> expression)
- public Template<TInput, TResult> Paths<TOther>(Expression<Func<TOther, object>> expression)
- public Template<TInput, TResult> PathsOfResult(Expression<Func<TResult, object>> expression)
- public Template<TInput, TResult> PosAll(Expression<Func<TInput, object>> expression)
- public Template<TInput, TResult> PosAll<TOther>(Expression<Func<TOther, object>> expression)
- public Template<TInput, TResult> PosAllOfResult(Expression<Func<TResult, object>> expression)
- public Template<TInput, TResult> PosFiltered(Expression<Func<TInput, object>> expression)
- public Template<TInput, TResult> PosFiltered<TOther>(Expression<Func<TOther, object>> expression)
- public Template<TInput, TResult> PosFilteredOfResult(Expression<Func<TResult, object>> expression)
- public Template<TInput, TResult> PosFirst(Expression<Func<TInput, object>> expression)
- public Template<TInput, TResult> PosFirst<TOther>(Expression<Func<TOther, object>> expression)
- public Template<TInput, TResult> PosFirstOfResult(Expression<Func<TResult, object>> expression)
- public Template<TInput, TResult> Properties(Expression<Func<TInput, object>> expression)
- public Template<TInput, TResult> Properties<TOther>(Expression<Func<TOther, object>> expression)
- public Template<TInput, TResult> PropertiesOfResult(Expression<Func<TResult, object>> expression)
- public Template<TInput, TResult> Property(Expression<Func<TInput, object>> expression)
- public Template<TInput, TResult> Property<TOther>(Expression<Func<TOther, object>> expression)
- public Template<TInput, TResult> PropertyOfResult(Expression<Func<TResult, object>> expression)
- public Template<TInput, TResult> Tag(string tagName, string replacementValue)
- public IEnumerable<ArrayFilterDefinition> ToArrayFilters()
- public PipelineDefinition<TInput, TResult> ToPipeline()
-
public class Transaction : DBContext, IDisposable
- public IClientSessionHandle Session { get; }
- public Transaction(string database = null, ClientSessionOptions options = null)
- public void Abort()
- public void AbortAsync()
- public void Commit()
- public void CommitAsync()
- public void Delete<T>(string ID) where T : Entity
- public void Delete<T>(Expression<Func<T, bool>> expression) where T : Entity
- public void Delete<T>(IEnumerable<string> IDs) where T : Entity
- public Task DeleteAsync<T>(string ID) where T : Entity
- public Task DeleteAsync<T>(Expression<Func<T, bool>> expression) where T : Entity
- public Task DeleteAsync<T>(IEnumerable<string> IDs) where T : Entity
- public Transaction(string database = null, ClientSessionOptions options = null, ModifiedBy modifiedBy = null)
- protected virtual void Dispose(bool disposing)
- public Find<T> Find<T>() where T : Entity
- public Find<T, TProjection> Find<T, TProjection>() where T : Entity
- public IAggregateFluent<T> Fluent<T>(AggregateOptions options = null)
- public IAggregateFluent<T> GeoNear<T>(Coordinates2D NearCoordinates, Expression<Func<T, object>> DistanceField, bool Spherical = true, int? MaxDistance = default, int? MinDistance = default, int? Limit = default, BsonDocument Query = null, int? DistanceMultiplier = default, Expression<Func<T, object>> IncludeLocations = null, string IndexKey = null, AggregateOptions options = null) where T : Entity
- public void Save<T>(T entity) where T : Entity
- public void Save<T>(IEnumerable<T> entities) where T : Entity
- public Task SaveAsync<T>(T entity) where T : Entity
- public Task SaveAsync<T>(IEnumerable<T> entities) where T : Entity
- public List<T> SearchText<T>(string searchTerm, bool caseSensitive = false, FindOptions<T, T> options = null)
- public Task<List<T>> SearchTextAsync<T>(string searchTerm, bool caseSensitive = false, FindOptions<T, T> options = null)
- public IAggregateFluent<T> SearchTextFluent<T>(string searchTerm, bool caseSensitive = false, AggregateOptions options = null)
- public Update<T> Update<T>() where T : Entity
-
public class Update<T> : UpdateBase<T> where T : IEntity
- public void Execute()
- public Task ExecuteAsync()
- public void ExecutePipeline()
- public Task ExecutePipelineAsync()
- public Task<UpdateResult> ExecuteAsync(CancellationToken cancellation = default)
- public Task<UpdateResult> ExecutePipelineAsync(CancellationToken cancellation = default)
- public Update<T> IgnoreGlobalFilters()
- public Update<T> Match(FilterDefinition<T> filterDefinition)
- public Update<T> Match(Template template)
- public Update<T> Match(Search searchType, string searchTerm, bool caseSensitive = false, bool diacriticSensitive = false, string language = null)
- public Update<T> Match(Expression<Func<T, object>> coordinatesProperty, Coordinates2D nearCoordinates, double? maxDistance = default, double? minDistance = default)
- public Update<T> MatchExpression(string expression)
- public Update<T> MatchExpression(Template template)
- public Update<T> MatchID(string ID)
- public Update<T> MatchString(string jsonString)
- public Update<T> Modify(Template template)
- public Update<T> ModifyExcept(Expression<Func<T, object>> members, T entity)
- public Update<T> ModifyOnly(Expression<Func<T, object>> members, T entity)
- public Update<T> ModifyWith(T entity)
- public Update<T> WithArrayFilter(Template template)
- public Update<T> WithArrayFilters(Template template)
- public Update<T> WithPipeline(Template template)
- public Update<T> WithPipelineStage(Template template)
-
public class UpdateAndGet<T> : UpdateAndGet<T, T> where T : IEntity
-
public class UpdateAndGet<T, TProjection> : UpdateBase<T> where T : IEntity
- public Task<TProjection> ExecuteAsync(CancellationToken cancellation = default)
- public Task<TProjection> ExecutePipelineAsync(CancellationToken cancellation = default)
- public UpdateAndGet<T, TProjection> IgnoreGlobalFilters()
- public UpdateAndGet<T, TProjection> IncludeRequiredProps()
- public UpdateAndGet<T, TProjection> Match(Expression<Func<T, bool>> expression)
- public UpdateAndGet<T, TProjection> Match(Func<FilterDefinitionBuilder<T>, FilterDefinition<T>> filter)
- public UpdateAndGet<T, TProjection> Match(FilterDefinition<T> filterDefinition)
- public UpdateAndGet<T, TProjection> Match(Template template)
- public UpdateAndGet<T, TProjection> Match(Search searchType, string searchTerm, bool caseSensitive = false, bool diacriticSensitive = false, string language = null)
- public UpdateAndGet<T, TProjection> Match(Expression<Func<T, object>> coordinatesProperty, Coordinates2D nearCoordinates, double? maxDistance = default, double? minDistance = default)
- public UpdateAndGet<T, TProjection> MatchExpression(string expression)
- public UpdateAndGet<T, TProjection> MatchExpression(Template template)
- public UpdateAndGet<T, TProjection> MatchID(string ID)
- public UpdateAndGet<T, TProjection> MatchString(string jsonString)
- public UpdateAndGet<T, TProjection> Modify<TProp>(Expression<Func<T, TProp>> property, TProp value)
- public UpdateAndGet<T, TProjection> Modify(Func<UpdateDefinitionBuilder<T>, UpdateDefinition<T>> operation)
- public UpdateAndGet<T, TProjection> Modify(string update)
- public UpdateAndGet<T, TProjection> Modify(Template template)
- public UpdateAndGet<T, TProjection> ModifyExcept(Expression<Func<T, object>> members, T entity)
- public UpdateAndGet<T, TProjection> ModifyOnly(Expression<Func<T, object>> members, T entity)
- public UpdateAndGet<T, TProjection> ModifyWith(T entity)
- public UpdateAndGet<T, TProjection> Option(Action<FindOneAndUpdateOptions<T, TProjection>> option)
- public UpdateAndGet<T, TProjection> Project(Expression<Func<T, TProjection>> expression)
- public UpdateAndGet<T, TProjection> Project(Func<ProjectionDefinitionBuilder<T>, ProjectionDefinition<T, TProjection>> projection)
- public UpdateAndGet<T, TProjection> WithArrayFilter(string filter)
- public UpdateAndGet<T, TProjection> WithArrayFilter(Template template)
- public UpdateAndGet<T, TProjection> WithArrayFilters(Template template)
- public UpdateAndGet<T, TProjection> WithPipeline(Template template)
- public UpdateAndGet<T, TProjection> WithPipelineStage(string stage)
- public UpdateAndGet<T, TProjection> WithPipelineStage(Template template)
-
public abstract class UpdateBase<T> where T : IEntity
-
public class Watcher<T> where T : IEntity
- public bool CanRestart { get; }
- public bool IsInitialized { get; }
- public string Name { get; }
- public BsonDocument ResumeToken { get; }
- public event Action<IEnumerable<T>> OnChanges
- public event AsyncEventHandler<IEnumerable<T>> OnChangesAsync
- public event Action<IEnumerable<ChangeStreamDocument<T>>> OnChangesCSD
- public event AsyncEventHandler<IEnumerable<ChangeStreamDocument<T>>> OnChangesCSDAsync
- public event Action<Exception> OnError
- public event Action OnStop
- public void ReStart(BsonDocument resumeToken = null)
- public void Start(EventType eventTypes, Expression<Func<ChangeStreamDocument<T>, bool>> filter = null, int batchSize = 25, bool onlyGetIDs = false, bool autoResume = true, CancellationToken cancellation = default)
- public void Start(EventType eventTypes, Expression<Func<T, T>> projection, Expression<Func<ChangeStreamDocument<T>, bool>> filter = null, int batchSize = 25, bool autoResume = true, CancellationToken cancellation = default)
- public void Start(EventType eventTypes, Func<FilterDefinitionBuilder<ChangeStreamDocument<T>>, FilterDefinition<ChangeStreamDocument<T>>> filter, int batchSize = 25, bool onlyGetIDs = false, bool autoResume = true, CancellationToken cancellation = default)
- public void Start(EventType eventTypes, Expression<Func<T, T>> projection, Func<FilterDefinitionBuilder<ChangeStreamDocument<T>>, FilterDefinition<ChangeStreamDocument<T>>> filter, int batchSize = 25, bool autoResume = true, CancellationToken cancellation = default)
- public void StartWithToken(BsonDocument resumeToken, EventType eventTypes, Expression<Func<ChangeStreamDocument<T>, bool>> filter = null, int batchSize = 25, bool onlyGetIDs = false, CancellationToken cancellation = default)
- public void StartWithToken(BsonDocument resumeToken, EventType eventTypes, Expression<Func<T, T>> projection, Expression<Func<ChangeStreamDocument<T>, bool>> filter = null, int batchSize = 25, CancellationToken cancellation = default)
- public void StartWithToken(BsonDocument resumeToken, EventType eventTypes, Func<FilterDefinitionBuilder<ChangeStreamDocument<T>>, FilterDefinition<ChangeStreamDocument<T>>> filter, int batchSize = 25, bool onlyGetIDs = false, CancellationToken cancellation = default)
- public void StartWithToken(BsonDocument resumeToken, EventType eventTypes, Expression<Func<T, T>> projection, Func<FilterDefinitionBuilder<ChangeStreamDocument<T>>, FilterDefinition<ChangeStreamDocument<T>>> filter, int batchSize = 25, CancellationToken cancellation = default)