Compare commits
2 commits
feature/ad
...
master
Author | SHA1 | Date | |
---|---|---|---|
93b681a202 | |||
d34e1329c8 |
3 changed files with 12 additions and 3 deletions
|
@ -15,6 +15,9 @@ var clientMetrics = grpcprom.NewClientMetrics(
|
|||
grpcprom.WithClientStreamRecvHistogram(
|
||||
grpcprom.WithHistogramBuckets(prometheus.DefBuckets),
|
||||
),
|
||||
grpcprom.WithClientStreamSendHistogram(
|
||||
grpcprom.WithHistogramBuckets(prometheus.DefBuckets),
|
||||
),
|
||||
)
|
||||
|
||||
func init() {
|
||||
|
@ -57,6 +60,12 @@ func init() {
|
|||
Help: "Histogram of response latency (seconds) of the gRPC single message receive.",
|
||||
VariableLabels: []string{"grpc_type", "grpc_service", "grpc_method"},
|
||||
},
|
||||
{
|
||||
Name: "grpc_client_msg_send_handling_seconds",
|
||||
Type: dto.MetricType_HISTOGRAM.String(),
|
||||
Help: "Histogram of response latency (seconds) of the gRPC single message send.",
|
||||
VariableLabels: []string{"grpc_type", "grpc_service", "grpc_method"},
|
||||
},
|
||||
}
|
||||
metrics.MustRegister(clientMetrics, descs...)
|
||||
}
|
||||
|
|
|
@ -82,7 +82,7 @@ func main() {
|
|||
cc, err := grpc.NewClient(":7000",
|
||||
grpc.WithTransportCredentials(insecure.NewCredentials()),
|
||||
grpc.WithChainUnaryInterceptor(
|
||||
tracing_grpc.NewUnaryClientInteceptor(),
|
||||
tracing_grpc.NewUnaryClientInterceptor(),
|
||||
verifyClientTraceID,
|
||||
),
|
||||
grpc.WithChainStreamInterceptor(
|
||||
|
|
|
@ -15,8 +15,8 @@ import (
|
|||
"google.golang.org/grpc/status"
|
||||
)
|
||||
|
||||
// NewUnaryClientInteceptor creates new gRPC unary interceptor to save gRPC client traces.
|
||||
func NewUnaryClientInteceptor() grpc.UnaryClientInterceptor {
|
||||
// NewUnaryClientInterceptor creates new gRPC unary interceptor to save gRPC client traces.
|
||||
func NewUnaryClientInterceptor() grpc.UnaryClientInterceptor {
|
||||
return func(ctx context.Context, method string, req, reply any, cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error {
|
||||
ctx, span := startClientSpan(ctx, cc, method)
|
||||
defer span.End()
|
||||
|
|
Loading…
Add table
Reference in a new issue