diff options
author | Devtools Arcadia <arcadia-devtools@yandex-team.ru> | 2022-02-07 18:08:42 +0300 |
---|---|---|
committer | Devtools Arcadia <arcadia-devtools@mous.vla.yp-c.yandex.net> | 2022-02-07 18:08:42 +0300 |
commit | 1110808a9d39d4b808aef724c861a2e1a38d2a69 (patch) | |
tree | e26c9fed0de5d9873cce7e00bc214573dc2195b7 /library/cpp/messagebus/monitoring | |
download | ydb-1110808a9d39d4b808aef724c861a2e1a38d2a69.tar.gz |
intermediate changes
ref:cde9a383711a11544ce7e107a78147fb96cc4029
Diffstat (limited to 'library/cpp/messagebus/monitoring')
-rw-r--r-- | library/cpp/messagebus/monitoring/mon_proto.proto | 55 | ||||
-rw-r--r-- | library/cpp/messagebus/monitoring/ya.make | 15 |
2 files changed, 70 insertions, 0 deletions
diff --git a/library/cpp/messagebus/monitoring/mon_proto.proto b/library/cpp/messagebus/monitoring/mon_proto.proto new file mode 100644 index 00000000000..73b6614481e --- /dev/null +++ b/library/cpp/messagebus/monitoring/mon_proto.proto @@ -0,0 +1,55 @@ +import "library/cpp/monlib/encode/legacy_protobuf/protos/metric_meta.proto"; + +package NBus; + +option java_package = "ru.yandex.messagebus.monitoring.proto"; + +message TMessageStatusRecord { + enum EMessageStatus { + MESSAGE_OK = 0; + MESSAGE_CONNECT_FAILED = 1; + MESSAGE_TIMEOUT = 2; + MESSAGE_SERVICE_UNKNOWN = 3; + MESSAGE_BUSY = 4; + MESSAGE_UNKNOWN = 5; + MESSAGE_DESERIALIZE_ERROR = 6; + MESSAGE_HEADER_CORRUPTED = 7; + MESSAGE_DECOMPRESS_ERROR = 8; + MESSAGE_MESSAGE_TOO_LARGE = 9; + MESSAGE_REPLY_FAILED = 10; + MESSAGE_DELIVERY_FAILED = 11; + MESSAGE_INVALID_VERSION = 12; + MESSAGE_SERVICE_TOOMANY = 13; + MESSAGE_SHUTDOWN = 14; + MESSAGE_DONT_ASK = 15; + } + + optional EMessageStatus Status = 1; + optional uint32 Count = 2; +} + +message TConnectionStatusMonRecord { + optional uint32 SendQueueSize = 1 [ (NMonProto.Metric).Type = GAUGE ]; + // client only + optional uint32 AckMessagesSize = 2 [ (NMonProto.Metric).Type = GAUGE ]; + optional uint32 ErrorCount = 3 [ (NMonProto.Metric).Type = RATE ]; + + optional uint64 WriteBytes = 10 [ (NMonProto.Metric).Type = RATE ]; + optional uint64 WriteBytesCompressed = 11; + optional uint64 WriteMessages = 12 [ (NMonProto.Metric).Type = RATE ]; + optional uint64 WriteSyscalls = 13; + optional uint64 WriteActs = 14; + optional uint64 ReadBytes = 20 [ (NMonProto.Metric).Type = RATE ]; + optional uint64 ReadBytesCompressed = 21; + optional uint64 ReadMessages = 22 [ (NMonProto.Metric).Type = RATE ]; + optional uint64 ReadSyscalls = 23; + optional uint64 ReadActs = 24; + + repeated TMessageStatusRecord ErrorCountByStatus = 25; +} + +message TSessionStatusMonRecord { + optional uint32 InFlight = 1 [ (NMonProto.Metric).Type = GAUGE ]; + optional uint32 ConnectionCount = 2 [ (NMonProto.Metric).Type = GAUGE ]; + optional uint32 ConnectCount = 3 [ (NMonProto.Metric).Type = RATE ]; +} diff --git a/library/cpp/messagebus/monitoring/ya.make b/library/cpp/messagebus/monitoring/ya.make new file mode 100644 index 00000000000..25782492b11 --- /dev/null +++ b/library/cpp/messagebus/monitoring/ya.make @@ -0,0 +1,15 @@ +PROTO_LIBRARY() + +OWNER(g:messagebus) + +PEERDIR( + library/cpp/monlib/encode/legacy_protobuf/protos +) + +SRCS( + mon_proto.proto +) + +EXCLUDE_TAGS(GO_PROTO) + +END() |