HouseofCat.Utilities
4.1.2
See the version list below for details.
dotnet add package HouseofCat.Utilities --version 4.1.2
NuGet\Install-Package HouseofCat.Utilities -Version 4.1.2
<PackageReference Include="HouseofCat.Utilities" Version="4.1.2" />
paket add HouseofCat.Utilities --version 4.1.2
#r "nuget: HouseofCat.Utilities, 4.1.2"
// Install HouseofCat.Utilities as a Cake Addin #addin nuget:?package=HouseofCat.Utilities&version=4.1.2 // Install HouseofCat.Utilities as a Cake Tool #tool nuget:?package=HouseofCat.Utilities&version=4.1.2
RabbitMQ & Dataflows
A RabbitMQ library of .NET
tools to help rapidly develop well performant services or
to just help manage durable connectivity with the RabbitMQ.Client
!
Status
Test Server: Windows 11
RabbitMQ Server: v3.13
Erlang: v26.2.3
Why Make A RabbitMQ Powered Dataflow?
Dataflows
have configurable concurrency, serialization, monitoring, compression, and
encryption all as first class citizens. This paradigm allows developers to just focus on
the important stuff - getting work done!
Here are some features ready with RabbitMQ.Dataflows
.
Workflows
- Pipelines (v1) are light weight workflow-esque function-as-step executor.
- All steps process in the order provided allowing you to still control order of execution.
- Configurable parallelism and concurrency built-in.
- No automatic OpenTelemetry.
- No automatic exception catching/async error handling (thrown exceptions kill Pipelines).
- Dataflows (v2) are the more complex, yet complete, workflow class.
- All steps process in the order provided allowing you to still control order of execution.
- Configurable parallelism and concurrency built-in.
- Async processing, batch processing, consumer cloning and more!
- Async error handling (simplify functional error handling by allowing functions to throw).
- AutoPublish (to the next Queue) functionality built-in.
- OpenTelemetry with native distributed tracing for Publish/Consumer.
Built-Ins
- A RabbitMQ ConnectionPool and ChannelPool (connection durability).
- Supports
ILogger<T>
via LogHelpers static singleton. - Contracted
IWorkState
simplifies functional generic returns and integration. - Has
ISerializationProvider
support forSystem.Text.Json
andMessagePack
.- Easy to write your own providers.
- Has
ICompressionProvider
built-in support for Gzip, Deflate, Brotli, and LZ4. - Has
IEncryptionProvider
built-in support for AesGcm and BouncyCastle AesGcm. - RecyclableMemoryStream options for
ICompressionProvider
andIEncryptionProvider
. - Publishers AutoPublish seamless encryption/decryption steps (adds headers too).
- Consumers allow seamless compression/decompression steps (uses headers).
- Publisher/Consumers have built-in
OpenTelemetry
support.
Testing
- All built-in steps will have integration tests that should remove concerns from end-user developer.
- Future case will include much more complex abstract UnitTesting as time allows.
- The developer should only need to unit test their functional business code.
Help & Guides
- Getting started with RabbitMQ.Dataflows ConnectionPool.
- Getting started with RabbitMQ.Dataflows ChannelPool.
- Getting started with RabbitMQ.Dataflows ChannelPool and BasicPublish.
- Getting started with RabbitMQ.Dataflows ChannelPool and BasicGet.
- Getting started with RabbitMQ.Dataflows ChannelPool and BasicConsume.
- Getting started with RabbitMQ.Dataflows Serialization.
- Getting started with RabbitMQ.Dataflows Publisher.
- Getting started with RabbitMQ.Dataflows AutoPublisher.
- Getting started with RabbitMQ.Dataflows Consumer.
- Getting started with RabbitMQ.Dataflows ConsumerDataflow.
More to come!
You can also find various library examples inside the tests/UnitTests
or the tests/RabbitMQ.Console.Test
project.
Main RabbitMQ Library
HouseofCat.RabbitMQ
A library that focuses on RabbitMQ connection and channel management to create fault tolerant Publishers and Consumers.
Formerly called CookedRabbit.Core/Tesseract.
DataFlow Library
HouseofCat.Dataflows
A library that provides the base magic Dataflows for RabbitMQ.Dataflows.
- Custom TPL Block - ChannelBock used as a Channel-based
BufferBlock<TIn>
- Has DataFlowEngine and ChannelBlockEngine.
- Has Pipelines (Dataflow alternative).
Core Productivity Libraries
These libraries are here to help you build powerful Dataflows for your messages.
HouseofCat.Serialization
A library that has a collection of .NET ISerializationProvider
or the interface to make your own.
- Supports MessagePack and System.Text.Json and Newtonsoft.Json.
HouseofCat.Compression
A library that has a collection of .NET ICompressionProvider
or the interface to make your own.
- Supports LZ4, Gzip, Brotli, and Deflate.
- Supports RecyclableMemoryStream variants.
HouseofCat.Hashing
A library that focuses on implementing hashing.
- Supports Argon2.
HouseofCat.Encryption
A library that provides encryption contracts and the base AesGCM
/AesCBC
.NET IEncryptionProvider
as
well as the interface to make your own.
- Supports AesCbc via CryptoStream (good for encrypted file/memorystreams).
- Supports .NET AesGcm 128, 192, 256 (non-streams).
- Supports BouncyCastle AesGcm 128/192/256.
- Supports RecyclableMemoryStream variants.
Non-Critical Library Integrations
HouseofCat.Data
A library that provides the provides helper classes for data manipulation and transformation.
Also provides Database abstractions, a simple Dapper integration, and SqlKata integration SQL query generation.
Database Connection Factory Support
- System.Data.SqlClient
- Microsoft.Data.SqlClient
- MySql.Data.MySqlClient
- Npgsq
- MySql.Data
- Oracle
- SQLite
HouseofCat.Utilities
A library that focuses on general purpose utilities and functions that simplify the coding experience.
HouseofCat.io
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. |
-
net8.0
- Microsoft.Extensions.Logging.Abstractions (>= 8.0.1)
- Microsoft.Extensions.Logging.Configuration (>= 8.0.0)
- Microsoft.Extensions.Logging.Console (>= 8.0.0)
- Microsoft.IO.RecyclableMemoryStream (>= 3.0.0)
- OpenTelemetry (>= 1.8.1)
- OpenTelemetry.Api (>= 1.8.1)
- OpenTelemetry.Exporter.Console (>= 1.8.1)
- OpenTelemetry.Exporter.OpenTelemetryProtocol (>= 1.8.1)
- OpenTelemetry.Extensions.Hosting (>= 1.8.1)
- OpenTelemetry.Instrumentation.AspNetCore (>= 1.8.1)
- OpenTelemetry.Instrumentation.Runtime (>= 1.8.0)
NuGet packages (8)
Showing the top 5 NuGet packages that depend on HouseofCat.Utilities:
Package | Downloads |
---|---|
HouseofCat.Encryption
RabbitMQ.Dataflows library helps use RabbitMQ as well as create powerful RabbitMQ powered workflows. |
|
HouseofCat.Compression
RabbitMQ.Dataflows library helps use RabbitMQ as well as create powerful RabbitMQ powered workflows. |
|
HouseofCat.Serialization
RabbitMQ.Dataflows library helps use RabbitMQ as well as create powerful RabbitMQ powered workflows. |
|
HouseofCat.RabbitMQ
RabbitMQ.Dataflows library helps use RabbitMQ as well as create powerful RabbitMQ powered workflows. |
|
HouseofCat.Metrics
RabbitMQ.Dataflows library helps use RabbitMQ as well as create powerful RabbitMQ powered workflows. |
GitHub repositories
This package is not used by any popular GitHub repositories.
Version | Downloads | Last updated |
---|---|---|
4.1.5 | 1,181 | 5/2/2024 |
4.1.4 | 131 | 5/2/2024 |
4.1.3 | 134 | 5/2/2024 |
4.1.2 | 146 | 5/1/2024 |
4.1.1 | 179 | 4/29/2024 |
4.1.0 | 166 | 4/29/2024 |
4.0.0 | 192 | 4/19/2024 |
3.2.2 | 610 | 3/28/2024 |
3.2.1 | 574 | 3/28/2024 |
3.2.0 | 242 | 3/27/2024 |
3.1.3 | 214 | 3/27/2024 |
3.1.2 | 293 | 3/26/2024 |
3.1.1 | 460 | 3/26/2024 |
3.1.0 | 220 | 3/26/2024 |
3.0.0 | 341 | 3/20/2024 |
Major overhaul!