mirror of
https://github.com/etcd-io/etcd.git
synced 2024-09-27 06:25:44 +00:00
clientv3: fix client for grpc change
Fix https://github.com/coreos/etcd/issues/5638.
This commit is contained in:
parent
b2a531d5a3
commit
5225a4e4bc
@ -48,7 +48,7 @@ type Client struct {
|
|||||||
|
|
||||||
conn *grpc.ClientConn
|
conn *grpc.ClientConn
|
||||||
cfg Config
|
cfg Config
|
||||||
creds *credentials.TransportAuthenticator
|
creds *credentials.TransportCredentials
|
||||||
|
|
||||||
ctx context.Context
|
ctx context.Context
|
||||||
cancel context.CancelFunc
|
cancel context.CancelFunc
|
||||||
@ -110,7 +110,7 @@ func (cred authTokenCredential) GetRequestMetadata(ctx context.Context, s ...str
|
|||||||
}, nil
|
}, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *Client) dialTarget(endpoint string) (proto string, host string, creds *credentials.TransportAuthenticator) {
|
func (c *Client) dialTarget(endpoint string) (proto string, host string, creds *credentials.TransportCredentials) {
|
||||||
proto = "tcp"
|
proto = "tcp"
|
||||||
host = endpoint
|
host = endpoint
|
||||||
creds = c.creds
|
creds = c.creds
|
||||||
@ -220,7 +220,7 @@ func newClient(cfg *Config) (*Client, error) {
|
|||||||
if cfg == nil {
|
if cfg == nil {
|
||||||
cfg = &Config{}
|
cfg = &Config{}
|
||||||
}
|
}
|
||||||
var creds *credentials.TransportAuthenticator
|
var creds *credentials.TransportCredentials
|
||||||
if cfg.TLS != nil {
|
if cfg.TLS != nil {
|
||||||
c := credentials.NewTLS(cfg.TLS)
|
c := credentials.NewTLS(cfg.TLS)
|
||||||
creds = &c
|
creds = &c
|
||||||
|
Loading…
x
Reference in New Issue
Block a user