kubernetes/staging/src/k8s.io/kube-aggregator/pkg/apiserver/handler_discovery_test.go

func newDiscoveryManager(rm discoveryendpoint.ResourceManager) *discoveryManager { … }

// Returns true if the queue of services to sync is complete which means
// everything has been reconciled and placed into merged document
func waitForQueueComplete(stopCh <-chan struct{ … }

// Test that the discovery manager starts and aggregates from two local API services
func TestBasic(t *testing.T) { … }

func checkAPIGroups(t *testing.T, api apidiscoveryv2.APIGroupDiscoveryList, response *apidiscoveryv2.APIGroupDiscoveryList) { … }

// TestInitialRunHasAllAPIServices tests that when discovery is ready, all APIService
// are present and ones that have not synced are in the list as Stale.
func TestInitialRunHasAllAPIServices(t *testing.T) { … }

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

// TestV2Beta1Skew tests that aggregated apiservers that only serve V2Beta1
// are still supported
func TestV2Beta1Skew(t *testing.T) { … }

// Test that a handler associated with an APIService gets pinged after the
// APIService has been marked as dirty
func TestDirty(t *testing.T) { … }

// Shows that waitForQueueComplete also waits for syncing to
// complete by artificially making the sync handler take a long time
func TestWaitForSync(t *testing.T) { … }

// Show that an APIService can be removed and that its group no longer remains
// if there are no versions
func TestRemoveAPIService(t *testing.T) { … }

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

func testLegacyFallbackWithCustomRootHandler(t *testing.T, rootHandlerFn func(http.ResponseWriter, *http.Request)) { … }

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

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

// Exercises the 304 Not Modified Path of the aggregator
// This path in 1.26.0 would result in a deadlock if an aggregated APIService
// returned a 304 Not Modified response for its own aggregated discovery document.
func TestNotModified(t *testing.T) { … }

// copied from staging/src/k8s.io/apiserver/pkg/endpoints/discovery/v2/handler_test.go
func fuzzAPIGroups(atLeastNumGroups, maxNumGroups int, seed int64) apidiscoveryv2.APIGroupDiscoveryList { … }

// copied from staging/src/k8s.io/apiserver/pkg/endpoints/discovery/v2/handler_test.go
func fetchPath(handler http.Handler, etag string) (*http.Response, []byte, *apidiscoveryv2.APIGroupDiscoveryList) { … }

type completerWorkqueue …

var _ …

func newCompleterWorkqueue(wq workqueue.TypedRateLimitingInterface[string]) *completerWorkqueue { … }

func (q *completerWorkqueue) Add(item string) { … }

func (q *completerWorkqueue) AddAfter(item string, duration time.Duration) { … }

func (q *completerWorkqueue) AddRateLimited(item string) { … }

func (q *completerWorkqueue) Done(item string) { … }

func (q *completerWorkqueue) isComplete() bool { … }