API Diff between 20.25.0 and 20.3.0
242 Additions
52 Removals
MongoDB.Entities
-
public sealed delegate AsyncEventHandler<TEventArgs> : MulticastDelegate
-
public static class AsyncEventHandlerExtensions
-
public class CollectionAttribute : Attribute
-
public class Coordinates2D
-
public class DataStreamer
-
public static class DB
- 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 Task<long> CountAsync<T>(Expression<Func<T, bool>> expression, IClientSessionHandle session = null, CancellationToken cancellation = default) 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 CreateCollectionAsync<T>(Action<CreateCollectionOptions<T>> options, CancellationToken cancellation = default, IClientSessionHandle session = null) where T : IEntity
- public static Task<DeleteResult> DeleteAsync<T>(Expression<Func<T, bool>> expression, 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 Find<T> Find<T>() where T : IEntity
- public static Find<T, TProjection> Find<T, TProjection>() where T : IEntity
- 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 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 MigrationsAsync(IEnumerable<IMigration> migrations)
- 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<ReplaceOneResult> SaveAsync<T>(T entity, IClientSessionHandle session = null, CancellationToken cancellation = default) 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<UpdateResult> SavePreservingAsync<T>(T entity, Expression<Func<T, object>> preservation = null, 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 Transaction Transaction(string database = null, ClientSessionOptions options = null)
- public static Transaction Transaction<T>(ClientSessionOptions options = null) where T : IEntity
- public static Update<T> Update<T>() where T : IEntity
- public static UpdateAndGet<T, TProjection> UpdateAndGet<T, TProjection>() where T : IEntity
- public static UpdateAndGet<T> UpdateAndGet<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 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 abstract class Entity : IEntity
-
public static class Extensions
- public static Task<DeleteResult> DeleteAllAsync<T>(this IEnumerable<T> entities, IClientSessionHandle session = null) where T : IEntity
- public static Task<DeleteResult> DeleteAsync<T>(this T entity, IClientSessionHandle session = null) 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 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 _) where T : IEntity
- 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 Task<ReplaceOneResult> SaveAsync<T>(this T entity, IClientSessionHandle session = null, CancellationToken cancellation = default) where T : IEntity
- public static Task SaveAsync<T>(this T entity, IClientSessionHandle session = null, CancellationToken cancellation = default) where T : IEntity
- public static Task<UpdateResult> SavePreservingAsync<T>(this T entity, Expression<Func<T, object>> preservation = null, 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 class FieldAttribute : BsonElementAttribute
-
public class Find<T, TProjection> where T : IEntity
-
public class FuzzyString
-
public interface IEntity
-
public class IgnoreDefaultAttribute : BsonIgnoreIfDefaultAttribute
-
public class Index<T> where T : IEntity
-
public sealed class Many<TChild> : ManyBase, IEnumerable<TChild>, IEnumerable where TChild : IEntity
-
public class ModifiedBy
-
public class NameAttribute : CollectionAttribute
- public string Name { get; }
-
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 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 class Template
-
public class Template<TInput, TResult> : Template where TInput : IEntity
-
public class Transaction : DBContext, IDisposable
- public IClientSessionHandle Session { get; }
- public Transaction(string database = null, ClientSessionOptions options = 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) where T : IEntity
- public Task<long> CountAsync<T>(CancellationToken cancellation = default) where T : IEntity
- public Task<DeleteResult> DeleteAsync<T>(string ID, CancellationToken cancellation = default) where T : IEntity
- public Task<DeleteResult> DeleteAsync<T>(Expression<Func<T, bool>> expression, CancellationToken cancellation = default) where T : IEntity
- public Task<DeleteResult> DeleteAsync<T>(IEnumerable<string> IDs, CancellationToken cancellation = default) where T : IEntity
- public Transaction(string database = null, ClientSessionOptions options = null, ModifiedBy modifiedBy = null)
- 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) where T : IEntity
- public IAggregateFluent<T> FluentTextSearch<T>(Search searchType, string searchTerm, bool caseSensitive = false, bool diacriticSensitive = false, string language = null, AggregateOptions options = 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) where T : IEntity
- public Task<List<TResult>> PipelineAsync<T, TResult>(Template<T, TResult> template, AggregateOptions options = null, CancellationToken cancellation = default) where T : IEntity
- public Task<IAsyncCursor<TResult>> PipelineCursorAsync<T, TResult>(Template<T, TResult> template, AggregateOptions options = null, CancellationToken cancellation = default) where T : IEntity
- public Task<TResult> PipelineFirstAsync<T, TResult>(Template<T, TResult> template, AggregateOptions options = null, CancellationToken cancellation = default) where T : IEntity
- public Task<TResult> PipelineSingleAsync<T, TResult>(Template<T, TResult> template, AggregateOptions options = null, CancellationToken cancellation = default) where T : IEntity
- public IMongoQueryable<T> Queryable<T>(AggregateOptions options = null) where T : IEntity
- public Task<ReplaceOneResult> 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> SavePreservingAsync<T>(T entity, Expression<Func<T, object>> preservation = null, CancellationToken cancellation = default) where T : IEntity
- public Update<T> Update<T>() where T : IEntity
- public UpdateAndGet<T> UpdateAndGet<T>() where T : IEntity
- public UpdateAndGet<T, TProjection> UpdateAndGet<T, TProjection>() where T : IEntity
-
public class Update<T> : UpdateBase<T> where T : IEntity
- public Update<T> IgnoreGlobalFilters()
- public Update<T> Match(FilterDefinition<T> filterDefinition)
- public Update<T> Match(string jsonString)
- 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> MatchString(string jsonString)
- 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 class UpdateAndGet<T, TProjection> : UpdateBase<T> where T : IEntity
- public UpdateAndGet<T, TProjection> IgnoreGlobalFilters()
- public UpdateAndGet<T, TProjection> IncludeRequiredProps()
- public UpdateAndGet<T, TProjection> Match(FilterDefinition<T> filterDefinition)
- public UpdateAndGet<T, TProjection> Match(string jsonString)
- 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> MatchString(string jsonString)
- 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 abstract class UpdateBase<T> where T : IEntity
-
public class Watcher<T> where T : IEntity
- public bool IsInitialized { get; }
- public event AsyncEventHandler<IEnumerable<T>> OnChangesAsync
- public event Action<IEnumerable<ChangeStreamDocument<T>>> OnChangesCSD
- public event AsyncEventHandler<IEnumerable<ChangeStreamDocument<T>>> OnChangesCSDAsync
- public void ReStart()
- public void ReStart(BsonDocument resumeToken = null)
- 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<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)