.NET event stream projection and scheduling platform with CosmosDB, DynamoDB, EventStoreDB, MemoryStore, message-db, Equinox and Kafka integrations
Versions 2.12.0 and 2.12.1 are unlisted
See ChangeLog
Prometheus
: Propulsion.Streams.Log.LogSink
: Support indicating the consumer group name via a Serilog (ForContext
) property "group"
#137Kafka
: Target FsCodec.NewtonsoftJson
v 2.3.2
#138Prometheus
: Propulsion.Streams.Log.LogSink
: Replace mandatory group
argument with optional defaultGroup
to emphasize primacy of "group"
Log property #137Targets (granularly) Equinox.CosmosStore 3.0.6
, Equinox.Cosmos 2.6.0
, Equinox.EventStore 3.0.6
, SqlStreamStore 1.2.0-beta.8
, FsCodec 2.3.2
, FsKafka 1.7.x
, Microsoft.Azure.Cosmos
v 3.22.0
, Microsoft.Azure.DocumentDB.ChangeFeedProcessor
v 2.2.8
, prometheus-net
v 3.6.0
See ChangeLog
Kafka.Producers
: optional constructor parameters #135 🙏 @avsaditya19CosmosStore
: Target Equinox.CosmosStore
v 3.0.6
#136EventStore
: Target Equinox.EventStore
v 3.0.6
#134Targets (granularly) Equinox.CosmosStore 3.0.6
, Equinox.Cosmos 2.6.0
, Equinox.EventStore 3.0.6
, SqlStreamStore 1.2.0-beta.8
, FsCodec 2.0.0
, FsKafka 1.7.x
, Microsoft.Azure.Cosmos
v 3.22.0
, Microsoft.Azure.DocumentDB.ChangeFeedProcessor
v 2.2.8
, prometheus-net
v 3.6.0
See ChangeLog
Run
with integrated Ctrl-C handling to Start
yielding a Pipeline
#133Targets (granularly) Equinox.CosmosStore 3.0.5
, Equinox.Cosmos 2.6.0
, Equinox.EventStore 2.6.0
, SqlStreamStore 1.2.0-beta.8
, FsCodec 2.0.0
, FsKafka 1.7.x
, Microsoft.Azure.Cosmos
v 3.22.0
, Microsoft.Azure.DocumentDB.ChangeFeedProcessor
v 2.2.8
, prometheus-net
v 3.6.0
See ChangeLog
Streams
: Added propulsion_scheduler_busy
metrics: count and seconds #126Feed.PeriodicSource
: Add readTranches
parameter to Pump
#130Feed.PeriodicSource
: Add TrancheId
parameter to crawl
#130CosmosStore
: Target Equinox.CosmosStore
v 3.0.5
SqlStreamStore
: Rebase on Propulsion.Feed.FeedSource
#131net461
support #123StreamsProjector
: Fix failure to pump batches when using maxReadAhead
of Int32.MaxValue
#124Targets (granularly) Equinox.CosmosStore 3.0.5
, Equinox.Cosmos 2.6.0
, Equinox.EventStore 2.6.0
, SqlStreamStore 1.2.0-beta.8
, FsCodec 2.0.0
, FsKafka 1.7.x
, Microsoft.Azure.Cosmos
v 3.22.0
, Microsoft.Azure.DocumentDB.ChangeFeedProcessor
v 2.2.8
, prometheus-net
v 3.6.0
See ChangeLog
CosmosStore
: Target Microsoft.Azure.Cosmos
(V3 CFP) 3.0.22
Targets (granularly) Equinox.CosmosStore 3.0.4
, Equinox.Cosmos 2.6.0
, Equinox.EventStore 2.6.0
, SqlStreamStore 1.2.0-beta.8
, FsCodec 2.0.0
, FsKafka 1.7.x
, Microsoft.Azure.Cosmos
v 3.22.0
, Microsoft.Azure.DocumentDB.ChangeFeedProcessor
v 2.2.8
, prometheus-net
v 3.6.0
See ChangeLog
Feed.PeriodicSource
: Enables periodic traversal of a source where the source does not present an incrementally readable change feed #117
Feed.Prometheus
: Prometheus integration providing metrics not dissimilar to those available from .CosmosStore
(no lag metrics though) #117
Pipeline
: Added AwaitWithStopOnCancellation
#118
CosmosStore
: Added handling of With(Error|LeaseAcquire|LeaseRevoke)Notification
APIs introduced in Microsoft.Azure.Cosmos
v 3.22.0-preview
#120
CosmosStore
: Target Microsoft.Azure.Cosmos
(V3 CFP) 3.0.22-preview
CosmosStore
: Target Equinox.CosmosStore
v 3.0.4
CosmosStore
: rename maxDocuments
to maxItems
Pipeline
: Renamed AwaitCompletion
to AwaitShutdown
#118
Kafka
: Target FsKafka [1.7.0, 1.9.99)
Kafka0
: Triggered by removal of underlying FsKafka0
#119
Kafka
: Removed support for net461
, triggered by removal of same in underlying FsKafka
#119
AssemblyVersion 1.0.0.0
(updated MinVer to 2.5.0
)5.0.200
Targets (granularly) Equinox.CosmosStore 3.0.4
, Equinox.Cosmos 2.6.0
, Equinox.EventStore 2.6.0
, SqlStreamStore 1.2.0-beta.8
, FsCodec 2.0.0
, FsKafka 1.7.x
, Microsoft.Azure.Cosmos
v 3.22.0-preview
, Microsoft.Azure.DocumentDB.ChangeFeedProcessor
v 2.2.8
, prometheus-net
v 3.6.0
See ChangeLog
Microsoft.Azure.Cosmos
v 3.0.20-preview
(breaking change vs 3.0.19-preview1
) #115Targets (granularly) Equinox.CosmosStore 3.0.0
, Equinox.Cosmos 2.6.0
, Equinox.EventStore 2.6.0
, SqlStreamStore 1.2.0-beta.8
, FsCodec 2.0.0
, FsKafka 1.5.x
, Microsoft.Azure.Cosmos
v 3.20.0-preview
, Microsoft.Azure.DocumentDB.ChangeFeedProcessor
v 2.2.8
, prometheus-net
v 3.6.0
See ChangeLog
Equinox.CosmosStore
v 3.0.1
, Microsoft.Azure.Cosmos
v 3.0.19-preview1
#113 #114Targets Equinox.Cosmos 2.6.0
, Equinox.CosmosStore 3.0.0
,Equinox.EventStore 2.6.0
, SqlStreamStore 1.2.0-beta.8
, FsCodec 2.0.0
, FsKafka 1.5.x
, Microsoft.Azure.Cosmos
v 3.19-preview1
, Microsoft.Azure.DocumentDB.ChangeFeedProcessor
v 2.2.8
, prometheus-net
v 3.6.0
See ChangeLog
Propulsion.Feed
: Initial implementation of generic feed consumer with support for checkpointing in an Equinox stream (HT @scrwtp who provided the baseline impl in Propulsion.SqlStreamStore
) #106Propulsion.CosmosStore.CosmosStoreSource
: NOTE subject to breaking changes in 2.11.0
as it will be rebased on Microsoft.Azure.Cosmos
#103Equinox.CosmosStore
v 3.0.0
Equinox.Cosmos
v [2.6.0,2.99.0]
Equinox.EventStore
v [2.6.0,2.99.0]
Kafka.StreamsConsumerStats
+ Streams.Projector.Stats
as Propulsion.Streams.Stats
Targets Equinox.Cosmos 2.6.0
, Equinox.CosmosStore 3.0.0
, Equinox.EventStore 2.6.0
, SqlStreamStore 1.2.0-beta.8
, FsCodec 2.0.0
, FsKafka 1.5.x
, Microsoft.Azure.DocumentDB.ChangeFeedProcessor
v 2.2.8
, prometheus-net
v 3.6.0
See ChangeLog
Targets Equinox.Cosmos 2.3.0
, Equinox.EventStore 2.0.0
, SqlStreamStore 1.2.0-beta.8
, FsCodec 2.0.0
, FsKafka 1.5.x