kubernetes/test/integration/apimachinery/watch_timeout_test.go

type extractRT …

func (rt *extractRT) RoundTrip(req *http.Request) (*http.Response, error) { … }

// headersForConfig extracts any http client logic necessary for the provided
// config.
func headersForConfig(c *restclient.Config, url *url.URL) (http.Header, error) { … }

// websocketConfig constructs a websocket config to the provided URL, using the client
// config, with the specified protocols.
func websocketConfig(url *url.URL, config *restclient.Config, protocols []string) (*websocket.Config, error) { … }

func TestWebsocketWatchClientTimeout(t *testing.T) { … }

func TestWatchClientTimeoutXXX(t *testing.T) { … }

func testWatchClientTimeouts(t *testing.T, config *restclient.Config) { … }

func testWatchClientTimeout(t *testing.T, config *restclient.Config, timeout, timeoutSeconds time.Duration) { … }