We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 800a39e commit 7457c73Copy full SHA for 7457c73
sdk/metric/exemplar/storage.go
@@ -43,6 +43,12 @@ func (r *storage) Collect(dest *[]Exemplar) {
43
*dest = reset(*dest, len(r.measurements), len(r.measurements))
44
var n int
45
for _, val := range r.measurements {
46
+ // For performance reasons, this iterates over measurements
47
+ // concurrently with new measurements being written. This means we do
48
+ // not get a point-in-time snapshot of the state of the reservoir.
49
+ // This means that for sequential Offer calls, a later Offer call may
50
+ // be collected and an earlier call not collected if they are written
51
+ // to different indicies.
52
loaded := val.Load()
53
if loaded == nil {
54
continue
0 commit comments