kubernetes/test/integration/controlplane/kube_apiserver_test.go

const testApiextensionsOverlapProbeString …

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

func endpointReturnsStatusOK(client *kubernetes.Clientset, path string) (bool, error) { … }

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

// TestOpenAPIDelegationChainPlumbing is a smoke test that checks for
// the existence of some representative paths from the
// apiextensions-server and the kube-aggregator server, both part of
// the delegation chain in kube-apiserver.
func TestOpenAPIDelegationChainPlumbing(t *testing.T) { … }

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

// triggerSpecUpdateWithProbeCRD creates a probe CRD with suffix in name, and waits until
// the path and definition for the probe CRD show up in the OpenAPI spec
func triggerSpecUpdateWithProbeCRD(t *testing.T, apiextensionsclient *apiextensionsclientset.Clientset, suffix string) error { … }

func specHasProbe(clientset *apiextensionsclientset.Clientset, probe string) (bool, error) { … }

func getOpenAPIPath(clientset *apiextensionsclientset.Clientset, path string) (spec.PathItem, bool, error) { … }

func getOpenAPIDefinition(clientset *apiextensionsclientset.Clientset, definition string) (spec.Schema, bool, error) { … }

// return the unique endpoint IPs
func getEndpointIPs(endpoints *corev1.Endpoints) []string { … }

func verifyEndpointsWithIPs(servers []*kubeapiservertesting.TestServer, ips []string) bool { … }

func testReconcilersAPIServerLease(t *testing.T, leaseCount int, apiServerCount int) { … }

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

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

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

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