Skip to content

Releases: jet/propulsion

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

10 Mar 17:55
Compare
Choose a tag to compare

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

28 Jan 12:52
Compare
Choose a tag to compare

See ChangeLog

Added

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

20 Dec 15:13
Compare
Choose a tag to compare

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

06 Dec 15:57
Compare
Choose a tag to compare

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

19 Oct 00:54
Compare
Choose a tag to compare

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

18 Oct 14:28
Compare
Choose a tag to compare

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

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

23 Jun 12:03
Compare
Choose a tag to compare

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

23 Jun 12:01
Compare
Choose a tag to compare

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

23 Jun 08:41
Compare
Choose a tag to compare

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

03 Dec 13:17
Compare
Choose a tag to compare

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