Interface PubSubPooler

Source from the content-addressed store, hash-verified

20	}
21
22	type PubSubPooler interface {
23	Stats() *pool.PubSubStats
24	}
25
26	// OTelRecorder is the interface for recording OpenTelemetry metrics.
27

nothing calls this directly

pubSubPoolerAdapterotel.go

mockPoolmaintnotifications/pool_hook_test.go

mockPoolerinternal/auth/streaming/manager_test.g

SingleConnPoolinternal/pool/pool_single.go

PubSubPoolinternal/pool/pubsub.go

ConnPoolinternal/pool/pool.go

StickyConnPoolinternal/pool/pool_sticky.go

no outgoing calls

no test coverage detected

searching dependent graphs…