Allow multiple etcd hosts to be specified in db.etcd.host.

kvdb/etcd/db.go

@@ -8,6 +8,7 @@ import (
 	"fmt"
 	"io"
 	"runtime"
+	"strings"
 	"sync"
 	"time"
 
@@ -138,7 +139,7 @@ func NewEtcdClient(ctx context.Context, cfg Config) (*clientv3.Client,
 	context.Context, func(), error) {
 
 	clientCfg := clientv3.Config{
-		Endpoints:          []string{cfg.Host},
+		Endpoints:          strings.Split(cfg.Host, ","),
 		DialTimeout:        etcdConnectionTimeout,
 		Username:           cfg.User,
 		Password:           cfg.Pass,

kvdb/etcd/fixture.go

@@ -5,6 +5,7 @@ package etcd
 
 import (
 	"context"
+	"strings"
 	"testing"
 	"time"
 
@@ -49,7 +50,7 @@ func NewEtcdTestFixture(t *testing.T) *EtcdTestFixture {
 	t.Cleanup(etcdCleanup)
 
 	cli, err := clientv3.New(clientv3.Config{
-		Endpoints: []string{config.Host},
+		Endpoints: strings.Split(config.Host, ","),
 		Username:  config.User,
 		Password:  config.Pass,
 	})