feat: adding Sent and Received bytes per message metrics for peers

sync/firewall/firewall.go

@@ -100,10 +100,10 @@ func (f *Firewall) decodeBundle(r io.Reader, pid peer.ID) (*bundle.Bundle, error
 	bdl := new(bundle.Bundle)
 	bytesRead, err := bdl.Decode(r)
 	if err != nil {
-		f.peerSet.IncreaseReceivedBytesCounter(pid, message.TypeUnspecified, bytesRead)
+		f.peerSet.IncreaseReceivedBytesCounter(pid, message.TypeUnspecified, int64(bytesRead))
 		return nil, errors.Errorf(errors.ErrInvalidMessage, err.Error())
 	}
-	f.peerSet.IncreaseReceivedBytesCounter(pid, bdl.Message.Type(), bytesRead)
+	f.peerSet.IncreaseReceivedBytesCounter(pid, bdl.Message.Type(), int64(bytesRead))
 
 	return bdl, nil
 }

sync/peerset/peer.go

@@ -6,6 +6,7 @@ import (
 	"github.com/libp2p/go-libp2p/core/peer"
 	"github.com/pactus-project/pactus/crypto/bls"
 	"github.com/pactus-project/pactus/crypto/hash"
+	"github.com/pactus-project/pactus/sync/bundle/message"
 	"github.com/pactus-project/pactus/util"
 )
 
@@ -26,7 +27,8 @@ type Peer struct {
 	Height          uint32
 	ReceivedBundles int
 	InvalidBundles  int
-	ReceivedBytes   int
+	ReceivedBytes   map[message.Type]int64
+	SentBytes       map[message.Type]int64
 	SendSuccess     int
 	SendFailed      int
 }
@@ -36,6 +38,8 @@ func NewPeer(peerID peer.ID) *Peer {
 		ConsensusKeys: make(map[bls.PublicKey]bool),
 		Status:        StatusCodeUnknown,
 		PeerID:        peerID,
+		ReceivedBytes: make(map[message.Type]int64),
+		SentBytes:     make(map[message.Type]int64),
 	}
 }
 

sync/peerset/peer_set.go

