Skip to content

Latest commit

 

History

History
842 lines (545 loc) · 40.1 KB

CHANGELOG.md

File metadata and controls

842 lines (545 loc) · 40.1 KB
Raw

Changelog

The repo is versioned based on SemVer 2.0 using the tiny-but-mighty MinVer from @adamralph. See here for more information on how it works.

All notable changes to this project will be documented in this file. The format is based on Keep a Changelog.

The Unreleased section name is replaced by the expected version of next release. A stable version's log contains all changes between that version and the previous stable version (can duplicate the prereleases logs).

Unreleased

Added

  • Feed: Monitor.AwaitCompletion enables quasi deterministic waiting for the processing of async reactions within integration tests #170
  • Feed: Checkpoint enables committing progress (and obtaining the achieved positions) without stopping the Sink #162
  • Feed.SinglePassFeedSource: Coordinates reads of a set of tranches until each reaches its Tail #179
  • Streams.Stats.abendThreshold: Abends Sink's processing with a HealthCheckException if a stream continually fails to progress, or continually errors with non-transient exceptions #246
  • Streams.Stats.Categorize: Break down ok handler outcomes by stream category #258
  • Streams.Stats.Latency.Record(Ok|Outcom|Exn): Gather custom Handler latency metrics #258
  • StreamFilter: Generic logic for filtering source events based on Category name, Stream name or Event type #252
  • Ingester, Sinks: Expose optional ingesterStateInterval and commitInterval control on Sink factories #154 #239
  • Scheduler: Split out stats re rateLimited and timedOut vs exceptions #194
  • Scheduler: Added index, eventType to error logging #237
  • Scheduler: purgeInterval to control memory usage #97
  • Scheduler: wakeForResults option to maximize throughput (without having to drop sleep interval to zero) #161
  • Internal.Async.AwaitKeyboardInterruptAsTaskCanceledException: Honored cancellation; moved to Propulsion.Internal #160
  • Propulsion.EventStoreDb: Ported EventStore to target Equinox.EventStore >= 4.0.0 (using the gRPC interface) #139
  • Propulsion.CosmosStore3: Special cased version of Propulsion.CosmosStore to target Equinox.CosmosStore v [3.0.7-3.99.0] Deprecated; Please migrate to Propulsion.CosmosStore by updating Equinox.CosmosStore dependencies to 4.0.0 #139
  • Propulsion.DynamoStore: Equinox.CosmosStore-equivalent functionality for Equinox.DynamoStore. Combines elements of CosmosStore, SqlStreamStore, Feed #140 #140 #177
  • Propulsion.MessageDb: FeedSource and CheckpointStore for MessageDb #181 🙏 @nordfjord
  • Propulsion.MemoryStore: MemoryStoreSource to align with other sources for integration testing. Includes deterministic AwaitCompletion as per Propulsion.Feed-based Sources #165
  • Propulsion.SqlStreamStore: Added startFromTail #173
  • Propulsion.Tool: checkpoint commandline option; enables viewing or overriding checkpoints #141
  • Propulsion.Tool: sync <kafka|stats> supports from json source option #250
  • Propulsion.Tool: Add support for autoscaling throughput of Cosmos containers and databases #142 🙏 @brihadish
  • Propulsion.Tool: sync cosmos from <cosmos|json> #252 #263

