go/go-micro
1
0
Fork 0
mirror of https://github.com/go-micro/go-micro.git synced 2025-06-30 22:33:49 +02:00
Code Issues Releases Activity

Merge pull request #712 from milosgajdos83/route-update

Browse Source 
Only emit table event if table.Update actually happens
This commit is contained in:
Asim Aslam
2019-08-29 16:30:27 +01:00
committed by GitHub
parent b457ec1990 4f788c6fc7
commit 690640eeeb
1 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
router/table.go
View File

@ -83,8 +83,10 @@ func (t *table) Delete(r Route) error {
return ErrRouteNotFound return ErrRouteNotFound
} }
if _, ok := t.routes[service][sum]; ok {
delete(t.routes[service], sum) delete(t.routes[service], sum)
go t.sendEvent(&Event{Type: Delete, Timestamp: time.Now(), Route: r}) go t.sendEvent(&Event{Type: Delete, Timestamp: time.Now(), Route: r})
}
return nil return nil
} }
@ -105,8 +107,10 @@ func (t *table) Update(r Route) error {
return nil return nil
} }
if _, ok := t.routes[service][sum]; !ok {
t.routes[service][sum] = r t.routes[service][sum] = r
go t.sendEvent(&Event{Type: Update, Timestamp: time.Now(), Route: r}) go t.sendEvent(&Event{Type: Update, Timestamp: time.Now(), Route: r})
}
return nil return nil
} }