Pārlūkot izejas kodu

Merge pull request #54 from eyakubovich/master

Use ModifiedIndex and not EtcdIndex for watches
Eugene Yakubovich 10 gadi atpakaļ
vecāks
revīzija
e20ae46cf6
1 mainītis faili ar 1 papildinājumiem un 1 dzēšanām
  1. 1 1
      subnet/subnet.go

+ 1 - 1
subnet/subnet.go

@@ -359,7 +359,7 @@ func (sm *SubnetManager) WatchLeases(receiver chan EventBatch, cancel chan bool)
 }
 
 func (sm *SubnetManager) parseSubnetWatchResponse(resp *etcd.Response) (batch *EventBatch, err error) {
-	sm.lastIndex = resp.EtcdIndex
+	sm.lastIndex = resp.Node.ModifiedIndex
 
 	sn, err := parseSubnetKey(resp.Node.Key)
 	if err != nil {