Helper func to connect to etcd

controller/resourceStore.go

@@ -19,6 +19,7 @@ package controller
 import (
 	"errors"
 	"reflect"
+	"time"
 	
 	log "github.com/Sirupsen/logrus"
 	"github.com/coreos/etcd/client"
@@ -38,6 +39,20 @@ func makeResourceStore(fs *fileStore, ks client.KeysAPI, s serializer) *resource
 	return &resourceStore{fileStore: fs, KeysAPI: ks, serializer: s}
 }
 
+func getEtcdKeyAPI(etcdUrls []string) client.KeysAPI {
+        cfg := client.Config{
+                Endpoints: etcdUrls,
+                Transport: client.DefaultTransport,
+                // set timeout per request to fail fast when the target endpoint is unavailable
+                HeaderTimeoutPerRequest: time.Second,
+        }
+        c, err := client.New(cfg)
+        if err != nil {
+                log.Fatalf("failed to connect to etcd: %v", err)
+        }
+        return client.NewKeysAPI(c)
+}
+
 func getTypeName(r resource) (string, error) {
 	typ := reflect.TypeOf(r)
 	if typ.Kind().String() == "ptr" {