Update etcd election to new API

google · Dec 5, 2017 · 1713865 · 1713865
1 parent 0ceb321
commit 1713865
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/util/etcd/election.go b/util/etcd/election.go
@@ -53,7 +53,7 @@ func (eme *MasterElection) IsMaster(ctx context.Context) (bool, error) {
 	if err != nil {
 		return false, err
 	}
-	return leader == eme.instanceID, nil
+	return string(leader.Kvs[0].Value) == eme.instanceID, nil
 }
 
 // ResignAndRestart releases mastership, and re-joins the election.