Skip to content

Commit f43a5fe

Browse files
author
ivan-skryabin
committed
feat grpc: log grpc response/request size
Log uncompressed grpc requests and responses size on both client and server sides. commit_hash:37ea52724c71131972e257b20a22aab6007251d8
1 parent ead6493 commit f43a5fe

File tree

2 files changed

+2
-0
lines changed

2 files changed

+2
-0
lines changed

grpc/src/ugrpc/client/middlewares/log/middleware.cpp

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -84,6 +84,7 @@ void Middleware::PostRecvMessage(MiddlewareCallContext& context, const google::p
8484
logging::LogExtra extra{
8585
{ugrpc::impl::kTypeTag, "response"},
8686
{ugrpc::impl::kBodyTag, GetMessageForLogging(message, settings_)},
87+
{ugrpc::impl::kMessageMarshalledLenTag, message.ByteSizeLong()},
8788
};
8889
if (context.IsServerStreaming()) {
8990
logger.Log(settings_.msg_log_level, "gRPC response stream message", std::move(extra));

grpc/src/ugrpc/server/middlewares/log/middleware.cpp

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -96,6 +96,7 @@ void Middleware::PreSendMessage(MiddlewareCallContext& context, google::protobuf
9696
{ugrpc::impl::kTypeTag, "response"},
9797
{"grpc_code", "OK"}, // TODO: revert
9898
{ugrpc::impl::kBodyTag, GetMessageForLogging(response, settings_)},
99+
{ugrpc::impl::kMessageMarshalledLenTag, response.ByteSizeLong()},
99100
};
100101
if (context.IsServerStreaming()) {
101102
logger.Log(settings_.msg_log_level, "gRPC response stream message", std::move(extra));

0 commit comments

Comments
 (0)