kubernetes/test/integration/apiserver/flowcontrol/concurrency_test.go

const nominalConcurrencyMetricsName …

const dispatchedRequestCountMetricsName …

const rejectedRequestCountMetricsName …

const labelPriorityLevel …

const timeout …

func setup(t testing.TB, maxReadonlyRequestsInFlight, maxMutatingRequestsInFlight int) (context.Context, *rest.Config, framework.TearDownFunc) { … }

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

func getClientFor(loopbackConfig *rest.Config, username string) clientset.Interface { … }

func getMetrics(c clientset.Interface) (string, error) { … }

func getNominalConcurrencyOfPriorityLevel(c clientset.Interface) (map[string]int, error) { … }

func getRequestCountOfPriorityLevel(c clientset.Interface) (map[string]int, map[string]int, error) { … }

func createPriorityLevelAndBindingFlowSchemaForUser(c clientset.Interface, username string, concurrencyShares, queuelength int) (*flowcontrol.PriorityLevelConfiguration, *flowcontrol.FlowSchema, error) { … }

func streamRequests(parallel int, request func(), wg *sync.WaitGroup, stopCh <-chan struct{ … }