Node/Processor: Peg observation metric for us

wormhole-foundation · Aug 30, 2024 · d6481ca · d6481ca
1 parent 2cce7a5
commit d6481ca
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 {