propulsion
propulsion copied to clipboard
jet
.NET event stream projection and scheduling platform with CosmosDB, DynamoDB, EventStoreDB, MemoryStore, message-db, Equinox and Kafka integrations
WIP re using as documented in https://aws.amazon.com/blogs/compute/introducing-the-net-6-runtime-for-aws-lambda/ (currently not starting up for some reason)
Follow-on from #126 adding support for backoffs. Such backoffs might be useful for the following scenarios: - if a watchdog is monitoring a stream, it can have a quick look...
- [x] Cosmos: continues to target Equinox.Cosmos >= 2.6.0, so can not be used side by side with Propulsion.* >=3.0.0. _Probably remove in 3.x_ - [x] CosmosStore: target non-preview CFP...
For EventStore storage specifically, it looks like this library is designed so that EventStore is only used for storage of events and that subsequent communicating that events occured is offloaded...
Given [ChangeFeed support in Equinox.MemoryStore](https://github.com/jet/equinox/issues/205), there should be a oneliner way to rig StreamsProjector(s) ingesting from the MemoryStore ChangeFeed that invoke Ingestion/Reaction handlers (also wired to In Memory stores) in...
Cosmos: Guidance, examples and/or provide pit of success regarding reading your writes in handlers
A CFP consumer based on `dotnet new proReactor` currently has the following key ingredients: - the [Propulsion Cosmos _Source_](https://github.com/jet/propulsion/blob/master/src/Propulsion.Cosmos/CosmosSource.fs#L64) uses the [V2 CFP lib](https://github.com/Azure/azure-documentdb-changefeedprocessor-dotnet) to read from the ChangeFeed (internally...
(Prompted by a discussion in DDD-CQRS-ES; dumping here for now as the perfect is the enemy of the good; hopefully I'll get around to expanding on this as either a...
Transcript of a FAQ: >hey, is there any guidance on when it makes sense to use propulsion and when it makes sense to use fskafka? ## FsKafka does: a) basic...
The reader for the CosmosDB ChangeFeed [emits an (indicative, depends on clock sync) "age" stat per batch retrieved](https://github.com/jet/propulsion/blob/97365de328e8fa3738983793b39271e7464dde76/src/Propulsion.Cosmos/CosmosSource.fs#L25), which can be very useful as an indicator for troubleshooting The same...