Publo.Abstraction
1.0.1
dotnet add package Publo.Abstraction --version 1.0.1
NuGet\Install-Package Publo.Abstraction -Version 1.0.1
<PackageReference Include="Publo.Abstraction" Version="1.0.1" />
<PackageVersion Include="Publo.Abstraction" Version="1.0.1" />
<PackageReference Include="Publo.Abstraction" />
paket add Publo.Abstraction --version 1.0.1
#r "nuget: Publo.Abstraction, 1.0.1"
#:package Publo.Abstraction@1.0.1
#addin nuget:?package=Publo.Abstraction&version=1.0.1
#tool nuget:?package=Publo.Abstraction&version=1.0.1
Publo.Abstraction
Core contracts and dependency injection helpers for Publo broadcast events.
Use this package when you need the common publishing and handling APIs for notifying every running pod or application instance, or when you want to implement a custom Publo provider.
Installation
dotnet add package Publo.Abstraction
Public API
IPubloService is the application-facing service used to publish broadcast events:
using Publo.Abstraction.Services;
public sealed class UsersService(IPubloService publo)
{
public Task PublishAsync(Guid userId, CancellationToken cancellationToken)
=> publo.SendAsync(new UserCreated(userId), cancellationToken);
}
public sealed record UserCreated(Guid UserId);
IPubloExecutor<T> handles received broadcast events:
using Publo.Abstraction.Executor;
public sealed class UserCreatedExecutor : IPubloExecutor<UserCreated>
{
public Task HandleAsync(UserCreated message, CancellationToken cancellationToken)
{
// React to the broadcast event here.
return Task.CompletedTask;
}
}
AddPublo registers the publishing service and configures a provider. AddPubloExecutor registers
event handlers:
using Publo.Abstraction.Extensions;
using Publo.Kafka.Extensions;
builder.Services
.AddPublo(publo => publo.UseKafka())
.AddPubloExecutor<UserCreated, UserCreatedExecutor>();
Custom Providers
Provider packages implement IPubloProvider and register it through IPubloBuilder.UseProvider.
using Publo.Abstraction.Builder;
using Publo.Abstraction.Provider;
public sealed class InMemoryPubloProvider : IPubloProvider
{
public Task SendAsync<T>(T message, CancellationToken cancellationToken)
{
// Publish or persist the broadcast event here.
return Task.CompletedTask;
}
}
builder.Services.AddPublo(publo => publo.UseProvider<InMemoryPubloProvider>());
Provider implementations are responsible for delivering received events to registered
IPubloExecutor<T> implementations.
| Product | Versions Compatible and additional computed target framework versions. |
|---|---|
| .NET | net5.0 was computed. net5.0-windows was computed. net6.0 was computed. net6.0-android was computed. net6.0-ios was computed. net6.0-maccatalyst was computed. net6.0-macos was computed. net6.0-tvos was computed. net6.0-windows was computed. net7.0 was computed. net7.0-android was computed. net7.0-ios was computed. net7.0-maccatalyst was computed. net7.0-macos was computed. net7.0-tvos was computed. net7.0-windows was computed. net8.0 was computed. net8.0-android was computed. net8.0-browser was computed. net8.0-ios was computed. net8.0-maccatalyst was computed. net8.0-macos was computed. net8.0-tvos was computed. net8.0-windows was computed. net9.0 was computed. net9.0-android was computed. net9.0-browser was computed. net9.0-ios was computed. net9.0-maccatalyst was computed. net9.0-macos was computed. net9.0-tvos was computed. net9.0-windows was computed. net10.0 was computed. net10.0-android was computed. net10.0-browser was computed. net10.0-ios was computed. net10.0-maccatalyst was computed. net10.0-macos was computed. net10.0-tvos was computed. net10.0-windows was computed. |
| .NET Core | netcoreapp2.0 was computed. netcoreapp2.1 was computed. netcoreapp2.2 was computed. netcoreapp3.0 was computed. netcoreapp3.1 was computed. |
| .NET Standard | netstandard2.0 is compatible. netstandard2.1 was computed. |
| .NET Framework | net461 was computed. net462 was computed. net463 was computed. net47 was computed. net471 was computed. net472 was computed. net48 was computed. net481 was computed. |
| MonoAndroid | monoandroid was computed. |
| MonoMac | monomac was computed. |
| MonoTouch | monotouch was computed. |
| Tizen | tizen40 was computed. tizen60 was computed. |
| Xamarin.iOS | xamarinios was computed. |
| Xamarin.Mac | xamarinmac was computed. |
| Xamarin.TVOS | xamarintvos was computed. |
| Xamarin.WatchOS | xamarinwatchos was computed. |
-
.NETStandard 2.0
- Microsoft.Extensions.Logging.Abstractions (>= 10.0.8)
NuGet packages (2)
Showing the top 2 NuGet packages that depend on Publo.Abstraction:
| Package | Downloads |
|---|---|
|
Publo.Postgres
PostgreSQL provider for Publo. Stores messages in PostgreSQL and runs a hosted polling runner that dispatches them to IPubloExecutor handlers. |
|
|
Publo.Kafka
Kafka provider for Publo. Publishes messages to a Kafka topic and runs a hosted consumer that dispatches them to IPubloExecutor handlers. |
GitHub repositories
This package is not used by any popular GitHub repositories.