Changed

  • Targeted net6.0 with 6.0.300 SDK, FSharp.Core v 6.0.0, FSharp.Control.TaskSeq v 0.4.0, MathNet.Numerics v 4.15.0
  • Changed all Tuple types to struct tuples (System.ValueTuple) #169
  • Changed all Async to Task #192
  • Dispatcher: Replaced GetConsumingEnumerable with System.Threading.Channels #155
  • Ingester,Submitter: Replaced Async.Sleep with Task.WhenAny; Condensed logging #154
  • Pipeline: Renamed AwaitShutdown to Await, added Wait #192
  • Projector: Replaced Async with task for projector supervision #156
  • Scheduler: Replaced Concurrent* with System.Threading.Channels #156
  • Scheduler: Struct/voption conversions; buffer reuse #157
  • Scheduler: Replaced Thead.Sleep with Task.WhenAny; Added Sleep time logging #161
  • Streams: Changed dominant ITimelineEvent EventBody type from byte[] to System.ReadOnlyMemory<byte> (Sinks.EventBody) #169 #208
  • Propulsion.CosmosStore: Changed to target Equinox.CosmosStore v 4.0.0 #139
  • Propulsion.CosmosStore.CosmosSource: Changed parsing to use System.Text.Json #139
  • Propulsion.CosmosStore.CosmosStoreSink+CosmosStorePruner: Exposed *Stats #226
  • Propulsion.EventStore: Pinned to target Equinox.EventStore v [3.0.7-3.99.0] Deprecated; Please migrate to Propulsion.EventStoreDb #139
  • Propulsion.EventStoreDb.EventStoreSource: Changed API to matchPropulsion.SqlStreamStore API rather thanPropulsion.EventStore #139
  • Propulsion.Feed: Moved implementations into main Propulsion library. While this adds a FSharp.Control.TaskSeq dependency, it makes maintenance and navigation easier #265
  • Propulsion.Feed,Kafka: Replaced Async with task for supervision #158, #159
  • Propulsion.Kafka: Target FsCodec.NewtonsoftJson v 3.0.0 #139
  • Propulsion.Prometheus: Extracted Propulsion.Prometheus and Propulsion.Feed.Prometheus in order to remove Prometheus dependency from core package #265
  • Propulsion.Tool: project renamed to sync; sources now have a from prefix #252

Removed

  • Streams.StreamSpan: Changed from a record to individual arguments of FsCodec.StreamName and Sinks.Event[] #169 #208
  • Streams.SpanResult: Replaced with int64 to reflect the updated position #264 #208
  • Streams: statsInterval is obtained from the Stats wherever one is supplied #208
  • Propulsion.Cosmos: Should not be in general use - users should port to Propulsion.CosmosStore3, then Propulsion.CosmosStore #193
  • Destructurama.FSharp dependency #152
  • Ingester,Submitter: Removed requirement to specify sleep intervals #154
  • Scheduler: Removed need to tune idleDelay except in extreme circumstances #161

Fixed

  • Propulsion.CosmosStore.CosmosStoreSource: Propagate correlationId/causationId #260
  • Propulsion.SqlStreamStore: Replaced incorrect/meaningless stream name for SqlStreamStoreSource #139
  • Synced AwaitTaskCorrect with official version 3c11142
  • Projector,Ingester,Submitter, Scheduler: Deterministic shutdown via Cancellation and/or unhandled exceptions #154

2.12.2 - 2022-03-10

Changed

  • Kafka: Target FsCodec.NewtonsoftJson v 2.3.2 #138

2.12.1 - 2022-02-15

Added

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

Changed

  • Prometheus: Propulsion.Streams.Log.LogSink: Replace mandatory group argument with optional defaultGroup to emphasize primacy of "group" Log property #137

2.12.0 - 2022-01-28

Added

Changed

  • EventStore: Target Equinox.EventStore v 3.0.6 #136

2.12.0-rc.3 - 2021-12-24

Changed

  • EventStore: Target Equinox.EventStore v 3.0.5 #134

2.12.0-rc.2 - 2021-12-20

Changed

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

2.12.0-rc.1 - 2021-12-06

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

2.11.0 - 2021-10-19

Changed

  • CosmosStore: Target Microsoft.Azure.Cosmos (V3 CFP) 3.0.22

2.11.0-rc3 - 2021-10-18

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.5
  • 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

2.11.0-rc2 - 2021-06-22

Changed

  • CosmosStore: Target Microsoft.Azure.Cosmos (V3 CFP) 3.0.20-preview #115

2.11.0-rc1 - 2021-06-21

Changed

  • CosmosStore: Clean/reorg in preparation for porting to V3 SDK; target Equinox.CosmosStore v 3.0.1 #114
  • CosmosStore: Port from Microsoft.Azure.Documents.ChangeFeedProcessor (V2 CFP) to Microsoft.Azure.Cosmos (V3 CFP) 3.0.19-preview1 #113

2.10.0 - 2021-05-13

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]

2.10.0-rc10 - 2021-05-05

