}
	}

	outObjFn := func(shares int32, annotations map[string]string) *flowcontrol.PriorityLevelConfiguration {
		return &flowcontrol.PriorityLevelConfiguration{
			ObjectMeta: metav1.ObjectMeta{
				Annotations: annotations,
			},
			Spec: flowcontrol.PriorityLevelConfigurationSpec{
				Type: flowcontrol.PriorityLevelEnablementLimited,
				Limited: &flowcontrol.LimitedPriorityLevelConfiguration{
					NominalConcurrencyShares: shares,

	store := &genericregistry.Store{
		NewFunc:                   func() runtime.Object { return &flowcontrol.FlowSchema{} },
		NewListFunc:               func() runtime.Object { return &flowcontrol.FlowSchemaList{} },
		DefaultQualifiedResource:  flowcontrol.Resource("flowschemas"),
		SingularQualifiedResource: flowcontrol.Resource("flowschema"),

		CreateStrategy:      flowschema.Strategy,
		UpdateStrategy:      flowschema.Strategy,

					Type: v1beta2.LimitResponseTypeReject,
				},
			},
			expected: &flowcontrol.LimitedPriorityLevelConfiguration{
				NominalConcurrencyShares: 100,
				LimitResponse: flowcontrol.LimitResponse{
					Type: flowcontrol.LimitResponseTypeReject,
				},
			},
		},
	}

	for _, test := range tests {
		t.Run(test.name, func(t *testing.T) {
			out := &flowcontrol.LimitedPriorityLevelConfiguration{}

	// the single rate limiter held by the cache
	rateLimiter flowcontrol.RateLimiter
}

func (c *singleCache) get(key interface{}) flowcontrol.RateLimiter {
	return c.rateLimiter
}

// lruCache is a least-recently-used cache
type lruCache struct {
	// factory to use to create new rate limiters
	rateLimiterFactory func() flowcontrol.RateLimiter
	// the actual LRU cache
	cache *lru.Cache
}

limitations under the License.
*/

// +k8s:deepcopy-gen=package
// +groupName=flowcontrol.apiserver.k8s.io

// Package flowcontrol provides api definitions for the "flowcontrol.apiserver.k8s.io" api group.

limitations under the License.
*/

// +k8s:conversion-gen=k8s.io/kubernetes/pkg/apis/flowcontrol
// +k8s:conversion-gen-external-types=k8s.io/api/flowcontrol/v1beta2
// +k8s:defaulter-gen=TypeMeta
// +k8s:defaulter-gen-input=k8s.io/api/flowcontrol/v1beta2

// +groupName=flowcontrol.apiserver.k8s.io

		}
	}
}

func TestLRUCache(t *testing.T) {
	rateLimiters := []flowcontrol.RateLimiter{
		flowcontrol.NewTokenBucketRateLimiter(1., 1),
		flowcontrol.NewTokenBucketRateLimiter(2., 2),
		flowcontrol.NewTokenBucketRateLimiter(3., 3),
		flowcontrol.NewTokenBucketRateLimiter(4., 4),
	}
	nextRateLimiter := 0
	rateLimiterFactory := func() flowcontrol.RateLimiter {
		rateLimiter := rateLimiters[nextRateLimiter]
		nextRateLimiter++

			errShouldContain: "",
		},
		{
			runtimeConfig:    "flowcontrol.apiserver.k8s.io/v1beta1=false",
			errShouldContain: "",
		},
		{
			runtimeConfig:    "flowcontrol.apiserver.k8s.io/v1beta2=false",
			errShouldContain: "",
		},
		{
			runtimeConfig:    "flowcontrol.apiserver.k8s.io/v1beta3=false",
			errShouldContain: "",
		},
		{
			runtimeConfig:    "flowcontrol.apiserver.k8s.io/v1beta3=true",
			errShouldContain: "",

limitations under the License.
*/

package testing

import (
	"context"

	"k8s.io/apiserver/pkg/util/flowcontrol/debug"
	fq "k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing"
	"k8s.io/apiserver/pkg/util/flowcontrol/metrics"
	fcrequest "k8s.io/apiserver/pkg/util/flowcontrol/request"
)

// NewNoRestraintFactory makes a QueueSetFactory that produces

import (
	"fmt"
	"testing"

	"github.com/google/go-cmp/cmp"

	flowcontrol "k8s.io/api/flowcontrol/v1"
	apiequality "k8s.io/apimachinery/pkg/api/equality"
	"k8s.io/apiserver/pkg/apis/flowcontrol/bootstrap"
)

func TestBootstrapConfigurationWithDefaulted(t *testing.T) {
	scheme := NewAPFScheme()

	bootstrapFlowSchemas := make([]*flowcontrol.FlowSchema, 0)