From 786b0399c3cea197c2579a802e1babdd58c3ba23 Mon Sep 17 00:00:00 2001 From: Clayton Coleman Date: Mon, 4 Aug 2014 15:34:43 -0400 Subject: [PATCH] Make interval a constant on proxy/config/etcd Allow future testing of intervals --- pkg/proxy/config/etcd.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/pkg/proxy/config/etcd.go b/pkg/proxy/config/etcd.go index e0451306916..ead13b73dee 100644 --- a/pkg/proxy/config/etcd.go +++ b/pkg/proxy/config/etcd.go @@ -51,6 +51,7 @@ type ConfigSourceEtcd struct { client *etcd.Client serviceChannel chan ServiceUpdate endpointsChannel chan EndpointsUpdate + interval time.Duration } // NewConfigSourceEtcd creates a new ConfigSourceEtcd and immediately runs the created ConfigSourceEtcd in a goroutine. @@ -59,6 +60,7 @@ func NewConfigSourceEtcd(client *etcd.Client, serviceChannel chan ServiceUpdate, client: client, serviceChannel: serviceChannel, endpointsChannel: endpointsChannel, + interval: 2 * time.Second, } go config.Run() return config @@ -76,7 +78,7 @@ func (s ConfigSourceEtcd) Run() { break } glog.Errorf("Failed to get any services: %v", err) - time.Sleep(2 * time.Second) + time.Sleep(s.interval) } if len(services) > 0 {