diff --git a/clientv3/lease.go b/clientv3/lease.go index 6e92fa3ba..68a8ae6b3 100644 --- a/clientv3/lease.go +++ b/clientv3/lease.go @@ -199,7 +199,7 @@ func NewLeaseFromLeaseClient(remote pb.LeaseClient, c *Client, keepAliveTimeout keepAlives: make(map[LeaseID]*keepAlive), remote: remote, firstKeepAliveTimeout: keepAliveTimeout, - lg: c.lg, + lg: c.lg, } if l.firstKeepAliveTimeout == time.Second { l.firstKeepAliveTimeout = defaultTTL diff --git a/functional/agent/server.go b/functional/agent/server.go index 8bba63792..a39f28e76 100644 --- a/functional/agent/server.go +++ b/functional/agent/server.go @@ -64,10 +64,10 @@ func NewServer( address string, ) *Server { return &Server{ - lg: lg, - network: network, - address: address, - last: rpcpb.Operation_NOT_STARTED, + lg: lg, + network: network, + address: address, + last: rpcpb.Operation_NOT_STARTED, advertiseClientPortToProxy: make(map[int]proxy.Server), advertisePeerPortToProxy: make(map[int]proxy.Server), } diff --git a/integration/cluster.go b/integration/cluster.go index c1149de85..bc6881126 100644 --- a/integration/cluster.go +++ b/integration/cluster.go @@ -291,8 +291,8 @@ func (c *cluster) mustNewMember(t *testing.T) *member { grpcKeepAliveTimeout: c.cfg.GRPCKeepAliveTimeout, clientMaxCallSendMsgSize: c.cfg.ClientMaxCallSendMsgSize, clientMaxCallRecvMsgSize: c.cfg.ClientMaxCallRecvMsgSize, - useIP: c.cfg.UseIP, - leaseCheckpointInterval: c.cfg.LeaseCheckpointInterval, + useIP: c.cfg.UseIP, + leaseCheckpointInterval: c.cfg.LeaseCheckpointInterval, }) m.DiscoveryURL = c.cfg.DiscoveryURL if c.cfg.UseGRPC { diff --git a/pkg/testutil/leak.go b/pkg/testutil/leak.go index 8a867b163..27eaa36d2 100644 --- a/pkg/testutil/leak.go +++ b/pkg/testutil/leak.go @@ -70,13 +70,13 @@ func CheckAfterTest(d time.Duration) error { } var bad string badSubstring := map[string]string{ - ").writeLoop(": "a Transport", + ").writeLoop(": "a Transport", "created by net/http/httptest.(*Server).Start": "an httptest.Server", - "timeoutHandler": "a TimeoutHandler", - "net.(*netFD).connect(": "a timing out dial", - ").noteClientGone(": "a closenotifier sender", - ").readLoop(": "a Transport", - ".grpc": "a gRPC resource", + "timeoutHandler": "a TimeoutHandler", + "net.(*netFD).connect(": "a timing out dial", + ").noteClientGone(": "a closenotifier sender", + ").readLoop(": "a Transport", + ".grpc": "a gRPC resource", } var stacks string diff --git a/proxy/httpproxy/reverse_test.go b/proxy/httpproxy/reverse_test.go index 284b6811b..47a3b4a5b 100644 --- a/proxy/httpproxy/reverse_test.go +++ b/proxy/httpproxy/reverse_test.go @@ -175,10 +175,10 @@ func TestRemoveSingleHopHeaders(t *testing.T) { "Keep-Alive": {"foo"}, "Proxy-Authenticate": {"Basic realm=example.com"}, "Proxy-Authorization": {"foo"}, - "Te": {"deflate,gzip"}, - "Trailers": {"ETag"}, - "Transfer-Encoding": {"chunked"}, - "Upgrade": {"WebSocket"}, + "Te": {"deflate,gzip"}, + "Trailers": {"ETag"}, + "Transfer-Encoding": {"chunked"}, + "Upgrade": {"WebSocket"}, // headers that should persist "Accept": {"application/json"},