kubernetes/staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/controller/controller_test.go

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

type mockWorkQueue …

func (m *mockWorkQueue) Done(item string) { … }

func (m *mockWorkQueue) Get() (item string, shutdown bool) { … }

func (m *mockWorkQueue) Add(item string) { … }

func (m *mockWorkQueue) ShutDown()                  { … }

func (m *mockWorkQueue) AddRateLimited(item string) { … }

type mockHealthChecker …

func (m *mockHealthChecker) Check(req *http.Request) error { … }

func (m *mockHealthChecker) Name() string { … }