kubernetes/test/integration/examples/apiserver_test.go

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

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

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

// TestFrontProxyConfig tests that the RequestHeader configuration is consumed
// correctly by the aggregated API servers.
func testFrontProxyConfig(t *testing.T, withUID bool) { … }

type roundTripperFunc …

func (f roundTripperFunc) RoundTrip(req *http.Request) (*http.Response, error) { … }

func testAggregatedAPIServer(t *testing.T, setWardleFeatureGate, banFlunder bool, wardleBinaryVersion, wardleEmulationVersion string) { … }

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

func prepareAggregatedWardleAPIServer(ctx context.Context, t *testing.T, namespace, kubebinaryVersion, wardleBinaryVersion string, kubeAPIServerFlags []string) (*kastesting.TestServer, *sampleserver.WardleServerOptions, int) { … }

func runPreparedWardleServer(
	ctx context.Context,
	t *testing.T,
	wardleOptions *sampleserver.WardleServerOptions,
	certDir string,
	wardlePort int,
	flunderBanningFeatureGate bool,
	banFlunder bool,
	emulationVersion string,
	kubeConfig *rest.Config,
) *rest.Config { … }

func waitForWardleAPIServiceReady(ctx context.Context, t *testing.T, kubeConfig *rest.Config, wardleCertDir string, namespace string) { … }

func getKubeConfig(testServer *kastesting.TestServer) *rest.Config { … }

func waitForWardleRunning(ctx context.Context, t *testing.T, wardleToKASKubeConfig *rest.Config, wardleCertDir string, wardlePort int) (*rest.Config, error) { … }

func wardleCAFilePath(wardleCertDir string) string { … }

func writeKubeConfigForWardleServerToKASConnection(t *testing.T, kubeClientConfig *rest.Config) string { … }

func createKubeConfig(clientCfg *rest.Config) *clientcmdapi.Config { … }

func readResponse(ctx context.Context, client rest.Interface, location string) ([]byte, error) { … }

func testAPIGroupList(ctx context.Context, t *testing.T, client rest.Interface) { … }

func testAPIGroup(ctx context.Context, t *testing.T, client rest.Interface) { … }

func testAPIResourceList(ctx context.Context, t *testing.T, client rest.Interface) { … }

var differentClientCA …

var differentFrontProxyCA …

type staticURLServiceResolver …

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