clientv3/naming: ignore empty update.

This commit is contained in:
johncming 2019-03-25 10:53:24 +08:00
parent 7a5acb4a43
commit cb39c97b22

View File

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