Changed

  • Cosmos: Replace incomplete/inconsistent usage of partitionKeyRangeId and "Range" with partitionId and "Reader" in ChangeFeed ingestion path #112
  • Ingester: Replace "Uncommitted" with "Reader" and "Ahead" terminology, and include partitionId in all messages #112

Removed

  • Kafka.StreamsConsumerStats: replaced by Propulsion.Streams.Stats #111

2.10.0-rc9 - 2021-04-30

Added

  • *.Prometheus.LogSink: Generalized app tag to arbitrary custom tags as per Equinox #287 #109 🙏 @deviousasti

Changed

2.10.0-rc8 - 2021-04-06

Added

  • 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

Changed

  • Moved Propulsion.Streams.Projector.Stats to Propulsion.Streams.Stats #108

2.10.0-rc7 - 2021-03-15

Changed

  • 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

2.10.0-rc6 - 2021-03-13

Added

  • Propulsion.CosmosStore: Included select aspects of Equinox.Cosmos constructs wrt connection logic etc; required until the CosmosStoreSource impl uses V >=3 CosmosClient #104

2.10.0-rc5 - 2021-03-12

Added

  • Propulsion.CosmosStore.CosmosStoreSource - equivalent of feature in Propulsion.Cosmos #103

2.10.0-rc4 - 2021-03-12

Added

  • Propulsion.CosmosStore.CosmosStoreSink+CosmosStorePruner - equivalents of features in Propulsion.Cosmos #89
  • StreamSpan.Version, SpanResult.NoneProcessed #102

Changed

  • Remove wart from createObserver signature introduced in #91 #101

2.10.0-rc3 - 2021-03-04

Added

  • Streams Scheduler: Tune memory consumption re write positions of inactive streams #94

2.10.0-rc2 - 2021-01-27

Added

  • Propulsion.Prometheus: Add Buffer, Cpu and Handler latency metrics to Propulsion.Streams Scheduler #93

Changed

  • Add <RollForward>Major</RollForward> for Propulsion.Tool #92

Fixed

  • Replaced numeric field names with strings in latency percentiles message #93

2.10.0-rc1 - 2020-12-03

Added

  • Propulsion.Cosmos: prometheus-net integration #91

Changed

  • Kafka: Replace defaulting of Producer's acks defaulting to Leader with mandatory argument #89

2.9.1 - 2020-11-09

Fixed

  • Cosmos.CosmosPruner: Fixed off-by-one error that renders pruning inert #88

2.9.0 - 2020-11-04

Added

  • Exposed optional maxEvents and maxBytes arguments for CosmosSink #84

Changed

  • Cosmos: Tweak logging in CosmosSink #85

2.9.0-rc2 - 2020-09-08

Changed

  • Consistently exposed optional idleDelay and pumpInterval arguments for all Projectors and Ingesters #81

Fixed

  • Kafka.StreamsProducerSink: Changed bad default idleDelay from 0ms to 1ms #82

2.9.0-rc1 - 2020-08-31

Added

  • Cosmos: Add CosmosPruner #80

Fixed

  • Corrected Cosmos + Stream Sink error logging #79

2.8.1 - 2020-08-04

Added

  • Kafka.Producer: Expose acks, linger, compression options #78

Changed

  • Kafka: Adjust default linger to 5ms #78

Fixed

2.8.0 - 2020-07-27

Changed

2.7.1 - 2020-07-27

Fixed

  • Fix Projector hang when using >1 Streams Scheduler #74 🙏 @fnipo

2.7.0 - 2020-06-09

Added

  • Propulsion.SqlStreamStore: Reader and checkpoint implementation for SqlStreamStore #72 🙏 @scrwtp

2.6.0 - 2020-05-20

Added

  • Kafka: Add Propulsion.Kafka.ConsumeResultContext and default StreamNameSequenceGenerator.ConsumeResultToStreamEvent #70

Changed

2.5.2 - 2020-05-16

Fixed

  • Kafka: Targets FsKafka/FsKafka0 v 1.5.0-beta.2 to resolve TypeLoadException when using 1.5.0-beta.1

2.5.1 - 2020-05-14 (Unlisted/broken : ☝️)

