github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-13 13:55:41 +00:00
Code Issues Projects Releases Wiki Activity

etcd3 backend: support TLS

Browse Source
This commit is contained in:
Hongchao Deng 2016-08-17 20:07:47 -07:00
parent 70ba811663
commit 014ad63111
1 changed files with 15 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
pkg/storage/storagebackend/factory/etcd3.go
View File

@ -19,21 +19,33 @@ package factory
import ( import (
"strings" "strings"
"github.com/coreos/etcd/clientv3"
"golang.org/x/net/context"
"k8s.io/kubernetes/pkg/storage" "k8s.io/kubernetes/pkg/storage"
"k8s.io/kubernetes/pkg/storage/etcd3" "k8s.io/kubernetes/pkg/storage/etcd3"
"k8s.io/kubernetes/pkg/storage/storagebackend" "k8s.io/kubernetes/pkg/storage/storagebackend"
"github.com/coreos/etcd/clientv3"
"github.com/coreos/etcd/pkg/transport"
"golang.org/x/net/context"
) )
func newETCD3Storage(c storagebackend.Config) (storage.Interface, error) { func newETCD3Storage(c storagebackend.Config) (storage.Interface, error) {
info := transport.TLSInfo{
CertFile: c.CertFile,
KeyFile: c.KeyFile,
CAFile: c.CAFile,
}
tlsConfig, err := info.ClientConfig()
if err != nil {
return nil, err
}
endpoints := c.ServerList endpoints := c.ServerList
for i, s := range endpoints { for i, s := range endpoints {
endpoints[i] = strings.TrimLeft(s, "http://") endpoints[i] = strings.TrimLeft(s, "http://")
} }
cfg := clientv3.Config{ cfg := clientv3.Config{
Endpoints: endpoints, Endpoints: endpoints,
TLS: tlsConfig,
} }
client, err := clientv3.New(cfg) client, err := clientv3.New(cfg)
if err != nil { if err != nil {