Skip to content

Commit

Permalink
Added InternalVisibleTo in OutboxWorker (#82)
Browse files Browse the repository at this point in the history
* Added InternalVisibleTo in OutboxWorker
  • Loading branch information
adimiko authored Mar 21, 2024
1 parent 1c57100 commit 9499a9e
Show file tree
Hide file tree
Showing 12 changed files with 18 additions and 29 deletions.
1 change: 0 additions & 1 deletion samples/TransactionalBox.Sample.WebApi/Program.cs
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,6 @@
using TransactionalBox.OutboxWorker.EntityFramework;
using TransactionalBox.OutboxWorker.Kafka;
using TransactionalBox.Sample.WebApi;

var postgreSqlContainer = new PostgreSqlBuilder()
.WithImage("postgres:15.1")
.Build();
Expand Down
Original file line number Diff line number Diff line change
@@ -1,12 +1,4 @@
using Confluent.Kafka;
using Microsoft.Extensions.Hosting;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Text;
using System.Threading.Tasks;
using TransactionalBox.Internals;

namespace TransactionalBox.OutboxWorker.Kafka.Internals
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,6 @@ namespace TransactionalBox.OutboxWorker.Configurators
{
public interface IOutboxWorkerStorageConfigurator
{
IServiceCollection Services { get; }
internal IServiceCollection Services { get; }
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,6 @@ namespace TransactionalBox.OutboxWorker.Configurators
{
public interface IOutboxWorkerTransportConfigurator
{
IServiceCollection Services { get; }
internal IServiceCollection Services { get; }
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@

namespace TransactionalBox.OutboxWorker.Internals.Contracts
{
public interface IOutboxStorage
internal interface IOutboxStorage
{
Task<int> MarkMessages(JobId jobId, JobName jobName, int batchSize, DateTime nowUtc, DateTime lockUtc);

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@

namespace TransactionalBox.OutboxWorker.Internals.Contracts
{
public interface ITransport
internal interface ITransport
{
Task<TransportResult> Add(IEnumerable<TransportMessage> transportMessages);
}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
namespace TransactionalBox.OutboxWorker.Internals.Contracts
{
public enum TransportResult
internal enum TransportResult
{
Success,
Failure
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2,10 +2,10 @@

namespace TransactionalBox.OutboxWorker.Internals
{
public sealed class GroupedOutboxMessagesWithTheSameTopic
internal sealed class GroupedOutboxMessagesWithTheSameTopic
{
public required string Topic { get; init; }
internal required string Topic { get; init; }

public required IEnumerable<OutboxMessage> Messages { get; init; }
internal required IEnumerable<OutboxMessage> Messages { get; init; }
}
}
Original file line number Diff line number Diff line change
@@ -1,5 +1,4 @@
using System.Text.Json;
using TransactionalBox.BackgroundServiceBase.Internals;
using TransactionalBox.BackgroundServiceBase.Internals;
using TransactionalBox.BackgroundServiceBase.Internals.Context;
using TransactionalBox.Internals;
using TransactionalBox.OutboxWorker.Internals.Contracts;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
namespace TransactionalBox.OutboxWorker.Internals
{
public sealed class TransportMessage
internal sealed class TransportMessage
{
public required string Topic { get; init; }
internal required string Topic { get; init; }

public required string Payload { get; init; }
internal required string Payload { get; init; }
}
}
Original file line number Diff line number Diff line change
@@ -1,11 +1,5 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Text.Json;
using System.Threading.Tasks;
using System.Text.Json;
using TransactionalBox.OutboxBase.StorageModel;
using TransactionalBox.OutboxWorker.Internals.Contracts;

namespace TransactionalBox.OutboxWorker.Internals
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -11,4 +11,9 @@
<ProjectReference Include="..\TransactionalBox\TransactionalBox.csproj" />
</ItemGroup>

<ItemGroup>
<InternalsVisibleTo Include="$(AssemblyName).EntityFramework" />
<InternalsVisibleTo Include="$(AssemblyName).Kafka" />
</ItemGroup>

</Project>

0 comments on commit 9499a9e

Please sign in to comment.