Skip to content

Add Feed, CosmosStore, Prometheus integration; Tune; Target Equinox 2.6+3.0
Compare
Choose a tag to compare
@bartelink bartelink released this 23 Jun 08:41
· 262 commits to master since this release
2.10.0
54767cb

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

Contributors

scrwtp
Assets 2