MCPcopy
hub / github.com/IBM/sarama / newCleanupRegistry

Function newCleanupRegistry

metrics.go:55–60  ·  view source on GitHub ↗
(parent metrics.Registry)

Source from the content-addressed store, hash-verified

53}
54
55func newCleanupRegistry(parent metrics.Registry) metrics.Registry {
56 return &cleanupRegistry{
57 parent: parent,
58 metrics: map[string]struct{}{},
59 }
60}
61
62func (r *cleanupRegistry) Each(fn func(string, any)) {
63 r.mutex.RLock()

Callers 6

newConsumerFunction · 0.85
OpenMethod · 0.85
newConsumerGroupFunction · 0.85
newAsyncProducerFunction · 0.85

Calls

no outgoing calls