github/client-go
1
0
Fork 0
mirror of https://github.com/kubernetes/client-go.git synced 2025-06-22 21:27:07 +00:00
Code Issues Projects Releases Wiki Activity

remove unused fakeUpgradeConnection

Browse Source 
Kubernetes-commit: bf9ce7fd76068903e909358d2b25b05da7e4a431
This commit is contained in:
Antonio Ojea 2021-11-16 22:54:18 +01:00 committed by Kubernetes Publisher
parent d62dc4e20e
commit 34c99305b5
1 changed files with 0 additions and 46 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
rest/request_test.go
View File

@ -47,7 +47,6 @@ import (
"k8s.io/apimachinery/pkg/runtime/serializer" "k8s.io/apimachinery/pkg/runtime/serializer"
"k8s.io/apimachinery/pkg/runtime/serializer/streaming" "k8s.io/apimachinery/pkg/runtime/serializer/streaming"
"k8s.io/apimachinery/pkg/util/diff" "k8s.io/apimachinery/pkg/util/diff"
"k8s.io/apimachinery/pkg/util/httpstream"
"k8s.io/apimachinery/pkg/util/intstr" "k8s.io/apimachinery/pkg/util/intstr"
utilnet "k8s.io/apimachinery/pkg/util/net" utilnet "k8s.io/apimachinery/pkg/util/net"
"k8s.io/apimachinery/pkg/watch" "k8s.io/apimachinery/pkg/watch"
@ -1436,51 +1435,6 @@ func TestRequestStream(t *testing.T) {
} }
} }
//nolint:unused
type fakeUpgradeConnection struct{}
//nolint:unused
func (c *fakeUpgradeConnection) CreateStream(headers http.Header) (httpstream.Stream, error) {
return nil, nil
}
//nolint:unused
func (c *fakeUpgradeConnection) Close() error {
return nil
}
//nolint:unused
func (c *fakeUpgradeConnection) CloseChan() <-chan bool {
return make(chan bool)
}
//nolint:unused
func (c *fakeUpgradeConnection) SetIdleTimeout(timeout time.Duration) {
}
//nolint:unused
type fakeUpgradeRoundTripper struct {
req *http.Request
conn httpstream.Connection
}
//nolint:unused
func (f *fakeUpgradeRoundTripper) RoundTrip(req *http.Request) (*http.Response, error) {
f.req = req
b := []byte{}
body := ioutil.NopCloser(bytes.NewReader(b))
resp := &http.Response{
StatusCode: http.StatusSwitchingProtocols,
Body: body,
}
return resp, nil
}
//nolint:unused
func (f *fakeUpgradeRoundTripper) NewConnection(resp *http.Response) (httpstream.Connection, error) {
return f.conn, nil
}
func TestRequestDo(t *testing.T) { func TestRequestDo(t *testing.T) {
testCases := []struct { testCases := []struct {
Request *Request Request *Request