Node/Processor: Peg observation metric for us

wormhole-foundation · Aug 30, 2024 · 6130bbb · 6130bbb
1 parent ddeb560
commit 6130bbb
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/node/pkg/processor/message.go b/node/pkg/processor/message.go
@@ -95,6 +95,10 @@ func (p *Processor) handleMessage(k *common.MessagePublication) {
  // Broadcast the signature.
  ourObs, msg := p.broadcastSignature(v.MessageID(), k.TxHash.Bytes(), digest, signature, shouldPublishImmediately)
 
+ // Indicate that we observed this one.
+ observationsReceivedTotal.Inc()
+ observationsReceivedByGuardianAddressTotal.WithLabelValues(p.ourAddr.Hex()).Inc()
+
  // Get / create our state entry.
  s := p.state.signatures[hash]
  if s == nil {