type google.golang.org/grpc/stats.Handler
22 uses
google.golang.org/grpc/stats (current package)
handlers.go#L53: type Handler interface {
google.golang.org/grpc
clientconn.go#L682: statsHandler stats.Handler
dialoptions.go#L523: func WithStatsHandler(h stats.Handler) DialOption {
server.go#L130: statsHandler stats.Handler
server.go#L167: statsHandlers []stats.Handler
server.go#L542: func StatsHandler(h stats.Handler) ServerOption {
stream.go#L655: statsHandler stats.Handler
stream.go#L1652: statsHandler stats.Handler
google.golang.org/grpc/internal/stats
metrics_recorder_list.go#L41: func NewMetricsRecorderList(shs []stats.Handler) *MetricsRecorderList {
stats.go#L28: handlers []stats.Handler
stats.go#L35: func NewCombinedHandler(handlers ...stats.Handler) stats.Handler {
google.golang.org/grpc/internal/transport
client_stream.go#L65: statsHandler stats.Handler // nil for internal streams (e.g., health check, ORCA) where telemetry is not supported.
handler_server.go#L53: func NewServerHandlerTransport(w http.ResponseWriter, r *http.Request, stats stats.Handler, bufferPool mem.BufferPool) (ServerTransport, error) {
handler_server.go#L173: stats stats.Handler
http2_client.go#L110: statsHandler stats.Handler
http2_client.go#L490: func (t *http2Client) newStream(ctx context.Context, callHdr *CallHdr, handler stats.Handler) *ClientStream {
http2_client.go#L757: func (t *http2Client) NewStream(ctx context.Context, callHdr *CallHdr, handler stats.Handler) (*ClientStream, error) {
http2_server.go#L92: stats stats.Handler
transport.go#L503: StatsHandler stats.Handler
transport.go#L537: StatsHandlers []stats.Handler
transport.go#L626: NewStream(ctx context.Context, callHdr *CallHdr, handler stats.Handler) (*ClientStream, error)