Commit 3f08a8c8 authored by Ralph Pichler's avatar Ralph Pichler Committed by GitHub

add metrics to track number of cheques (#1446)

parent b90bd7cd
......@@ -12,6 +12,8 @@ import (
type metrics struct {
TotalReceived prometheus.Counter
TotalSent prometheus.Counter
ChequesReceived prometheus.Counter
ChequesSent prometheus.Counter
ChequesRejected prometheus.Counter
AvailableBalance prometheus.Gauge
}
......@@ -32,6 +34,18 @@ func newMetrics() metrics {
Name: "total_sent",
Help: "Amount of tokens sent to peers (costs paid by the node)",
}),
ChequesReceived: prometheus.NewCounter(prometheus.CounterOpts{
Namespace: m.Namespace,
Subsystem: subsystem,
Name: "cheques_received",
Help: "Number of cheques received from peers",
}),
ChequesSent: prometheus.NewCounter(prometheus.CounterOpts{
Namespace: m.Namespace,
Subsystem: subsystem,
Name: "cheques_sent",
Help: "Number of cheques sent to peers",
}),
ChequesRejected: prometheus.NewCounter(prometheus.CounterOpts{
Namespace: m.Namespace,
Subsystem: subsystem,
......
......@@ -101,6 +101,7 @@ func (s *Service) ReceiveCheque(ctx context.Context, peer swarm.Address, cheque
}
s.metrics.TotalReceived.Add(float64(amount.Uint64()))
s.metrics.ChequesReceived.Inc()
return s.notifyPaymentFunc(peer, amount)
}
......@@ -129,6 +130,7 @@ func (s *Service) Pay(ctx context.Context, peer swarm.Address, amount *big.Int)
s.metrics.AvailableBalance.Set(bal)
amountFloat, _ := big.NewFloat(0).SetInt(amount).Float64()
s.metrics.TotalSent.Add(amountFloat)
s.metrics.ChequesSent.Inc()
return nil
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment