kubernetes/test/integration/storageversion/storage_version_filter_test.go

type wrappedStorageVersionManager …

func (w *wrappedStorageVersionManager) UpdateStorageVersions(loopbackClientConfig *rest.Config, serverID string) { … }

func (w *wrappedStorageVersionManager) Completed() bool { … }

func assertBlocking(name string, t *testing.T, err error, shouldBlock bool) { … }

func testBuiltinResourceWrite(t *testing.T, cfg *rest.Config, shouldBlock bool) { … }

func testCRDWrite(t *testing.T, cfg *rest.Config, shouldBlock bool) { … }

func testAPIServiceWrite(t *testing.T, cfg *rest.Config, shouldBlock bool) { … }

func testCRWrite(t *testing.T, cfg *rest.Config, shouldBlock bool) { … }

func testStorageVersionWrite(t *testing.T, cfg *rest.Config, shouldBlock bool) { … }

func testNonPersistedWrite(t *testing.T, cfg *rest.Config, shouldBlock bool) { … }

func testBuiltinResourceRead(t *testing.T, cfg *rest.Config, shouldBlock bool) { … }

// TestStorageVersionBootstrap ensures that before the StorageVersions are
// updated, only the following the request are accepted by the apiserver:
// 1. read requests
// 2. non-persisting write requests
// 3. write requests to the storageversion API
// 4. requests to CR or aggregated API
func TestStorageVersionBootstrap(t *testing.T) { … }