jet/propulsion

Propulsion is an F# library that provides a unified pipeline for ingesting, processing, and publishing stream events across diverse backends. It supports storage and indexing via Cosmos DB, DynamoDB, PostgreSQL, SQL Server, and in-memory stores, while also integrating with Kafka for message transport. The system enables robust event handling through features like exactly-once ingestion, checkpointing, and Prometheus monitoring, all managed via a dedicated CLI tool.

The project established its foundational structure and documentation while removing the legacy Confluent.Kafka.FSharp wrapper. Development focused on expanding the core Propulsion library with new Kafka and EventStore integrations, adding Prometheus metrics, and introducing a unified CLI tool for managing event stores.

10 changes

The project significantly expanded its data integration capabilities by introducing new storage backends for SQL Server, PostgreSQL, EventStoreDB, and DynamoDB, each with dedicated source and checkpoint implementations. Concurrently, the core feed subsystem was refactored to use FsCodec for robust event body handling, while infrastructure support was added for AWS Lambda functions to process DynamoDB streams.

13 changes

jet/propulsion was measured the same way every project in this corpus was: the same rubric, at a pinned commit, with the result published in full. Point the surveyor at a repository you know and see whether you agree with it.