mirror of
https://github.com/prometheus/alertmanager
synced 2025-02-23 14:26:59 +00:00
Remove unused import & fix codestyle
Signed-off-by: nip <182409448+nip-was-here@users.noreply.github.com>
This commit is contained in:
parent
b9f7a856ee
commit
80112ab6f5
@ -33,7 +33,6 @@ import (
|
||||
"github.com/prometheus/client_golang/prometheus"
|
||||
"github.com/prometheus/common/promslog"
|
||||
|
||||
"github.com/prometheus/alertmanager/cluster"
|
||||
pb "github.com/prometheus/alertmanager/nflog/nflogpb"
|
||||
)
|
||||
|
||||
@ -526,7 +525,7 @@ func (l *Log) Merge(b []byte) error {
|
||||
defer l.mtx.Unlock()
|
||||
now := l.now()
|
||||
|
||||
var needsBroadcast = false
|
||||
needsBroadcast := false
|
||||
for _, e := range st {
|
||||
if merged := l.st.merge(e, now); merged {
|
||||
// If this is the first we've seen the message, gossip state to other nodes.
|
||||
@ -537,7 +536,7 @@ func (l *Log) Merge(b []byte) error {
|
||||
if needsBroadcast {
|
||||
l.broadcast(b)
|
||||
l.metrics.propagatedMessagesTotal.Inc()
|
||||
l.logger.Debug("gossiping new entry", "entry", e)
|
||||
l.logger.Debug("gossiping received state")
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user