@@ -95,7 +95,7 @@ module Internal =
95
95
let interval = StopwatchInterval( startTicks, System.Diagnostics.Stopwatch.GetTimestamp())
96
96
let log = let evt = Log.Metric.Index { database = container.Database.Id; container = container.Id; stream = cat + FsCodec.StreamName.Category.SeparatorStr
97
97
interval = interval; bytes = totalOds; count = items; ru = totalRu } in log |> Log.event evt
98
- log.Information( " EqxCosmos {action:l} {count} ({trips}r {totalRtt:f0}ms; {rdc}i {rds:f2}>{ods:f2} MiB) {rc:f2} RU {latency } ms" ,
98
+ log.Information( " EqxCosmos {action:l} {count} ({trips}r {totalRtt:f0}ms; {rdc}i {rds:f2}>{ods:f2} MiB) {rc:f2} RU {lat:n0 } ms" ,
99
99
" Index" , items, responses, totalRtt.TotalMilliseconds, totalRdc, miB totalRds, miB totalOds, totalRu, interval.ElapsedMilliseconds) }
100
100
/// Runs a query that can by hydrated as 'T
101
101
let enum < 'T > ( log : ILogger ) ( container : Container ) cat ( queryDefinition : QueryDefinition ): TaskSeq < 'T > =
@@ -117,7 +117,7 @@ module Internal =
117
117
let totalOds , totalRu = m.OutputDocumentSize, rsp.RequestCharge
118
118
let log = let evt = Log.Metric.Index { database = container.Database.Id; container = container.Id; stream = cat + FsCodec.StreamName.Category.SeparatorStr
119
119
interval = interval; bytes = int totalOds; count = - 1 ; ru = totalRu } in log |> Log.event evt
120
- log.Information( " EqxCosmos {action:l} {cat} {count} ({rdc}i {rds:f2}>{ods:f2} MiB) {rc} RU {latency } ms" ,
120
+ log.Information( " EqxCosmos {action:l} {cat} {count} ({rdc}i {rds:f2}>{ods:f2} MiB) {rc} RU {lat:n0 } ms" ,
121
121
op, cat, summary, m.RetrievedDocumentCount, miB m.RetrievedDocumentSize, miB totalOds, totalRu, interval.ElapsedMilliseconds)
122
122
return res }
123
123
/// Runs query.CountAsync, with instrumentation equivalent to what query provides
0 commit comments