aboutsummaryrefslogtreecommitdiff
path: root/middleware/etcd/setup.go
diff options
context:
space:
mode:
Diffstat (limited to 'middleware/etcd/setup.go')
-rw-r--r--middleware/etcd/setup.go24
1 files changed, 1 insertions, 23 deletions
diff --git a/middleware/etcd/setup.go b/middleware/etcd/setup.go
index 380b57167..bedc154f8 100644
--- a/middleware/etcd/setup.go
+++ b/middleware/etcd/setup.go
@@ -2,9 +2,6 @@ package etcd
import (
"crypto/tls"
- "net"
- "net/http"
- "time"
"github.com/coredns/coredns/core/dnsserver"
"github.com/coredns/coredns/middleware"
@@ -135,7 +132,7 @@ func etcdParse(c *caddy.Controller) (*Etcd, bool, error) {
func newEtcdClient(endpoints []string, cc *tls.Config) (etcdc.KeysAPI, error) {
etcdCfg := etcdc.Config{
Endpoints: endpoints,
- Transport: newHTTPSTransport(cc),
+ Transport: mwtls.NewHTTPSTransport(cc),
}
cli, err := etcdc.New(etcdCfg)
if err != nil {
@@ -144,23 +141,4 @@ func newEtcdClient(endpoints []string, cc *tls.Config) (etcdc.KeysAPI, error) {
return etcdc.NewKeysAPI(cli), nil
}
-func newHTTPSTransport(cc *tls.Config) etcdc.CancelableTransport {
- // this seems like a bad idea but was here in the previous version
- if cc != nil {
- cc.InsecureSkipVerify = true
- }
-
- tr := &http.Transport{
- Proxy: http.ProxyFromEnvironment,
- Dial: (&net.Dialer{
- Timeout: 30 * time.Second,
- KeepAlive: 30 * time.Second,
- }).Dial,
- TLSHandshakeTimeout: 10 * time.Second,
- TLSClientConfig: cc,
- }
-
- return tr
-}
-
const defaultEndpoint = "http://localhost:2379"