Fixed

  • EventStoreSource: Fixed obj -> int type discrepancy re #63

2.5.0 - 2020-05-13 (Unlisted/broken ☝️)

Changed

Removed

  • Propulsion.Kafka0 Some Propulsion.Kafka0-namespaced shimming elements are now found in the FsKafka namespace in FsKafka0 #67
  • Propulsion.Kafka: KafkaMonitor is now found in the FsKafka namespace in FsKafka/FsKafka0` (NOTE: integration tests continue to live in this repo) #67

Fixed

  • Kafka: Change buffer grouping to include Topic alongside PartitionId - existing implementation did not guarantee marking progress where consuming from more than one Topic concurrently #63

2.4.3 - 2020-04-27

Changed

  • Revised handle function signatures in Propulsion.Sync.StreamsSync and Propulsion.Streams.StreamsProjector to use Propulsion.Streams.SpanResult representing Write Position updates #62

2.4.2 - 2020-04-27

Changed

  • Mark Scheduler.Stats abstract, reorder/name statsInterval arguments #61

2.4.1 - 2020-04-25

Changed

  • Added abstract HandleExn method to type Stats; removed defaulting of stats arguments in almost all cases #60

2.4.0 - 2020-04-24

Added

  • BREAKING: Revised handle function signatures in Propulsion.Kafka.StreamsConsumer and Propulsion.Streams.StreamsProjector to include a Propulsion.Streams.SpanResult representing Write Position updates #59

Changed

  • Removed egregious int64 from stats handler signatures in Propulsion.Streams.Scheduling.StreamSchedulerStats and Projector.Stats #59
  • Renamed Streams.Sync.StreamsSyncStats and Streams.Scheduling.StreamSchedulerStats to Stats for consistency #59

2.3.0 - 2020-04-22

Added

  • Propulsion.Kafka: StreamNameSequenceGenerator.ConsumeResultToStreamEvent provides a set of helpers for mapping from Kafka ConsumeResults to a StreamEvent for processing #56
  • Propulsion.Kafka.StreamsConsumer.Start: now has a consumeResultToStreamEvents : ConsumeResult<_, _> -> Propulsion.Streams.StreamEvent<_> seq parameter (which can be implemented via StreamNameSequenceGenerator.ConsumeResultToStreamEvent) #56
  • BREAKING: Moved pubternal Propulsion.Kafka.Core.StreamKeyEventSequencer to public Propulsion.Kafka.StreamNameSequenceGenerator #56

Changed

  • BREAKING: Moved Propulsion.Kafka.StreamsConsumer's Start methods to Propulsion.Core.StreamsConsumer (i.e. need to prefix StreamsConsumer to migrate) #56
  • BREAKING: Propulsion.Kafka.Core.StreamKeyEventSequencer.ToStreamEvent becomes Propulsion.Kafka.StreamNameSequenceGenerator.KeyValueToStreamEvent #56

2.2.0 - 2020-04-18

Added

  • Propulsion.Kafka/Kafka0: Exposed Produce API providing ability to customize the Confluent.Kafka API used
  • Propulsion.Kafka: Added Produce API admitting a raw Message
  • Propulsion.Kafka: Added Produce API admitting optional headers

Changed

  • Kafka: Targets FsKafka v 1.4.1
  • Propulsion.Kafka/Kafka0: Replaced ProduceAsync API with Produce that no longer yields a DeliveryReport (this functionality can be replicated via an alternate overload)
  • EventStore: Updated CheckpointSeries to adhere more closely to naming per standardized naming #51

2.1.1 - 2020-03-11

Added

  • StreamsSyncStats: Added missing HandleOk

2.1.0 - 2020-03-11

Added

  • StreamsProducerSink: Added overload to facilitate prepare make production of an output optional and admitting processing of Stats #50

Changed

  • StreamsSync: Add * 'outcome to handle function signature #50
  • Update to 3.1.101 SDK
  • Retarget netcoreapp2.1 apps to netcoreapp3.1 (not least to make tool traverse proxies on Windows)

2.0.0 - 2020-02-19

Changed

  • Target FsCodec.* v 2.0.0, Equinox.* v 2.0.0

2.0.0-rc3 - 2020-02-08

Changed

  • Extend StreamsProjector overloads to enable simplified overriding of Write Position

2.0.0-rc2 - 2020-02-04

Fixed

  • Kafka0: Change "compression.type" to "compression.codec" to correctly support Confluent.Kafka v 0.11.3

2.0.0-rc1 - 2020-01-31

Changed

  • Target FsCodec.* v 2.0.0, Equinox.* v 2.0.0-rc9 #47
  • Use FsCodec.StreamName to replace string names; remove need for categorize functions #47
  • Updated EventStore.Checkpoint to adhere to standard naming/layout (Folds->Fold)

1.5.0 - 2019-12-06

Changed

  • Tool: Change switches (without arguments) to upper case
  • Kafka: Targets FsKafka v 1.3.0
  • Cosmos: Targets Microsoft.Azure.DocumentDB.ChangeFeedProcessor v 2.2.8
  • EventStore: Targets TypeShape v 8.0.1
  • Tool: Uses Argu v 6.0.0
  • Update to Microsoft.SourceLink.GitHub v 1.0.0

1.4.0 - 2019-11-14

Changed

  • Targets Equinox v 2.0.0-rc8, FsCodec v 1.2.1
  • Cosmos: Retarget to specify stores as DocumentClient #40 🙏 @Kelvin4702

1.3.2 - 2019-11-13

Fixed

  • StreamKeyEventSequencer: Handle null keys #43 🙏 @nosman
  • EventStore.Checkpoint: Fix to actually write Checkpointed events #44

1.3.1 - 2019-11-12

Changed

Fixed

  • EventStore: Handle minBatchSize < 128
  • EventStore: Inhibit redundant checkpoint writing as originally intended in 1.0.1

1.3.0 - 2019-10-17

Changed

  • Targets Equinox v 2.0.0-rc7, FsCodec v 1.0.0
  • Updated MinVer to 2.0.0

1.2.1 - 2019-10-11

Added

  • .Kafka.Core.StreamKeyEventSequencer - helper to synthesize a stream index in the event of a source not providing it intrinsically.

Changed

  • .Kafka: Targeted Jet.ConfluentKafka.FSharp v 1.2.0
  • rename offsetCommitInterval to autoCommitInterval to match similar change in Jet.ConfluentKafka.FSharp v 1.2.0
  • Generalize Checkpoints.Folds.transmute to be directly usable #35
  • Updated MinVer to 2.0.0-rc.1

Fixed

  • NullReferenceException when handling null keys/values in Kafka messages #37 🙏 @jgardella

1.2.0 - 2019-09-15

Added

  • honored maxBatchSize in Kafka Consumers #31
  • offsetCommitInterval to Propulsion.Kafka0's KafkaConsumerConfig
  • maximizeOffsetWriting to StreamsConsumer in order to give maximum effect to maxBatchSize limit implemented in #31
  • test suite for StreamsConsumer #32
  • BatchesConsumer: support for custom stream based batch scheduling algorithms #29

Changed

  • Use IIndexedEvent in lieu of IIEvent + index in StreamSpan and StreamEvent #28
  • Shorten Rendered*.parse* to Rendered*.parse #28
  • Updated MinVer to 2.0.0-alpha.2

1.1.1 - 2019-09-07

Changed

  • Targeted Equinox.* v 2.0.0-rc6, FsCodec.* v 1.0.0-rc2 #27

1.1.0 - 2019-08-30

Added

  • Rebased on FcCodec to enable cleaner interop with Equinox. Includes removing redundant Converters and helpers #26
  • Targeted Equinox.* v 2.0.0-rc5 #26

1.0.1 - 2019-08-26

Added

  • EventStore: Switched Checkpoints to correctly only log one event per hour using Equinox RollingUnfolds/transmute mechanism
  • Kafka/Kafka0: Added KafkaMonitor based on Burrow #12 🙏 @jgardella
  • Added overloads, Codec.RenderedSummary and Propulsion.Streams.Sync to support dotnet new proSummaryProjector/Consumer #23

Changed

  • Targeted Equinox.* v 2.0.0-rc3 #22
  • Targeted Equinox.* v 2.0.0-rc4

1.0.1-rc9 - 2019-08-09

Added

  • Propulsion.Tool: initAux (now init) and project facilities moved from Equinox #17
  • Propulsion.Tool: initAux and project facilities moved from Equinox #17

Changed

  • Targeted Equinox.* v 2.0.0-rc2

Fixed

  • Resolve Propulsion.Kafka0 conflicts with Jet.ConfluentKafka.fsharp v0 #19

1.0.1-rc8 - 2019-07-05

Changed

  • Kafka/Kafka0: Tuned stream producer params

1.0.1-rc7 - 2019-07-04

Added

  • Kafka: Log Producer exceptions
  • Kafka: StreamsProducerSink Enable control of maxEvents, maxBytes

Fixed

  • Propulsion/Propulsion.Kafka/Propulsion.Kafka0: Removed IEvent on StreamEvent, IEnumerable<IEvent> on StreamEventSpan

1.0.1-rc6 - 2019-07-03

Changed

  • Kafka/Kafka0: Rename Producers to Producer, add deprecation not to [renamed] degreeOfParallelism parameter

Fixed

  • Kafka0 - added missing error check on produce #14

1.0.1-rc5 - 2019-07-02

Added

  • Propulsion: Implement IEvent on StreamEvent, IEnumerable<IEvent> on StreamEventSpan
  • Propulsion.Kafka: Implemented IEnumerable<IEvent> on RenderedSpan
  • Propulsion.Kafka: Added Parse, parseStreamEvents helpers to RenderedSpan

1.0.1-rc4 - 2019-07-01

Changed

  • .Kafka: Targeted Jet.ConfluentKafka.FSharp v 1.1.0

Fixed

  • Idling logic bug #13
  • EventStoreSource: Gorging -> Tailing transition #10 #13

1.0.1-rc3 - 2019-06-18

Added

  • Core: Average Streams latency measurements/loggging for StreamsConsumer #3
  • Kafka: customize option for ParallelConsumer and StreamsConsumer's .Create methods #3
  • Kafka: producerParallelism option #3
  • Kafka0: Provides source-compatibility with Propulsion.Kafka targeting Jet.ConfluentKafka.FSharp v 0.9.1 / Confluent.Kafka v 1.0.1 #4
  • Kafka/Kafka0: Producers - Common Kafka producer wrapper with metrics #9
  • Kafka/Kafka0: StreamsConsumerStats - Consumer outcome / statistics / logging support #9

Changed

  • Propulsion.Cosmos: Tidied Cosmos ingester lag breakdown
  • Moved RenderedSpan et al to Propulsion.Codec.NewtonsoftJson #5
  • Targeted Jet.ConfluentKafka.FSharp v 1.0.1 #3
  • Targeted Equinox.* v 2.0.0-rc1 #7

1.0.1-rc2 - 2019-06-07

Added

  • Propulsion.EventStore.EventStoreSource (productized from Equinox.Templates's eqxsync) #1

Changed

  • Targets Microsoft.Azure.DocumentDB.ChangeFeedProcessor v 2.2.7, which includes critical lease management improvements

1.0.1-rc1 - 2019-06-03

Added

  • Propulsion.Kafka.Codec.RenderedSpan (nee Equinox.Projection.Codec.RenderedSpan, which is deprecated and is being removed)
  • Propulsion.EventStore, Propulsion.Cosmos (productized from Equinox.Templates's eqxsync and eqxprojector)

Changed

  • Targets Jet.ConfluentKafka.FSharp v 1.0.1

1.0.0-rc13 - 2019-06-01

Added

  • StreamsConsumer and StreamsProducer #35
  • ParallelProducer #36

Changed

  • Split reusable components of ParallelConsumer out into independent Propulsion and Propulsion.Kafka libraries #34

1.0.0-rc12 - 2019-05-31

Fixed

  • Significant tuning / throughput improvements for ParallelConsumer

1.0.0-rc11 - 2019-05-27

Added

  • ParallelConsumer #33

squashed prior to initial relevant commit

(Stripped down repo for history purposes, see master branch of Jet.ConfluentKafka.FSharp for complete history prior to 1.0.0-rc13)