@@ -1,6 +1,7 @@
 package peerset
 
 import (
+	"fmt"
 	"sync"
 	"time"
 
@@ -23,8 +24,8 @@ type PeerSet struct {
 	nextSessionID      int
 	maxClaimedHeight   uint32
 	sessionTimeout     time.Duration
-	totalSentBytes     int
-	totalReceivedBytes int
+	totalSentBytes     int64
+	totalReceivedBytes int64
 	sentBytes          map[message.Type]int64
 	receivedBytes      map[message.Type]int64
 	startedAt          time.Time
@@ -311,23 +312,29 @@ func (ps *PeerSet) IncreaseInvalidBundlesCounter(pid peer.ID) {
 	p.InvalidBundles++
 }
 
-func (ps *PeerSet) IncreaseReceivedBytesCounter(pid peer.ID, msgType message.Type, c int) {
+func (ps *PeerSet) IncreaseReceivedBytesCounter(pid peer.ID, msgType message.Type, c int64) {
 	ps.lk.Lock()
 	defer ps.lk.Unlock()
 
 	p := ps.mustGetPeer(pid)
-	p.ReceivedBytes += c
+	fmt.Println(&p)
+	p.ReceivedBytes[msgType] += c
 
 	ps.totalReceivedBytes += c
-	ps.receivedBytes[msgType] += int64(c)
+	ps.receivedBytes[msgType] += c
 }
 
-func (ps *PeerSet) IncreaseSentBytesCounter(msgType message.Type, c int) {
+func (ps *PeerSet) IncreaseSentBytesCounter(msgType message.Type, c int64, pid *peer.ID) {
 	ps.lk.Lock()
 	defer ps.lk.Unlock()
 
 	ps.totalSentBytes += c
-	ps.sentBytes[msgType] += int64(c)
+	ps.sentBytes[msgType] += c
+
+	if pid != nil {
+		p := ps.mustGetPeer(*pid)
+		p.SentBytes[msgType] += c
+	}
 }
 
 func (ps *PeerSet) IncreaseSendSuccessCounter(pid peer.ID) {
@@ -346,14 +353,14 @@ func (ps *PeerSet) IncreaseSendFailedCounter(pid peer.ID) {
 	p.SendFailed++
 }
 
-func (ps *PeerSet) TotalSentBytes() int {
+func (ps *PeerSet) TotalSentBytes() int64 {
 	ps.lk.RLock()
 	defer ps.lk.RUnlock()
 
 	return ps.totalSentBytes
 }
 
-func (ps *PeerSet) TotalReceivedBytes() int {
+func (ps *PeerSet) TotalReceivedBytes() int64 {
 	ps.lk.RLock()
 	defer ps.lk.RUnlock()
 

sync/peerset/peer_set_test.go

@@ -73,28 +73,35 @@ func TestPeerSet(t *testing.T) {
 		peerSet.IncreaseInvalidBundlesCounter(pid1)
 		peerSet.IncreaseReceivedBundlesCounter(pid1)
 		peerSet.IncreaseReceivedBytesCounter(pid1, message.TypeBlocksResponse, 100)
-		peerSet.IncreaseSentBytesCounter(message.TypeBlocksRequest, 200)
+		peerSet.IncreaseReceivedBytesCounter(pid1, message.TypeTransactions, 150)
+		peerSet.IncreaseSentBytesCounter(message.TypeBlocksRequest, 200, nil)
+		peerSet.IncreaseSentBytesCounter(message.TypeBlocksRequest, 250, &pid1)
 		peerSet.IncreaseSendFailedCounter(pid1)
 		peerSet.IncreaseSendSuccessCounter(pid1)
 
 		peer1 := peerSet.getPeer(pid1)
 
 		receivedBytes := make(map[message.Type]int64)
 		receivedBytes[message.TypeBlocksResponse] = 100
+		receivedBytes[message.TypeTransactions] = 150
 
 		sentBytes := make(map[message.Type]int64)
-		sentBytes[message.TypeBlocksRequest] = 200
+		sentBytes[message.TypeBlocksRequest] = 450
 
 		assert.Equal(t, peer1.InvalidBundles, 1)
 		assert.Equal(t, peer1.ReceivedBundles, 1)
-		assert.Equal(t, peer1.ReceivedBytes, 100)
+		assert.Equal(t, peer1.ReceivedBytes[message.TypeBlocksResponse], int64(100))
+		assert.Equal(t, peer1.ReceivedBytes[message.TypeTransactions], int64(150))
 		assert.Equal(t, peer1.SendFailed, 1)
 		assert.Equal(t, peer1.SendSuccess, 1)
-		assert.Equal(t, peerSet.TotalReceivedBytes(), 100)
+		assert.Equal(t, peer1.SentBytes[message.TypeBlocksRequest], int64(250))
+
+		assert.Equal(t, peerSet.TotalReceivedBytes(), int64(250))
 		assert.Equal(t, peerSet.ReceivedBytesMessageType(message.TypeBlocksResponse), int64(100))
+		assert.Equal(t, peerSet.ReceivedBytesMessageType(message.TypeTransactions), int64(150))
 		assert.Equal(t, peerSet.ReceivedBytes(), receivedBytes)
-		assert.Equal(t, peerSet.TotalSentBytes(), 200)
-		assert.Equal(t, peerSet.SentBytesMessageType(message.TypeBlocksRequest), int64(200))
+		assert.Equal(t, peerSet.TotalSentBytes(), int64(450))
+		assert.Equal(t, peerSet.SentBytesMessageType(message.TypeBlocksRequest), int64(450))
 		assert.Equal(t, peerSet.SentBytes(), sentBytes)
 	})
 

sync/sync.go

@@ -327,7 +327,8 @@ func (sync *synchronizer) sendTo(msg message.Message, to peer.ID, sessionID int)
 			sync.logger.Info("sending bundle to a peer", "bundle", bdl, "to", to)
 			sync.peerSet.IncreaseSendSuccessCounter(to)
 		}
-		sync.peerSet.IncreaseSentBytesCounter(msg.Type(), len(data))
+
+		sync.peerSet.IncreaseSentBytesCounter(msg.Type(), int64(len(data)), &to)
 	}
 }
 
@@ -343,7 +344,7 @@ func (sync *synchronizer) broadcast(msg message.Message) {
 		} else {
 			sync.logger.Info("broadcasting new bundle", "bundle", bdl)
 		}
-		sync.peerSet.IncreaseSentBytesCounter(msg.Type(), len(data))
+		sync.peerSet.IncreaseSentBytesCounter(msg.Type(), int64(len(data)), nil)
 	}
 }
 

www/grpc/gen/dart/network.pb.dart

@@ -253,13 +253,14 @@ class PeerInfo extends $pb.GeneratedMessage {
     ..a<$core.int>(6, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'height', $pb.PbFieldType.OU3)
     ..a<$core.int>(7, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'receivedMessages', $pb.PbFieldType.O3)
     ..a<$core.int>(8, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'invalidMessages', $pb.PbFieldType.O3)
-    ..a<$core.int>(9, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'receivedBytes', $pb.PbFieldType.O3)
-    ..a<$core.int>(10, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'status', $pb.PbFieldType.O3)
-    ..aInt64(11, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'lastSent')
-    ..aInt64(12, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'lastReceived')
-    ..a<$core.int>(13, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'sendSuccess', $pb.PbFieldType.O3)
-    ..a<$core.int>(14, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'sendFailed', $pb.PbFieldType.O3)
-    ..a<$core.List<$core.int>>(15, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'lastBlockHash', $pb.PbFieldType.OY)
+    ..m<$core.int, $fixnum.Int64>(9, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'sentBytes', entryClassName: 'PeerInfo.SentBytesEntry', keyFieldType: $pb.PbFieldType.O3, valueFieldType: $pb.PbFieldType.O6, packageName: const $pb.PackageName('pactus'))
+    ..m<$core.int, $fixnum.Int64>(10, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'receivedBytes', entryClassName: 'PeerInfo.ReceivedBytesEntry', keyFieldType: $pb.PbFieldType.O3, valueFieldType: $pb.PbFieldType.O6, packageName: const $pb.PackageName('pactus'))
+    ..a<$core.int>(11, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'status', $pb.PbFieldType.O3)
+    ..aInt64(12, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'lastSent')
+    ..aInt64(13, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'lastReceived')
+    ..a<$core.int>(14, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'sendSuccess', $pb.PbFieldType.O3)
+    ..a<$core.int>(15, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'sendFailed', $pb.PbFieldType.O3)
+    ..a<$core.List<$core.int>>(16, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'lastBlockHash', $pb.PbFieldType.OY)
     ..hasRequiredFields = false
   ;
 
@@ -273,7 +274,8 @@ class PeerInfo extends $pb.GeneratedMessage {
     $core.int? height,
     $core.int? receivedMessages,
     $core.int? invalidMessages,
-    $core.int? receivedBytes,
+    $core.Map<$core.int, $fixnum.Int64>? sentBytes,
+    $core.Map<$core.int, $fixnum.Int64>? receivedBytes,
     $core.int? status,
     $fixnum.Int64? lastSent,
     $fixnum.Int64? lastReceived,
@@ -306,8 +308,11 @@ class PeerInfo extends $pb.GeneratedMessage {
     if (invalidMessages != null) {
       _result.invalidMessages = invalidMessages;
     }
+    if (sentBytes != null) {
+      _result.sentBytes.addAll(sentBytes);
+    }
     if (receivedBytes != null) {
-      _result.receivedBytes = receivedBytes;
+      _result.receivedBytes.addAll(receivedBytes);
     }
     if (status != null) {
       _result.status = status;
@@ -417,67 +422,64 @@ class PeerInfo extends $pb.GeneratedMessage {
   void clearInvalidMessages() => clearField(8);
 
   @$pb.TagNumber(9)
-  $core.int get receivedBytes => $_getIZ(8);
-  @$pb.TagNumber(9)
-  set receivedBytes($core.int v) { $_setSignedInt32(8, v); }
-  @$pb.TagNumber(9)
-  $core.bool hasReceivedBytes() => $_has(8);
-  @$pb.TagNumber(9)
-  void clearReceivedBytes() => clearField(9);
+  $core.Map<$core.int, $fixnum.Int64> get sentBytes => $_getMap(8);
 
   @$pb.TagNumber(10)
-  $core.int get status => $_getIZ(9);
-  @$pb.TagNumber(10)
-  set status($core.int v) { $_setSignedInt32(9, v); }
-  @$pb.TagNumber(10)
-  $core.bool hasStatus() => $_has(9);
-  @$pb.TagNumber(10)
-  void clearStatus() => clearField(10);
+  $core.Map<$core.int, $fixnum.Int64> get receivedBytes => $_getMap(9);
 
   @$pb.TagNumber(11)
-  $fixnum.Int64 get lastSent => $_getI64(10);
+  $core.int get status => $_getIZ(10);
   @$pb.TagNumber(11)
-  set lastSent($fixnum.Int64 v) { $_setInt64(10, v); }
+  set status($core.int v) { $_setSignedInt32(10, v); }
   @$pb.TagNumber(11)
-  $core.bool hasLastSent() => $_has(10);
+  $core.bool hasStatus() => $_has(10);
   @$pb.TagNumber(11)
-  void clearLastSent() => clearField(11);
+  void clearStatus() => clearField(11);
 
   @$pb.TagNumber(12)
-  $fixnum.Int64 get lastReceived => $_getI64(11);
+  $fixnum.Int64 get lastSent => $_getI64(11);
   @$pb.TagNumber(12)
-  set lastReceived($fixnum.Int64 v) { $_setInt64(11, v); }
+  set lastSent($fixnum.Int64 v) { $_setInt64(11, v); }
   @$pb.TagNumber(12)
-  $core.bool hasLastReceived() => $_has(11);
+  $core.bool hasLastSent() => $_has(11);
   @$pb.TagNumber(12)
-  void clearLastReceived() => clearField(12);
+  void clearLastSent() => clearField(12);
 
   @$pb.TagNumber(13)
-  $core.int get sendSuccess => $_getIZ(12);
+  $fixnum.Int64 get lastReceived => $_getI64(12);
   @$pb.TagNumber(13)
-  set sendSuccess($core.int v) { $_setSignedInt32(12, v); }
+  set lastReceived($fixnum.Int64 v) { $_setInt64(12, v); }
   @$pb.TagNumber(13)
-  $core.bool hasSendSuccess() => $_has(12);
+  $core.bool hasLastReceived() => $_has(12);
   @$pb.TagNumber(13)
-  void clearSendSuccess() => clearField(13);
+  void clearLastReceived() => clearField(13);
 
   @$pb.TagNumber(14)
-  $core.int get sendFailed => $_getIZ(13);
+  $core.int get sendSuccess => $_getIZ(13);
   @$pb.TagNumber(14)
-  set sendFailed($core.int v) { $_setSignedInt32(13, v); }
+  set sendSuccess($core.int v) { $_setSignedInt32(13, v); }
   @$pb.TagNumber(14)
-  $core.bool hasSendFailed() => $_has(13);
+  $core.bool hasSendSuccess() => $_has(13);
   @$pb.TagNumber(14)
-  void clearSendFailed() => clearField(14);
+  void clearSendSuccess() => clearField(14);
 
   @$pb.TagNumber(15)
-  $core.List<$core.int> get lastBlockHash => $_getN(14);
+  $core.int get sendFailed => $_getIZ(14);
   @$pb.TagNumber(15)
-  set lastBlockHash($core.List<$core.int> v) { $_setBytes(14, v); }
+  set sendFailed($core.int v) { $_setSignedInt32(14, v); }
   @$pb.TagNumber(15)
-  $core.bool hasLastBlockHash() => $_has(14);
+  $core.bool hasSendFailed() => $_has(14);
   @$pb.TagNumber(15)
-  void clearLastBlockHash() => clearField(15);
+  void clearSendFailed() => clearField(15);
+
+  @$pb.TagNumber(16)
+  $core.List<$core.int> get lastBlockHash => $_getN(15);
+  @$pb.TagNumber(16)
+  set lastBlockHash($core.List<$core.int> v) { $_setBytes(15, v); }
+  @$pb.TagNumber(16)
+  $core.bool hasLastBlockHash() => $_has(15);
+  @$pb.TagNumber(16)
+  void clearLastBlockHash() => clearField(16);
 }
 
 class NetworkApi {

www/grpc/gen/dart/network.pbjson.dart

@@ -82,18 +82,40 @@ const PeerInfo$json = const {
     const {'1': 'height', '3': 6, '4': 1, '5': 13, '10': 'height'},
     const {'1': 'received_messages', '3': 7, '4': 1, '5': 5, '10': 'receivedMessages'},
     const {'1': 'invalid_messages', '3': 8, '4': 1, '5': 5, '10': 'invalidMessages'},
-    const {'1': 'received_bytes', '3': 9, '4': 1, '5': 5, '10': 'receivedBytes'},
-    const {'1': 'status', '3': 10, '4': 1, '5': 5, '10': 'status'},
-    const {'1': 'last_sent', '3': 11, '4': 1, '5': 3, '10': 'lastSent'},
-    const {'1': 'last_received', '3': 12, '4': 1, '5': 3, '10': 'lastReceived'},
-    const {'1': 'send_success', '3': 13, '4': 1, '5': 5, '10': 'sendSuccess'},
-    const {'1': 'send_failed', '3': 14, '4': 1, '5': 5, '10': 'sendFailed'},
-    const {'1': 'last_block_hash', '3': 15, '4': 1, '5': 12, '10': 'lastBlockHash'},
+    const {'1': 'sent_bytes', '3': 9, '4': 3, '5': 11, '6': '.pactus.PeerInfo.SentBytesEntry', '10': 'sentBytes'},
+    const {'1': 'received_bytes', '3': 10, '4': 3, '5': 11, '6': '.pactus.PeerInfo.ReceivedBytesEntry', '10': 'receivedBytes'},
+    const {'1': 'status', '3': 11, '4': 1, '5': 5, '10': 'status'},
+    const {'1': 'last_sent', '3': 12, '4': 1, '5': 3, '10': 'lastSent'},
+    const {'1': 'last_received', '3': 13, '4': 1, '5': 3, '10': 'lastReceived'},
+    const {'1': 'send_success', '3': 14, '4': 1, '5': 5, '10': 'sendSuccess'},
+    const {'1': 'send_failed', '3': 15, '4': 1, '5': 5, '10': 'sendFailed'},
+    const {'1': 'last_block_hash', '3': 16, '4': 1, '5': 12, '10': 'lastBlockHash'},
   ],
+  '3': const [PeerInfo_SentBytesEntry$json, PeerInfo_ReceivedBytesEntry$json],
+};
+
+@$core.Deprecated('Use peerInfoDescriptor instead')
+const PeerInfo_SentBytesEntry$json = const {
+  '1': 'SentBytesEntry',
+  '2': const [
+    const {'1': 'key', '3': 1, '4': 1, '5': 5, '10': 'key'},
+    const {'1': 'value', '3': 2, '4': 1, '5': 3, '10': 'value'},
+  ],
+  '7': const {'7': true},
+};
+
+@$core.Deprecated('Use peerInfoDescriptor instead')
+const PeerInfo_ReceivedBytesEntry$json = const {
+  '1': 'ReceivedBytesEntry',
+  '2': const [
+    const {'1': 'key', '3': 1, '4': 1, '5': 5, '10': 'key'},
+    const {'1': 'value', '3': 2, '4': 1, '5': 3, '10': 'value'},
+  ],
+  '7': const {'7': true},
 };
 
 /// Descriptor for `PeerInfo`. Decode as a `google.protobuf.DescriptorProto`.
-final $typed_data.Uint8List peerInfoDescriptor = $convert.base64Decode('CghQZWVySW5mbxIYCgdtb25pa2VyGAEgASgJUgdtb25pa2VyEhQKBWFnZW50GAIgASgJUgVhZ2VudBIXCgdwZWVyX2lkGAMgASgMUgZwZWVySWQSJQoOY29uc2Vuc3VzX2tleXMYBCADKAlSDWNvbnNlbnN1c0tleXMSFAoFZmxhZ3MYBSABKAVSBWZsYWdzEhYKBmhlaWdodBgGIAEoDVIGaGVpZ2h0EisKEXJlY2VpdmVkX21lc3NhZ2VzGAcgASgFUhByZWNlaXZlZE1lc3NhZ2VzEikKEGludmFsaWRfbWVzc2FnZXMYCCABKAVSD2ludmFsaWRNZXNzYWdlcxIlCg5yZWNlaXZlZF9ieXRlcxgJIAEoBVINcmVjZWl2ZWRCeXRlcxIWCgZzdGF0dXMYCiABKAVSBnN0YXR1cxIbCglsYXN0X3NlbnQYCyABKANSCGxhc3RTZW50EiMKDWxhc3RfcmVjZWl2ZWQYDCABKANSDGxhc3RSZWNlaXZlZBIhCgxzZW5kX3N1Y2Nlc3MYDSABKAVSC3NlbmRTdWNjZXNzEh8KC3NlbmRfZmFpbGVkGA4gASgFUgpzZW5kRmFpbGVkEiYKD2xhc3RfYmxvY2tfaGFzaBgPIAEoDFINbGFzdEJsb2NrSGFzaA==');
+final $typed_data.Uint8List peerInfoDescriptor = $convert.base64Decode('CghQZWVySW5mbxIYCgdtb25pa2VyGAEgASgJUgdtb25pa2VyEhQKBWFnZW50GAIgASgJUgVhZ2VudBIXCgdwZWVyX2lkGAMgASgMUgZwZWVySWQSJQoOY29uc2Vuc3VzX2tleXMYBCADKAlSDWNvbnNlbnN1c0tleXMSFAoFZmxhZ3MYBSABKAVSBWZsYWdzEhYKBmhlaWdodBgGIAEoDVIGaGVpZ2h0EisKEXJlY2VpdmVkX21lc3NhZ2VzGAcgASgFUhByZWNlaXZlZE1lc3NhZ2VzEikKEGludmFsaWRfbWVzc2FnZXMYCCABKAVSD2ludmFsaWRNZXNzYWdlcxI+CgpzZW50X2J5dGVzGAkgAygLMh8ucGFjdHVzLlBlZXJJbmZvLlNlbnRCeXRlc0VudHJ5UglzZW50Qnl0ZXMSSgoOcmVjZWl2ZWRfYnl0ZXMYCiADKAsyIy5wYWN0dXMuUGVlckluZm8uUmVjZWl2ZWRCeXRlc0VudHJ5Ug1yZWNlaXZlZEJ5dGVzEhYKBnN0YXR1cxgLIAEoBVIGc3RhdHVzEhsKCWxhc3Rfc2VudBgMIAEoA1IIbGFzdFNlbnQSIwoNbGFzdF9yZWNlaXZlZBgNIAEoA1IMbGFzdFJlY2VpdmVkEiEKDHNlbmRfc3VjY2VzcxgOIAEoBVILc2VuZFN1Y2Nlc3MSHwoLc2VuZF9mYWlsZWQYDyABKAVSCnNlbmRGYWlsZWQSJgoPbGFzdF9ibG9ja19oYXNoGBAgASgMUg1sYXN0QmxvY2tIYXNoGjwKDlNlbnRCeXRlc0VudHJ5EhAKA2tleRgBIAEoBVIDa2V5EhQKBXZhbHVlGAIgASgDUgV2YWx1ZToCOAEaQAoSUmVjZWl2ZWRCeXRlc0VudHJ5EhAKA2tleRgBIAEoBVIDa2V5EhQKBXZhbHVlGAIgASgDUgV2YWx1ZToCOAE=');
 const $core.Map<$core.String, $core.dynamic> NetworkServiceBase$json = const {
   '1': 'Network',
   '2': const [
@@ -107,6 +129,8 @@ const $core.Map<$core.String, $core.Map<$core.String, $core.dynamic>> NetworkSer
   '.pactus.GetNetworkInfoRequest': GetNetworkInfoRequest$json,
   '.pactus.GetNetworkInfoResponse': GetNetworkInfoResponse$json,
   '.pactus.PeerInfo': PeerInfo$json,
+  '.pactus.PeerInfo.SentBytesEntry': PeerInfo_SentBytesEntry$json,
+  '.pactus.PeerInfo.ReceivedBytesEntry': PeerInfo_ReceivedBytesEntry$json,
   '.pactus.GetNetworkInfoResponse.SentBytesEntry': GetNetworkInfoResponse_SentBytesEntry$json,
   '.pactus.GetNetworkInfoResponse.ReceivedBytesEntry': GetNetworkInfoResponse_ReceivedBytesEntry$json,
   '.pactus.GetNodeInfoRequest': GetNodeInfoRequest$json,