Target FsCodec 2.3.2, Support metrics for >1 scheduler per process

Versions 2.12.0 and 2.12.1 are unlisted

See ChangeLog

Added

• Prometheus: Propulsion.Streams.Log.LogSink: Support indicating the consumer group name via a Serilog (ForContext) property "group" #137

Changed

• Kafka: Target FsCodec.NewtonsoftJson v 2.3.2 #138
• Prometheus: Propulsion.Streams.Log.LogSink: Replace mandatory group argument with optional defaultGroup to emphasize primacy of "group" Log property #137

Targets (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

Target Equinox 3.0.6, add optional producer args

See ChangeLog

Added

• Kafka.Producers: optional constructor parameters #135 🙏 @avsaditya19

Changed

• CosmosStore: Target Equinox.CosmosStore v 3.0.6#136
• EventStore: Target Equinox.EventStore v 3.0.6 #134

Targets (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

Generalize CosmosStoreSource.Run API as .Start

See ChangeLog

Changed

• CosmosStoreSource: Generalize Run with integrated Ctrl-C handling to Start yielding a Pipeline #133

Targets (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

Add propulsion_scheduler_busy metrics; Rebase SqlStreamStore on Propulsion.Feed

See ChangeLog

Added

• Streams: Added propulsion_scheduler_busy metrics: count and seconds #126

Changed

• Feed.PeriodicSource: Add readTranches parameter to Pump #130
• Feed.PeriodicSource: Add TrancheId parameter to crawl #130
• CosmosStore: Target Equinox.CosmosStore v 3.0.5
• SqlStreamStore: Rebase on Propulsion.Feed.FeedSource #131

Removed

• net461 support #123

Fixed

• StreamsProjector: Fix failure to pump batches when using maxReadAhead of Int32.MaxValue #124

Targets (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

Target Microsoft.Azure.Cosmos 3.0.22

See ChangeLog

Changed

• 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

Add Feed.PeriodicSource+.Prometheus, Target Microsoft.Azure.Cosmos 3.0.22-preview

See ChangeLog

Added

• 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

Changed

• 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)

Removed

• Kafka0: Triggered by removal of underlying FsKafka0 #119
• Kafka: Removed support for net461, triggered by removal of same in underlying FsKafka #119

Fixed

• Fix CI to stop emitting builds with incorrect AssemblyVersion 1.0.0.0 (updated MinVer to 2.5.0)
• Update global.json to use SDK version 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

Target Microsoft.Azure.Cosmos 3.0.20-preview

See ChangeLog

Changed

• CosmosStore: Target Microsoft.Azure.Cosmos v 3.0.20-preview (breaking change vs 3.0.19-preview1) #115

Targets (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

Port CosmosStore to Microsoft.Azure.Cosmos 3.0.19-preview1

See ChangeLog

Changed

• CosmosStore: Port to Equinox.CosmosStore v 3.0.1, Microsoft.Azure.Cosmos v 3.0.19-preview1 #113 #114

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.Cosmos v 3.19-preview1, Microsoft.Azure.DocumentDB.ChangeFeedProcessor v 2.2.8, prometheus-net v 3.6.0

Add Feed, CosmosStore, Prometheus integration; Tune; Target Equinox 2.6+3.0

See ChangeLog

Added

• Prometheus integration
• 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) #106
• Propulsion.CosmosStore.CosmosStoreSource: NOTE subject to breaking changes in 2.11.0 as it will be rebased on Microsoft.Azure.Cosmos #103
• Propulsion.CosmosStore.CosmosStoreSink+CosmosStorePruner - equivalents of features in Propulsion.Cosmos #89
• StreamSpan.Version, SpanResult.NoneProcessed #102
• Streams Scheduler: Tune memory consumption re write positions of inactive streams #94
• StreamsProjector: Tuned submission policy to forward 80% of batches read ahead (except in Kafka case where there's limited benefit so default remains to submit 5 per partition) #105

Changed

• CosmosStore: Target Equinox.CosmosStore v 3.0.0
• Cosmos: Target Equinox.Cosmos v [2.6.0,2.99.0]
• EventStore: Target Equinox.EventStore v [2.6.0,2.99.0]
• lots of finessing of log message text
• Unified Kafka.StreamsConsumerStats + Streams.Projector.Stats as Propulsion.Streams.Stats
• Remove wart from createObserver signature introduced in #91 #101
• Add Major for Propulsion.Tool #92
• Replaced numeric field names with strings in latency percentiles message #93
• Kafka: Replace defaulting of Producer's acks defaulting to Leader with mandatory argument #89

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

Preview release for ChangeFeed Prometheus metrics

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