make etcd periodic member sync configurable and optional

fix docker#137 Signed-off-by: Viktor Stanchev <[email protected]>
abronan · Aug 12, 2017 · aa80c88 · aa80c88
1 parent 0517c63
commit aa80c88
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 6 deletions.
diff --git a/store/etcd/etcd.go b/store/etcd/etcd.go
@@ -40,7 +40,6 @@ type etcdLock struct {
 }
 
 const (
-	periodicSync      = 5 * time.Minute
 	defaultLockTTL    = 20 * time.Second
 	defaultUpdateTime = 5 * time.Second
 )
@@ -88,11 +87,13 @@ func New(addrs []string, options *store.Config) (store.Store, error) {
 	s.client = etcd.NewKeysAPI(c)
 
 	// Periodic Cluster Sync
-	go func() {
-		for {
-			c.AutoSync(context.Background(), periodicSync)
-		}
-	}()
+	if options != nil && options.SyncPeriod != 0 {
+		go func() {
+			for {
+				c.AutoSync(context.Background(), options.SyncPeriod)
+			}
+		}()
+	}
 
 	return s, nil
 }

diff --git a/store/store.go b/store/store.go
@@ -44,6 +44,7 @@ type Config struct {
 	ClientTLS         *ClientTLSConfig
 	TLS               *tls.Config
 	ConnectionTimeout time.Duration
+	SyncPeriod        time.Duration
 	Bucket            string
 	PersistConnection bool
 	Username          string