Assorted typos

Author: bartelink

README.md

@@ -308,10 +308,10 @@ A key facility of this repo is being able to run load tests, either in process a
 
 - `Favorite` - Simulate a very enthusiastic user that favorites something once per second
   - the test generates an ever-growing state that can only be managed efficiently if you apply either caching, snapshotting or both
-  - NB due to being unbounded, even Rolling Snapshots or Unfolds will eventually hit the Store's limits (4MB/event for EventStore, 3MB/Item (document) for CosmosDB)
+  - NB due to being unbounded, `RollingSnapshots`, `Snapshot`, `Unfolded` etc. will eventually hit the Store's limits (4MB/event for EventStore, 3MB/Item (document) for CosmosDB)
 - `SaveForLater` - Simulate a happy shopper that saves 3 items per second, and empties the Save For Later list whenever it is full (when it hits 50 items)
   - Snapshotting helps a lot
-  - Caching is not as essential as it is for the `Favorite` test (as long as oyu have either aching or snapshotting, that is)
+  - Caching is not as essential as it is for the `Favorite` test (as long as you have either caching or snapshotting, that is)
 - `Todo` - Keeps a) getting the list b) adding an item c) clearing the list when it hits 1000 items.
   - the `Cleared` event acts as a natural event to use in the `isOrigin` check. This makes snapshotting less crucial than it is, for example, in the case of the `Favorite` test
   - the `-s` parameter can be used to adjust the maximum item text length from the default (`100`, implying average length of 50)

samples/Store/Integration/CartIntegration.fs

@@ -23,7 +23,7 @@ let resolveGesStreamWithRollingSnapshots gateway =
 let resolveGesStreamWithoutCustomAccessStrategy gateway =
     EventStore.Resolver(gateway, codec, fold, initial).Resolve
 
-let resolveCosmosStreamWithProjection gateway =
+let resolveCosmosStreamWithSnapshotStrategy gateway =
     Cosmos.Resolver(gateway, codec, fold, initial, Cosmos.CachingStrategy.NoCaching, Cosmos.AccessStrategy.Snapshot snapshot).Resolve
 let resolveCosmosStreamWithoutCustomAccessStrategy gateway =
     Cosmos.Resolver(gateway, codec, fold, initial, Cosmos.CachingStrategy.NoCaching).Resolve
@@ -78,7 +78,7 @@ type Tests(testOutputHelper) =
     }
 
     [<AutoData(SkipIfRequestedViaEnvironmentVariable="EQUINOX_INTEGRATION_SKIP_COSMOS")>]
-    let ``Can roundtrip against Cosmos, correctly folding the events with With Projection`` args = Async.RunSynchronously <| async {
-        let! service = arrange connectToSpecifiedCosmosOrSimulator createCosmosContext resolveCosmosStreamWithProjection
+    let ``Can roundtrip against Cosmos, correctly folding the events with With Snapshotting`` args = Async.RunSynchronously <| async {
+        let! service = arrange connectToSpecifiedCosmosOrSimulator createCosmosContext resolveCosmosStreamWithSnapshotStrategy
         do! act service args
     }

samples/Store/Integration/LogIntegration.fs

@@ -124,7 +124,7 @@ type Tests() =
         let log = createLoggerWithMetricsExtraction buffer.Enqueue
         let! conn = connectToSpecifiedCosmosOrSimulator log
         let gateway = createCosmosContext conn batchSize
-        let service = Backend.Cart.Service(log, CartIntegration.resolveCosmosStreamWithProjection gateway)
+        let service = Backend.Cart.Service(log, CartIntegration.resolveCosmosStreamWithSnapshotStrategy gateway)
         let itemCount = batchSize / 2 + 1
         let cartId = % Guid.NewGuid()
         do! act buffer service itemCount context cartId skuId "EqxCosmos Tip " // one is a 404, one is a 200

src/Equinox.Cosmos/CosmosInternalJson.fs

@@ -26,7 +26,7 @@ open System.IO
 open System.IO.Compression
 
 /// Manages zipping of the UTF-8 json bytes to make the index record minimal from the perspective of the writer stored proc
-/// Only applied to snapshots in the Index
+/// Only applied to snapshots in the Tip
 type Base64ZipUtf8JsonConverter() =
     inherit JsonConverter()
     let pickle (input : byte[]) : string =

src/Equinox.MemoryStore/MemoryStore.fs

@@ -13,7 +13,7 @@ exception private WrongVersionException of streamName: string * expected: int *
 [<NoEquality; NoComparison>]
 type ConcurrentDictionarySyncResult<'t> = Written of 't | Conflict of int
 
-/// Response type for ConcurrentArrayStore.TrySync to communicate the outcome and updated state of a stream
+/// Response type for VolatileStore.TrySync to communicate the outcome and updated state of a stream
 [<NoEquality; NoComparison>]
 type ConcurrentArraySyncResult<'t> = Written of 't | Conflict of 't
 

tests/Equinox.Cosmos.Integration/CosmosCoreIntegration.fs

@@ -55,7 +55,7 @@ type Tests(testOutputHelper) =
         test <@ AppendResult.Ok 6L = res @>
         test <@ [EqxAct.Append] = capture.ExternalCalls @>
         // We didnt request small batches or splitting so it's not dramatically more expensive to write N events
-        verifyRequestChargesMax 40 // observed 38.95 // was 11
+        verifyRequestChargesMax 41 // observed 40.78 // was 11
     }
 
     // It's conceivable that in the future we might allow zero-length batches as long as a sync mechanism leveraging the etags and unfolds updote mechanisms
@@ -150,7 +150,7 @@ type Tests(testOutputHelper) =
         let extrasCount = match extras with x when x > 50 -> 5000 | x when x < 1 -> 1 | x -> x*100
         let! _pos = ctx.NonIdempotentAppend(stream, TestEvents.Create (int pos,extrasCount))
         test <@ [EqxAct.Append] = capture.ExternalCalls @>
-        verifyRequestChargesMax 300 // 251.39 observed
+        verifyRequestChargesMax 460 // 451.01 observed
         capture.Clear()
 
         let! pos = ctx.Sync(stream,?position=None)

tests/Equinox.Cosmos.Integration/CosmosFixturesInfrastructure.fs

@@ -29,10 +29,10 @@ type AutoDataAttribute() =
 // Derived from https://github.com/damianh/CapturingLogOutputWithXunit2AndParallelTests
 // NB VS does not surface these atm, but other test runners / test reports do
 type TestOutputAdapter(testOutput : Xunit.Abstractions.ITestOutputHelper) =
-    let formatter = Serilog.Formatting.Display.MessageTemplateTextFormatter("{Timestamp:yyyy-MM-dd HH:mm:ss.fff zzz} [{Level}] {Message}{NewLine}{Exception}", null);
+    let formatter = Serilog.Formatting.Display.MessageTemplateTextFormatter("{Timestamp:yyyy-MM-dd HH:mm:ss.fff zzz} [{Level}] {Message}{NewLine}{Properties}{Exception}", null);
     let writeSerilogEvent logEvent =
         use writer = new System.IO.StringWriter()
-        formatter.Format(logEvent, writer);
+        formatter.Format(logEvent, writer)
         writer |> string |> testOutput.WriteLine
     interface Serilog.Core.ILogEventSink with member __.Emit logEvent = writeSerilogEvent logEvent