Indent Affected cats

jet · Dec 6, 2021 · d623c78 · d623c78
1 parent 29c78b2
commit d623c78
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/src/Propulsion.Cosmos/CosmosSink.fs b/src/Propulsion.Cosmos/CosmosSink.fs
@@ -94,7 +94,7 @@ module Internal =
                     mb exnBytes, fails, failStreams.Count, exnEvents, !rateLimited, rlStreams.Count, !timedOut, toStreams.Count)
                 rateLimited := 0; timedOut := 0; resultExnOther := 0; failStreams.Clear(); rlStreams.Clear(); toStreams.Clear(); exnBytes <- 0L; exnEvents <- 0
             if badCats.Any then
-                log.Warning("Affected cats {@badCats} Too large {tooLarge:n0}r {@tlStreams} Malformed {malformed:n0}r {@mfStreams} Other {other:n0}r {@oStreams}",
+                log.Warning(" Affected cats {@badCats} Too large {tooLarge:n0}r {@tlStreams} Malformed {malformed:n0}r {@mfStreams} Other {other:n0}r {@oStreams}",
                     badCats.StatsDescending |> Seq.truncate 50, !tooLarge, tlStreams |> Seq.truncate 100, !malformed, mfStreams |> Seq.truncate 100, !resultExnOther, oStreams |> Seq.truncate 100)
                 badCats.Clear(); tooLarge := 0; malformed := 0;  resultExnOther := 0; tlStreams.Clear(); mfStreams.Clear(); oStreams.Clear()
             Equinox.Cosmos.Store.Log.InternalMetrics.dump log

diff --git a/src/Propulsion.CosmosStore/CosmosStoreSink.fs b/src/Propulsion.CosmosStore/CosmosStoreSink.fs
@@ -91,7 +91,7 @@ module Internal =
                     mb exnBytes, fails, failStreams.Count, exnEvents, !rateLimited, rlStreams.Count, !timedOut, toStreams.Count)
                 rateLimited := 0; timedOut := 0; resultExnOther := 0; failStreams.Clear(); rlStreams.Clear(); toStreams.Clear(); exnBytes <- 0L; exnEvents <- 0
             if badCats.Any then
-                log.Warning("Affected cats {@badCats} Too large {tooLarge:n0}r {@tlStreams} Malformed {malformed:n0}r {@mfStreams} Other {other:n0}r {@oStreams}",
+                log.Warning(" Affected cats {@badCats} Too large {tooLarge:n0}r {@tlStreams} Malformed {malformed:n0}r {@mfStreams} Other {other:n0}r {@oStreams}",
                     badCats.StatsDescending |> Seq.truncate 50, !tooLarge, tlStreams |> Seq.truncate 100, !malformed, mfStreams |> Seq.truncate 100, !resultExnOther, oStreams |> Seq.truncate 100)
                 badCats.Clear(); tooLarge := 0; malformed := 0;  resultExnOther := 0; tlStreams.Clear(); mfStreams.Clear(); oStreams.Clear()
             Equinox.CosmosStore.Core.Log.InternalMetrics.dump log

diff --git a/src/Propulsion.EventStore/EventStoreSink.fs b/src/Propulsion.EventStore/EventStoreSink.fs
@@ -78,7 +78,7 @@ module Internal =
                     mb exnBytes, fails, failStreams.Count, exnEvents, !timedOut, toStreams.Count)
                 timedOut := 0; resultExnOther := 0; failStreams.Clear(); toStreams.Clear(); exnBytes <- 0L; exnEvents <- 0
             if badCats.Any then
-                log.Warning("Affected cats {@badCats} Other {other:n0}r {@oStreams}",
+                log.Warning(" Affected cats {@badCats} Other {other:n0}r {@oStreams}",
                     badCats.StatsDescending |> Seq.truncate 50, !resultExnOther, oStreams |> Seq.truncate 100)
                 badCats.Clear(); resultExnOther := 0; oStreams.Clear()
             Equinox.EventStore.Log.InternalMetrics.dump log

diff --git a/src/Propulsion/Streams.fs b/src/Propulsion/Streams.fs
@@ -978,7 +978,7 @@ type Stats<'Outcome>(log : ILogger, statsInterval, statesInterval) =
         if resultExnOther <> 0 then
             log.Warning("Exceptions {mb:n0}MB {fails:n0}r {streams:n0}s {events:n0}e", mb exnBytes, resultExnOther, failStreams.Count, exnEvents)
             resultExnOther <- 0; failStreams.Clear(); exnBytes <- 0L; exnEvents <- 0
-            log.Warning("Affected cats {@badCats}", badCats.StatsDescending)
+            log.Warning(" Affected cats {@badCats}", badCats.StatsDescending)
             badCats.Clear()
 
     override this.Handle message =