kubernetes/test/integration/apiserver/apiserver_test.go

func setup(t *testing.T, groupVersions ...schema.GroupVersion) (context.Context, clientset.Interface, *restclient.Config, framework.TearDownFunc) { … }

func setupWithResources(t *testing.T, groupVersions []schema.GroupVersion, resources []schema.GroupVersionResource) (context.Context, clientset.Interface /* TODO (pohly): return ktesting.TContext */, *restclient.Config, framework.TearDownFunc) { … }

func verifyStatusCode(t *testing.T, transport http.RoundTripper, verb, URL, body string, expectedStatusCode int) { … }

func newRS(namespace string) *apps.ReplicaSet { … }

var cascDel …

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

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

// Tests that the apiserver returns HSTS headers as expected.
func TestHSTS(t *testing.T) { … }

// Tests that the apiserver returns 202 status code as expected.
func Test202StatusCode(t *testing.T) { … }

var invalidContinueToken …

var invalidResourceVersion …

var invalidResourceVersionMatch …

// TestListOptions ensures that list works as expected for valid and invalid combinations of limit, continue,
// resourceVersion and resourceVersionMatch.
func TestListOptions(t *testing.T) { … }

func testListOptionsCase(t *testing.T, rsClient appsv1.ReplicaSetInterface, watchCacheEnabled bool, opts metav1.ListOptions, compactedRv string) { … }

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

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

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

func makeSecret(name string) *v1.Secret { … }

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

type callWrapper …

func (w *callWrapper) RoundTrip(req *http.Request) (*http.Response, error) { … }

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

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

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

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

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

func expectTableWatchEvents(t *testing.T, count, columns int, policy metav1.IncludeObjectPolicy, d *json.Decoder) [][]byte { … }

type streamedEvent …

func expectTableWatchEventsWithTypes(t *testing.T, count, columns int, policy metav1.IncludeObjectPolicy, d *json.Decoder) []streamedEvent { … }

func expectPartialObjectMetaEvents(t *testing.T, d *json.Decoder, values ...string) { … }

type partialObjectMetadataCheck …

func expectPartialObjectMetaEventsProtobuf(t *testing.T, r io.Reader, values ...string) { … }

func expectPartialObjectMetaEventsProtobufChecks(t *testing.T, r io.Reader, checks []partialObjectMetadataCheck) { … }

func expectTableV1WatchEvents(t *testing.T, count, columns int, policy metav1.IncludeObjectPolicy, d *json.Decoder) [][]byte { … }

func expectPartialObjectMetaV1Events(t *testing.T, d *json.Decoder, values ...string) { … }

func expectPartialObjectMetaV1EventsProtobuf(t *testing.T, r io.Reader, values ...string) { … }

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

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

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

// TestAllowedEmulationVersions tests the TestServer can start without problem for all allowed emulation versions.
func TestAllowedEmulationVersions(t *testing.T) { … }

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

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

type dependentClient …

func (c *dependentClient) createDependentWithOwners(refs []metav1.OwnerReference) *unstructured.Unstructured { … }

func (c *dependentClient) updateDependentWithOwners(obj *unstructured.Unstructured, refs []metav1.OwnerReference) *unstructured.Unstructured { … }

func (c *dependentClient) patchDependentWithOwner(obj *unstructured.Unstructured, ref metav1.OwnerReference) *unstructured.Unstructured { … }

func (c *dependentClient) deleteDependent() { … }

type warningCounter …

func assertOwnerReferences(t *testing.T, obj *unstructured.Unstructured, refs []metav1.OwnerReference) { … }

func assertWarningCount(t *testing.T, counter warningCounter, expected int) { … }

func assertWarningMessage(t *testing.T, b *bytes.Buffer, expected string) { … }

func assertManagedFields(t *testing.T, obj *unstructured.Unstructured) { … }

func int32Ptr(i int32) *int32 { … }