MCPcopy
hub / github.com/segmentio/kafka-go / observe

Method observe

stats.go:55–57  ·  view source on GitHub ↗
(v int64)

Source from the content-addressed store, hash-verified

53}
54
55func (g *gauge) observe(v int64) {
56 atomic.StoreInt64(g.ptr(), v)
57}
58
59func (g *gauge) snapshot() int64 {
60 return atomic.LoadInt64(g.ptr())

Callers 9

observeMethod · 0.45
runMethod · 0.45
readLagMethod · 0.45
runMethod · 0.45
initializeMethod · 0.45
readMethod · 0.45
NewWriterFunction · 0.45
awaitBatchMethod · 0.45
writeBatchMethod · 0.45

Calls 1

ptrMethod · 0.95

Tested by

no test coverage detected