OpenSleigh.Persistence.Mongo by davidguida

<PackageReference Include="OpenSleigh.Persistence.Mongo" Version="0.7.0" />

---

API Diff between 0.7.0 and 0.0.1

56 Additions 8 Removals

OpenSleigh.Persistence.Mongo

• public class DbContext : IDbContext
  • public IMongoCollection<OutboxMessage> Outbox { get; }
• public interface IDbContext
  • IMongoCollection<OutboxMessage> Outbox { get; }
• public interface ISagaStateSerializer
• public class JsonSagaStateSerializer : ISagaStateSerializer
• public static class MongoBusConfiguratorExtensions
  • public static IBusConfigurator UseMongoPersistence(this IBusConfigurator busConfigurator, MongoConfiguration config)
• public class MongoConfiguration : IEquatable<MongoConfiguration>
  • public MongoSagaStateRepositoryOptions RepositoryOptions { get; set; }
  • public MongoConfiguration(string ConnectionString, string DbName, MongoSagaStateRepositoryOptions RepositoryOptions)
  • public MongoOutboxRepositoryOptions OutboxRepositoryOptions { get; set; }
  • public MongoSagaStateRepositoryOptions SagaRepositoryOptions { get; set; }
  • public MongoConfiguration(string ConnectionString, string DbName, MongoSagaStateRepositoryOptions SagaRepositoryOptions, MongoOutboxRepositoryOptions OutboxRepositoryOptions)
  • public void Deconstruct(out string ConnectionString, out string DbName, out MongoSagaStateRepositoryOptions RepositoryOptions)
  • public void Deconstruct(out string ConnectionString, out string DbName, out MongoSagaStateRepositoryOptions SagaRepositoryOptions, out MongoOutboxRepositoryOptions OutboxRepositoryOptions)
• public static class MongoSagaConfiguratorExtensions
• public class MongoSagaStateRepository : ISagaStateRepository
  • public MongoSagaStateRepository(IDbContext dbContext, ISagaStateSerializer sagaStateSerializer, MongoSagaStateRepositoryOptions options)
  • public MongoSagaStateRepository(IDbContext dbContext, ISerializer serializer, MongoSagaStateRepositoryOptions options)
  • public Task UpdateAsync<TD>(TD state, Guid lockId, bool releaseLock = false, CancellationToken cancellationToken = default) where TD : SagaState
  • public Task ReleaseLockAsync<TD>(TD state, Guid lockId, ITransaction transaction = null, CancellationToken cancellationToken = default) where TD : SagaState
• public class MongoUnitOfWork : IUnitOfWork
  • public MongoUnitOfWork(IMongoClient client, ILogger<MongoUnitOfWork> logger)
  • public Task<ITransaction> StartTransactionAsync(CancellationToken cancellationToken = default)

OpenSleigh.Persistence.Mongo.Entities

• public class OutboxMessage : IEquatable<OutboxMessage>
  • public byte[] Data { get; set; }
  • protected virtual Type EqualityContract { get; }
  • public Guid Id { get; set; }
  • public Guid? LockId { get; set; }
  • public DateTime? LockTime { get; set; }
  • public DateTime? PublishingDate { get; set; }
  • public string Status { get; set; }
  • public string Type { get; set; }
  • public OutboxMessage(Guid Id, byte[] Data, string Type, string Status, DateTime? PublishingDate = default, Guid? LockId = default, DateTime? LockTime = default)
  • protected OutboxMessage(OutboxMessage original)
  • public static bool op_Equality(OutboxMessage r1, OutboxMessage r2)
  • public static bool op_Inequality(OutboxMessage r1, OutboxMessage r2)
  • public virtual OutboxMessage <Clone>$()
  • public void Deconstruct(out Guid Id, out byte Data, out string Type, out string Status, out Nullable PublishingDate, out Nullable LockId, out Nullable LockTime)
  • public virtual bool Equals(OutboxMessage other)
  • protected virtual bool PrintMembers(StringBuilder builder)

OpenSleigh.Persistence.Mongo.Messaging

• public class MongoOutboxRepository : IOutboxRepository
  • public MongoOutboxRepository(IDbContext dbContext, ISerializer serializer, MongoOutboxRepositoryOptions options)
  • public Task AppendAsync(IMessage message, ITransaction transaction = null, CancellationToken cancellationToken = default)
  • public Task<Guid> BeginProcessingAsync(IMessage message, CancellationToken cancellationToken = default)
  • public Task CleanProcessedAsync(CancellationToken cancellationToken = default)
  • public Task MarkAsSentAsync(IMessage message, Guid lockId, CancellationToken cancellationToken = default)
  • public Task<IEnumerable<IMessage>> ReadMessagesToProcess(CancellationToken cancellationToken = default)
• public class MongoOutboxRepositoryOptions : IEquatable<MongoOutboxRepositoryOptions>
  • public static readonly MongoOutboxRepositoryOptions Default
  • protected virtual Type EqualityContract { get; }
  • public TimeSpan LockMaxDuration { get; set; }
  • public MongoOutboxRepositoryOptions(TimeSpan LockMaxDuration)
  • protected MongoOutboxRepositoryOptions(MongoOutboxRepositoryOptions original)
  • public static bool op_Equality(MongoOutboxRepositoryOptions r1, MongoOutboxRepositoryOptions r2)
  • public static bool op_Inequality(MongoOutboxRepositoryOptions r1, MongoOutboxRepositoryOptions r2)
  • public virtual MongoOutboxRepositoryOptions <Clone>$()
  • public void Deconstruct(out TimeSpan LockMaxDuration)
  • public virtual bool Equals(MongoOutboxRepositoryOptions other)
  • protected virtual bool PrintMembers(StringBuilder builder)

OpenSleigh.Persistence.Mongo.Utils

• public interface ISerializer
  • ValueTask<T> DeserializeAsync<T>(byte[] data, CancellationToken cancellationToken = default)
  • ValueTask<byte[]> SerializeAsync<T>(T state, CancellationToken cancellationToken = default)
• public class JsonSerializer : ISerializer
  • public JsonSerializer()
  • public ValueTask<T> DeserializeAsync<T>(byte[] data, CancellationToken cancellationToken = default)
  • public ValueTask<byte[]> SerializeAsync<T>(T state, CancellationToken cancellationToken = default)