blob: 5373fa1616a0eb2cea63a00ea62a7047a5b0587e (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
|
discard """
matrix: "-d:nimNoLentIterators --mm:arc"
output: '''PUSH DATA: {"test.message":{"test":{"nested":"v1"}}}'''
joinable: false
"""
# bug #22748
import std/[json, typetraits, times]
# publish
proc publish*[T](payload: T) =
discard
type MetricsPoint* = JsonNode
proc push*(stat: string, data: JsonNode, usec: int64 = 0) =
let payload = newJObject()
# this results in a infinite recursion unless we deepCopy()
payload[stat] = data #.deepCopy
echo "PUSH DATA: ", payload
publish[MetricsPoint](payload)
var scopes {.threadvar.}: seq[JsonNode]
type WithTimeCallback*[T] = proc(data: var JsonNode): T
proc pushScoped*[T](metric: string, blk: WithTimeCallback[T]): T {.gcsafe.} =
scopes.add newJObject()
defer: discard scopes.pop()
let stc = (cpuTime() * 1000_000).int64
result = blk(scopes[^1])
let dfc = (cpuTime() * 1000_000).int64 - stc
push(metric, scopes[^1], dfc)
# demo code
discard pushScoped[int]("test.message") do (data: var JsonNode) -> int:
data["test"] = %*{
"nested": "v1"
}
|