1
0
Fork 0

fix: prevent firing registry events on heartbeat

This commit is contained in:
Arthur K. 2026-01-23 12:19:16 +03:00
parent 2af9e734dd
commit fc31d375a2
Signed by: wzray
GPG key ID: B97F30FDC4636357

View file

@ -123,6 +123,15 @@ func (r *Registry) RemoveNode(node types.Node) error {
func (r *Registry) Set(nodes map[string]types.Node) error {
r.lock.Lock()
equalFunc := func(a, b types.Node) bool {
return a.Hostname == b.Hostname
}
if maps.EqualFunc(r.nodes, nodes, equalFunc) {
r.lock.Unlock()
return nil
}
r.nodes = maps.Clone(nodes)
snapshot := r.snapshot()
r.lock.Unlock()