Pipelinez Documentation
Pipelinez is a .NET 8 library for building typed, observable source -> segment -> destination record-processing pipelines with retries, dead-lettering, flow control, performance snapshots, health/metrics, and transport extensions.
Start Here
- Conceptual documentation
- API reference
- In-memory quickstart
- Kafka quickstart
- Azure Service Bus quickstart
- RabbitMQ quickstart
- Amazon S3 transport
- PostgreSQL destination quickstart
- SQL Server destination quickstart
Packages
| Package | Purpose |
|---|---|
Pipelinez |
Core typed pipeline runtime |
Pipelinez.Kafka |
Kafka source, destination, dead-lettering, distributed execution, and partition-aware scaling |
Pipelinez.AzureServiceBus |
Azure Service Bus queue/topic sources, destinations, dead-lettering, and competing-consumer workers |
Pipelinez.RabbitMQ |
RabbitMQ queue sources, exchange/queue destinations, dead-lettering, and competing-consumer workers |
Pipelinez.AmazonS3 |
Amazon S3 object sources, object destinations, and dead-letter artifact writes |
Pipelinez.PostgreSql |
PostgreSQL destination and dead-letter writes with consumer-owned schema mapping |
Pipelinez.SqlServer |
SQL Server destination and dead-letter writes with consumer-owned schema mapping |
API Reference
The API reference is generated from the public XML documentation comments in the package projects. Missing public XML documentation is treated as a build error for package projects, so the generated reference should remain aligned with the package IntelliSense experience.