|
@@ -98,6 +98,8 @@ func (gw *gRPCWatcher) Next() ([]*naming.Update, error) {
|
|
|
case etcd.EventTypeDelete:
|
|
case etcd.EventTypeDelete:
|
|
|
err = json.Unmarshal(e.PrevKv.Value, &jupdate)
|
|
err = json.Unmarshal(e.PrevKv.Value, &jupdate)
|
|
|
jupdate.Op = naming.Delete
|
|
jupdate.Op = naming.Delete
|
|
|
|
|
+ default:
|
|
|
|
|
+ continue
|
|
|
}
|
|
}
|
|
|
if err == nil {
|
|
if err == nil {
|
|
|
updates = append(updates, &jupdate)
|
|
updates = append(updates, &jupdate)
|