From d64b684831aff2df86d9cea8e23bf57c85b6772f Mon Sep 17 00:00:00 2001
From: Miek Gieben <miek@miek.nl>
Date: Fri, 20 Oct 2017 22:53:17 +0100
Subject: plugin/kubernetes: implement HasSynced()  (#1155)

* plugin/kubernetes: wait until api is ready

Wait for HasSynced before allowing startup to avoid startup race.

Also do a small refactor in findServices() to pull a check out of the
loop - only needs to be done once.

* sigh
---
 plugin/federation/kubernetes_api_test.go | 1 +
 1 file changed, 1 insertion(+)

(limited to 'plugin/federation/kubernetes_api_test.go')

diff --git a/plugin/federation/kubernetes_api_test.go b/plugin/federation/kubernetes_api_test.go
index 0d8df64d3..1dba1fccd 100644
--- a/plugin/federation/kubernetes_api_test.go
+++ b/plugin/federation/kubernetes_api_test.go
@@ -9,6 +9,7 @@ import (
 
 type APIConnFederationTest struct{}
 
+func (APIConnFederationTest) HasSynced() bool                        { return true }
 func (APIConnFederationTest) Run()                                   { return }
 func (APIConnFederationTest) Stop() error                            { return nil }
 func (APIConnFederationTest) SvcIndexReverse(string) []*api.Service  { return nil }
-- 
cgit v1.2.3