Versions in this module Expand all Collapse all v0 v0.24.2 Aug 29, 2023 v0.24.1 Dec 14, 2022 Changes in this version + var ClientCompletedRPCsView = &view.View + var ClientReceivedBytesPerRPC = stats.Int64("grpc.io/client/received_bytes_per_rpc", ...) + var ClientReceivedBytesPerRPCView = &view.View + var ClientReceivedMessagesPerRPC = stats.Int64("grpc.io/client/received_messages_per_rpc", ...) + var ClientReceivedMessagesPerRPCView = &view.View + var ClientRoundtripLatency = stats.Float64("grpc.io/client/roundtrip_latency", ...) + var ClientRoundtripLatencyView = &view.View + var ClientSentBytesPerRPC = stats.Int64("grpc.io/client/sent_bytes_per_rpc", ...) + var ClientSentBytesPerRPCView = &view.View + var ClientSentMessagesPerRPC = stats.Int64("grpc.io/client/sent_messages_per_rpc", ...) + var ClientSentMessagesPerRPCView = &view.View + var ClientServerLatency = stats.Float64("grpc.io/client/server_latency", ...) + var ClientServerLatencyView = &view.View + var ClientStartedRPCs = stats.Int64("grpc.io/client/started_rpcs", "Number of started client RPCs.", ...) + var ClientStartedRPCsView = &view.View + var DefaultBytesDistribution = view.Distribution(1024, 2048, 4096, 16384, 65536, 262144, 1048576, 4194304, 16777216, 67108864, ...) + var DefaultClientViews = []*view.View + var DefaultMessageCountDistribution = view.Distribution(1, 2, 4, 8, 16, 32, 64, 128, 256, 512, 1024, 2048, 4096, 8192, 16384, 32768, ...) + var DefaultMillisecondsDistribution = view.Distribution(0.01, 0.05, 0.1, 0.3, 0.6, 0.8, 1, 2, 3, 4, 5, 6, 8, 10, 13, 16, 20, 25, 30, ...) + var DefaultServerViews = []*view.View + var KeyClientMethod = tag.MustNewKey("grpc_client_method") + var KeyClientStatus = tag.MustNewKey("grpc_client_status") + var KeyServerMethod = tag.MustNewKey("grpc_server_method") + var KeyServerStatus = tag.MustNewKey("grpc_server_status") + var ServerCompletedRPCsView = &view.View + var ServerLatency = stats.Float64("grpc.io/server/server_latency", ...) + var ServerLatencyView = &view.View + var ServerReceivedBytesPerRPC = stats.Int64("grpc.io/server/received_bytes_per_rpc", ...) + var ServerReceivedBytesPerRPCView = &view.View + var ServerReceivedMessagesPerRPC = stats.Int64("grpc.io/server/received_messages_per_rpc", ...) + var ServerReceivedMessagesPerRPCView = &view.View + var ServerSentBytesPerRPC = stats.Int64("grpc.io/server/sent_bytes_per_rpc", ...) + var ServerSentBytesPerRPCView = &view.View + var ServerSentMessagesPerRPC = stats.Int64("grpc.io/server/sent_messages_per_rpc", ...) + var ServerSentMessagesPerRPCView = &view.View + var ServerStartedRPCs = stats.Int64("grpc.io/server/started_rpcs", "Number of started server RPCs.", ...) + var ServerStartedRPCsView = &view.View + type ClientHandler struct + StartOptions trace.StartOptions + func (c *ClientHandler) HandleConn(ctx context.Context, cs stats.ConnStats) + func (c *ClientHandler) HandleRPC(ctx context.Context, rs stats.RPCStats) + func (c *ClientHandler) TagConn(ctx context.Context, cti *stats.ConnTagInfo) context.Context + func (c *ClientHandler) TagRPC(ctx context.Context, rti *stats.RPCTagInfo) context.Context + type ServerHandler struct + IsPublicEndpoint bool + StartOptions trace.StartOptions + func (s *ServerHandler) HandleConn(ctx context.Context, cs stats.ConnStats) + func (s *ServerHandler) HandleRPC(ctx context.Context, rs stats.RPCStats) + func (s *ServerHandler) TagConn(ctx context.Context, cti *stats.ConnTagInfo) context.Context + func (s *ServerHandler) TagRPC(ctx context.Context, rti *stats.RPCTagInfo) context.Context
Go to main page