mirror of
https://github.com/jhillyerd/inbucket.git
synced 2025-12-18 18:17:03 +00:00
Metrics: rename Delivered to Received, closes #10
This commit is contained in:
@@ -340,11 +340,11 @@ func (ss *Session) dataHandler() {
|
|||||||
for _, m := range messages {
|
for _, m := range messages {
|
||||||
if m != nil {
|
if m != nil {
|
||||||
m.Close()
|
m.Close()
|
||||||
expDeliveredTotal.Add(1)
|
expReceivedTotal.Add(1)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
expDeliveredTotal.Add(1)
|
expReceivedTotal.Add(1)
|
||||||
}
|
}
|
||||||
ss.send("250 Mail accepted for delivery")
|
ss.send("250 Mail accepted for delivery")
|
||||||
ss.info("Message size %v bytes", msgSize)
|
ss.info("Message size %v bytes", msgSize)
|
||||||
|
|||||||
@@ -25,7 +25,7 @@ type Server struct {
|
|||||||
// Raw stat collectors
|
// Raw stat collectors
|
||||||
var expConnectsTotal = new(expvar.Int)
|
var expConnectsTotal = new(expvar.Int)
|
||||||
var expConnectsCurrent = new(expvar.Int)
|
var expConnectsCurrent = new(expvar.Int)
|
||||||
var expDeliveredTotal = new(expvar.Int)
|
var expReceivedTotal = new(expvar.Int)
|
||||||
var expErrorsTotal = new(expvar.Int)
|
var expErrorsTotal = new(expvar.Int)
|
||||||
var expWarnsTotal = new(expvar.Int)
|
var expWarnsTotal = new(expvar.Int)
|
||||||
|
|
||||||
@@ -36,7 +36,7 @@ var errorsHist = list.New()
|
|||||||
var warnsHist = list.New()
|
var warnsHist = list.New()
|
||||||
|
|
||||||
// History rendered as comma delim string
|
// History rendered as comma delim string
|
||||||
var expDeliveredHist = new(expvar.String)
|
var expReceivedHist = new(expvar.String)
|
||||||
var expConnectsHist = new(expvar.String)
|
var expConnectsHist = new(expvar.String)
|
||||||
var expErrorsHist = new(expvar.String)
|
var expErrorsHist = new(expvar.String)
|
||||||
var expWarnsHist = new(expvar.String)
|
var expWarnsHist = new(expvar.String)
|
||||||
@@ -96,7 +96,7 @@ func metricsTicker(t *time.Ticker) {
|
|||||||
ok := true
|
ok := true
|
||||||
for ok {
|
for ok {
|
||||||
_, ok = <-t.C
|
_, ok = <-t.C
|
||||||
expDeliveredHist.Set(pushMetric(deliveredHist, expDeliveredTotal))
|
expReceivedHist.Set(pushMetric(deliveredHist, expReceivedTotal))
|
||||||
expConnectsHist.Set(pushMetric(connectsHist, expConnectsTotal))
|
expConnectsHist.Set(pushMetric(connectsHist, expConnectsTotal))
|
||||||
expErrorsHist.Set(pushMetric(errorsHist, expErrorsTotal))
|
expErrorsHist.Set(pushMetric(errorsHist, expErrorsTotal))
|
||||||
expWarnsHist.Set(pushMetric(warnsHist, expWarnsTotal))
|
expWarnsHist.Set(pushMetric(warnsHist, expWarnsTotal))
|
||||||
@@ -120,8 +120,8 @@ func init() {
|
|||||||
m.Set("ConnectsTotal", expConnectsTotal)
|
m.Set("ConnectsTotal", expConnectsTotal)
|
||||||
m.Set("ConnectsHist", expConnectsHist)
|
m.Set("ConnectsHist", expConnectsHist)
|
||||||
m.Set("ConnectsCurrent", expConnectsCurrent)
|
m.Set("ConnectsCurrent", expConnectsCurrent)
|
||||||
m.Set("DeliveredTotal", expDeliveredTotal)
|
m.Set("ReceivedTotal", expReceivedTotal)
|
||||||
m.Set("DeliveredHist", expDeliveredHist)
|
m.Set("ReceivedHist", expReceivedHist)
|
||||||
m.Set("ErrorsTotal", expErrorsTotal)
|
m.Set("ErrorsTotal", expErrorsTotal)
|
||||||
m.Set("ErrorsHist", expErrorsHist)
|
m.Set("ErrorsHist", expErrorsHist)
|
||||||
m.Set("WarnsTotal", expWarnsTotal)
|
m.Set("WarnsTotal", expWarnsTotal)
|
||||||
|
|||||||
@@ -100,8 +100,8 @@
|
|||||||
metric('smtpConnectsCurrent', data.smtp.ConnectsCurrent, numberFilter, true)
|
metric('smtpConnectsCurrent', data.smtp.ConnectsCurrent, numberFilter, true)
|
||||||
|
|
||||||
// Server-side history
|
// Server-side history
|
||||||
metric('smtpDeliveredTotal', data.smtp.DeliveredTotal, numberFilter, false)
|
metric('smtpReceivedTotal', data.smtp.ReceivedTotal, numberFilter, false)
|
||||||
setHistory('smtpDeliveredTotal', data.smtp.DeliveredHist)
|
setHistory('smtpReceivedTotal', data.smtp.ReceivedHist)
|
||||||
metric('smtpConnectsTotal', data.smtp.ConnectsTotal, numberFilter, false)
|
metric('smtpConnectsTotal', data.smtp.ConnectsTotal, numberFilter, false)
|
||||||
setHistory('smtpConnectsTotal', data.smtp.ConnectsHist)
|
setHistory('smtpConnectsTotal', data.smtp.ConnectsHist)
|
||||||
metric('smtpWarnsTotal', data.smtp.WarnsTotal, numberFilter, false)
|
metric('smtpWarnsTotal', data.smtp.WarnsTotal, numberFilter, false)
|
||||||
@@ -189,9 +189,9 @@
|
|||||||
<td>(60min)</td>
|
<td>(60min)</td>
|
||||||
</tr>
|
</tr>
|
||||||
<tr>
|
<tr>
|
||||||
<th>Messages Delivered:</th>
|
<th>Messages Received:</th>
|
||||||
<td><span id="m-smtpDeliveredTotal">.</span></td>
|
<td><span id="m-smtpReceivedTotal">.</span></td>
|
||||||
<td class="sparkline"><span id="s-smtpDeliveredTotal">.</span></td>
|
<td class="sparkline"><span id="s-smtpReceivedTotal">.</span></td>
|
||||||
<td>(60min)</td>
|
<td>(60min)</td>
|
||||||
</tr>
|
</tr>
|
||||||
<tr>
|
<tr>
|
||||||
|
|||||||
Reference in New Issue
Block a user