Skip to content

Commit

Permalink
mb
Browse files Browse the repository at this point in the history
  • Loading branch information
bartelink committed Apr 17, 2019
1 parent 2d8128c commit 26c4985
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion equinox-sync/Sync/EventStoreSource.fs
Original file line number Diff line number Diff line change
Expand Up @@ -146,7 +146,7 @@ let pullAll (slicesStats : SliceStatsBuffer, overallStats : OverallStats) (conn
let streams = batches |> Seq.groupBy (fun b -> b.stream) |> Array.ofSeq
let usedStreams, usedCats = streams.Length, streams |> Seq.map fst |> Seq.distinct |> Seq.length
postBatch currentSlice.NextPosition batches
Log.Information("Read {pos,10} {pct:p1} {ft:n3}s {mb:#0.000}MB {count,4} {categories,4}c {streams,4}s {events,4}e Post {pt:n0}ms",
Log.Information("Read {pos,10} {pct:p1} {ft:n3}s {mb:,4#0.0}MB {count,4} {categories,4}c {streams,4}s {events,4}e Post {pt:n0}ms",
range.Current.CommitPosition, range.PositionAsRangePercentage, (let e = sw.Elapsed in e.TotalSeconds), mb batchBytes,
batchEvents, usedCats, usedStreams, batches.Length, postSw.ElapsedMilliseconds)
if not (range.TryNext currentSlice.NextPosition && not once && not currentSlice.IsEndOfStream) then return currentSlice.IsEndOfStream else
Expand Down

0 comments on commit 26c4985

Please sign in to comment.