Skip to content

Commit d623c78

Browse files
committed
Indent Affected cats
1 parent 29c78b2 commit d623c78

4 files changed

Lines changed: 4 additions & 4 deletions

File tree

src/Propulsion.Cosmos/CosmosSink.fs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -94,7 +94,7 @@ module Internal =
9494
mb exnBytes, fails, failStreams.Count, exnEvents, !rateLimited, rlStreams.Count, !timedOut, toStreams.Count)
9595
rateLimited := 0; timedOut := 0; resultExnOther := 0; failStreams.Clear(); rlStreams.Clear(); toStreams.Clear(); exnBytes <- 0L; exnEvents <- 0
9696
if badCats.Any then
97-
log.Warning("Affected cats {@badCats} Too large {tooLarge:n0}r {@tlStreams} Malformed {malformed:n0}r {@mfStreams} Other {other:n0}r {@oStreams}",
97+
log.Warning(" Affected cats {@badCats} Too large {tooLarge:n0}r {@tlStreams} Malformed {malformed:n0}r {@mfStreams} Other {other:n0}r {@oStreams}",
9898
badCats.StatsDescending |> Seq.truncate 50, !tooLarge, tlStreams |> Seq.truncate 100, !malformed, mfStreams |> Seq.truncate 100, !resultExnOther, oStreams |> Seq.truncate 100)
9999
badCats.Clear(); tooLarge := 0; malformed := 0; resultExnOther := 0; tlStreams.Clear(); mfStreams.Clear(); oStreams.Clear()
100100
Equinox.Cosmos.Store.Log.InternalMetrics.dump log

src/Propulsion.CosmosStore/CosmosStoreSink.fs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -91,7 +91,7 @@ module Internal =
9191
mb exnBytes, fails, failStreams.Count, exnEvents, !rateLimited, rlStreams.Count, !timedOut, toStreams.Count)
9292
rateLimited := 0; timedOut := 0; resultExnOther := 0; failStreams.Clear(); rlStreams.Clear(); toStreams.Clear(); exnBytes <- 0L; exnEvents <- 0
9393
if badCats.Any then
94-
log.Warning("Affected cats {@badCats} Too large {tooLarge:n0}r {@tlStreams} Malformed {malformed:n0}r {@mfStreams} Other {other:n0}r {@oStreams}",
94+
log.Warning(" Affected cats {@badCats} Too large {tooLarge:n0}r {@tlStreams} Malformed {malformed:n0}r {@mfStreams} Other {other:n0}r {@oStreams}",
9595
badCats.StatsDescending |> Seq.truncate 50, !tooLarge, tlStreams |> Seq.truncate 100, !malformed, mfStreams |> Seq.truncate 100, !resultExnOther, oStreams |> Seq.truncate 100)
9696
badCats.Clear(); tooLarge := 0; malformed := 0; resultExnOther := 0; tlStreams.Clear(); mfStreams.Clear(); oStreams.Clear()
9797
Equinox.CosmosStore.Core.Log.InternalMetrics.dump log

src/Propulsion.EventStore/EventStoreSink.fs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,7 @@ module Internal =
7878
mb exnBytes, fails, failStreams.Count, exnEvents, !timedOut, toStreams.Count)
7979
timedOut := 0; resultExnOther := 0; failStreams.Clear(); toStreams.Clear(); exnBytes <- 0L; exnEvents <- 0
8080
if badCats.Any then
81-
log.Warning("Affected cats {@badCats} Other {other:n0}r {@oStreams}",
81+
log.Warning(" Affected cats {@badCats} Other {other:n0}r {@oStreams}",
8282
badCats.StatsDescending |> Seq.truncate 50, !resultExnOther, oStreams |> Seq.truncate 100)
8383
badCats.Clear(); resultExnOther := 0; oStreams.Clear()
8484
Equinox.EventStore.Log.InternalMetrics.dump log

src/Propulsion/Streams.fs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -978,7 +978,7 @@ type Stats<'Outcome>(log : ILogger, statsInterval, statesInterval) =
978978
if resultExnOther <> 0 then
979979
log.Warning("Exceptions {mb:n0}MB {fails:n0}r {streams:n0}s {events:n0}e", mb exnBytes, resultExnOther, failStreams.Count, exnEvents)
980980
resultExnOther <- 0; failStreams.Clear(); exnBytes <- 0L; exnEvents <- 0
981-
log.Warning("Affected cats {@badCats}", badCats.StatsDescending)
981+
log.Warning(" Affected cats {@badCats}", badCats.StatsDescending)
982982
badCats.Clear()
983983

984984
override this.Handle message =

0 commit comments

Comments
 (0)