CerbiStream 1.0.13
dotnet add package CerbiStream --version 1.0.13
NuGet\Install-Package CerbiStream -Version 1.0.13
This command is intended to be used within the Package Manager Console in Visual Studio, as it uses the NuGet module's version of Install-Package.
<PackageReference Include="CerbiStream" Version="1.0.13" />
For projects that support PackageReference, copy this XML node into the project file to reference the package.
<PackageVersion Include="CerbiStream" Version="1.0.13" />
<PackageReference Include="CerbiStream" />
For projects that support Central Package Management (CPM), copy this XML node into the solution Directory.Packages.props file to version the package.
paket add CerbiStream --version 1.0.13
The NuGet Team does not provide support for this client. Please contact its maintainers for support.
#r "nuget: CerbiStream, 1.0.13"
#r directive can be used in F# Interactive and Polyglot Notebooks. Copy this into the interactive tool or source code of the script to reference the package.
#addin nuget:?package=CerbiStream&version=1.0.13
#tool nuget:?package=CerbiStream&version=1.0.13
The NuGet Team does not provide support for this client. Please contact its maintainers for support.
CerbiStream: Dev-Friendly Logging for .NET
Compare against Serilog, NLog, and others. CerbiStream is tuned for performance, governance, and enterprise-scale routing.
✅ Highlights
- Works with
ILogger<T> - Structured logging enforcement
- Supports RabbitMQ, Kafka, Azure, AWS, GCP queues
- Flexible encryption (None, Base64, AES)
- Schema enforcement with GovernanceAnalyzer
- 🔁 Queue-first architecture (sink-agnostic)
✨ What's New in v1.0.11
- New presets:
BenchmarkMode(),EnableDeveloperModeWithTelemetry() - Toggle: telemetry, console, metadata, governance
- JSON conversion with encryption
- Queue routing using enums
🧰 Install
dotnet add package CerbiStream
Optional governance analyzer:
dotnet add package CerbiStream.GovernanceAnalyzer
⚡ Quick Start
builder.Logging.AddCerbiStreamWithRouting(options =>
{
options.WithQueue("RabbitMQ", "localhost", "logs-queue")
.EnableDeveloperModeWithoutTelemetry()
.WithEncryptionMode(EncryptionType.Base64);
});
🔐 Runtime Encryption
options.WithEncryptionMode(EncryptionType.AES)
.WithEncryptionKey(myKey, myIV);
Default (lazy) test keys:
var (key, iv) = EncryptionHelpers.GetInsecureDefaultKeyPair();
options.WithEncryptionKey(key, iv);
KeyVault example:
var key = Convert.FromBase64String(await secretClient.GetSecret("CerbiKey"));
var iv = Convert.FromBase64String(await secretClient.GetSecret("CerbiIV"));
🛠️ Preset Modes
| Method | Description |
|---|---|
EnableDeveloperModeWithTelemetry() |
Console + telemetry + metadata |
EnableDeveloperModeWithoutTelemetry() |
Console + metadata, no telemetry |
EnableDevModeMinimal() |
Console only |
EnableBenchmarkMode() |
Silent mode (no telemetry, queue, or console) |
🔁 Retry Example
Policy
.Handle<Exception>()
.WaitAndRetry(3, _ => TimeSpan.FromSeconds(1), (ex, _, attempt, _) =>
{
TelemetryContext.IsRetry = true;
TelemetryContext.RetryAttempt = attempt;
});
🔧 Configuration Options
| Option | Description |
|---|---|
.WithQueue(...) |
Configure queue host, name, and type |
.DisableQueue() |
Stops sending logs to queues |
.WithTelemetryProvider() |
Set custom telemetry provider |
.IncludeSecurityMetadata() |
Adds IP/UserID info |
.EnableTelemetryLogging() |
Sends to telemetry even if queue is disabled |
📊 Telemetry Provider Support
| Provider | Supported |
|---|---|
| OpenTelemetry | ✅ |
| Azure App Insights | ✅ |
| AWS CloudWatch | ✅ |
| GCP Trace | ✅ |
| Datadog | ✅ |
📘 Code Samples
CerbiLoggerBuilder
var logger = new CerbiLoggerBuilder()
.UseAzureServiceBus("<conn>", "<queue>")
.EnableDebugMode()
.Build(logger, new ConvertToJson(), new NoOpEncryption());
Fluent API
var options = new CerbiStreamOptions()
.WithEncryptionMode(EncryptionType.Base64)
.WithQueue("RabbitMQ", "localhost", "logs");
AddCerbiStreamWithRouting (DI)
builder.Logging.AddCerbiStreamWithRouting(options =>
{
options.WithQueue("AzureServiceBus", "sb://...", "queue")
.WithEncryptionMode(EncryptionType.AES);
});
🧪 Unit Test Example
var mockQueue = Substitute.For<IQueue>();
var logger = new Logging(Substitute.For<ILogger<Logging>>(), mockQueue, new ConvertToJson(), new NoOpEncryption());
var result = await logger.LogEventAsync("Test", LogLevel.Information);
Assert.True(result);
🌐 Supported Queues
- RabbitMQ
- Kafka
- Azure Queue / Service Bus
- AWS SQS / Kinesis
- Google Pub/Sub
🧵 Queue-First Logging (Sink-Agnostic)
CerbiStream does not directly send logs to sinks like Splunk, Elastic, or Blob.
Instead:
- 🔁 Logs are emitted to queues only (Kafka, RabbitMQ, Azure, etc.)
- 🧠 CerbIQ reads from these queues and sends logs to sinks
- ✅ Keeps log generation decoupled from log delivery
This design gives you:
- Better performance
- Retry-friendly resilience
- Pluggable downstream integrations
➡️ Add CerbIQ to handle routing and sink delivery.
🔐 Governance Enforcement (Optional)
{
"LoggingProfiles": {
"SecurityLog": {
"RequiredFields": ["UserId", "IPAddress"],
"OptionalFields": ["DeviceType"]
}
}
}
📜 License
MIT
Star the repo ⭐ — Contribute 🔧 — File issues 🐛
Created by @Zeroshi
| Product | Versions Compatible and additional computed target framework versions. |
|---|---|
| .NET | net8.0 is compatible. 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. |
Compatible target framework(s)
Included target framework(s) (in package)
Learn more about Target Frameworks and .NET Standard.
-
net8.0
- AWSSDK.CloudWatchLogs (>= 3.7.410.5)
- AWSSDK.Kinesis (>= 3.7.402.86)
- AWSSDK.SQS (>= 3.7.400.109)
- Azure.Core (>= 1.45.0)
- Azure.Messaging.ServiceBus (>= 7.18.4)
- Azure.Storage.Common (>= 12.23.0-beta.1)
- Azure.Storage.Queues (>= 12.22.0-beta.1)
- cerberus-logger-interface (>= 1.0.26)
- CerbiStream.GovernanceAnalyzer (>= 1.0.1)
- Datadog.Trace (>= 3.12.0)
- Google.Cloud.Logging.V2 (>= 4.4.0)
- Google.Cloud.PubSub.V1 (>= 3.21.0)
- Google.Protobuf (>= 3.30.0)
- Microsoft.ApplicationInsights (>= 2.23.0)
- Microsoft.Extensions.Configuration (>= 9.0.2)
- Microsoft.Extensions.Configuration.Abstractions (>= 10.0.0-preview.1.25080.5)
- Moq (>= 4.20.72)
- NUnit (>= 4.3.2)
- OpenTelemetry (>= 1.11.2)
- OpenTelemetry.Exporter.Console (>= 1.11.2)
- RabbitMQ.Client (>= 6.4.0)
- System.Configuration.ConfigurationManager (>= 10.0.0-preview.1.25080.5)
- System.Data.SqlClient (>= 4.9.0)
- System.Diagnostics.EventLog (>= 10.0.0-preview.1.25080.5)
NuGet packages
This package is not used by any NuGet packages.
GitHub repositories
This package is not used by any popular GitHub repositories.