kubernetes/test/integration/apiserver/admissionwebhook/load_balance_test.go

const testLoadBalanceClientUsername …

type staticURLServiceResolver …

func (u staticURLServiceResolver) ResolveEndpoint(namespace, name string, port int32) (*url.URL, error) { … }

// TestWebhookLoadBalance ensures that the admission webhook opens multiple connections to backends to satisfy concurrent requests
func TestWebhookLoadBalance(t *testing.T) { … }

type connectionRecorder …

// Reset zeros out all counts and returns a channel that is closed when the first admission of the
// marker object is received.
func (i *connectionRecorder) Reset() chan struct{ … }

func (i *connectionRecorder) MarkerReceived() { … }

func newLoadBalanceWebhookHandler(recorder *connectionRecorder) http.Handler { … }

var loadBalanceMarkerFixture …

type connectionTrackingListener …

func (c *connectionTrackingListener) Reset() { … }

func (c *connectionTrackingListener) Accept() (net.Conn, error) { … }

func (c *connectionTrackingListener) Close() error { … }

func (c *connectionTrackingListener) Addr() net.Addr { … }