- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for makeHandler (0.41 sec)
-
pkg/proxy/util/nfacct/nfacct_linux_test.go
counterName string handler *fakeHandler err error netlinkCalls int }{ { name: "valid", counterName: "metric-1", handler: &fakeHandler{}, // expected calls: NFNL_MSG_ACCT_NEW netlinkCalls: 1, }, { name: "add duplicate counter", counterName: "metric-2", handler: &fakeHandler{ errs: []error{syscall.EBUSY}, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 06:47:50 UTC 2024 - 18.8K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/plugin_manager_test.go
pluginManager.Run(sourcesReady, stopChan) }() // Add handler for device plugin fakeHandler := newFakePluginHandler() pluginManager.AddHandler(registerapi.DevicePlugin, fakeHandler) const maxDepth = 3 // Make sure the plugin manager is aware of the socket in subdirectories for i := 0; i < maxDepth; i++ { fakeHandler.Reset() pluginDir := socketDir for j := 0; j < i; j++ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 4.4K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconciler_test.go
kubeClient := createTestClient() fakeRecorder := &record.FakeRecorder{} fakeHandler := volumetesting.NewBlockVolumePathHandler() oex := operationexecutor.NewOperationExecutor(operationexecutor.NewOperationGenerator( kubeClient, volumePluginMgr, fakeRecorder, fakeHandler, )) reconciler := NewReconciler( kubeClient, false, /* controllerAttachDetachEnabled */
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 75.4K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/reconciler/reconciler_test.go
fakeKubeClient := controllervolumetesting.CreateTestClient() fakeRecorder := &record.FakeRecorder{} fakeHandler := volumetesting.NewBlockVolumePathHandler() ad := operationexecutor.NewOperationExecutor(operationexecutor.NewOperationGenerator( fakeKubeClient, volumePluginMgr, fakeRecorder, fakeHandler)) informerFactory := informers.NewSharedInformerFactory(fakeKubeClient, controller.NoResyncPeriodFunc())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 07:00:14 UTC 2024 - 72.8K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_generator_test.go
fakeKubeClient := fakeclient.NewSimpleClientset(objects...) fakeRecorder := &record.FakeRecorder{} fakeHandler := volumetesting.NewBlockVolumePathHandler() operationGenerator := NewOperationGenerator( fakeKubeClient, volumePluginMgr, fakeRecorder, fakeHandler) return operationGenerator }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/controller/controller_utils_test.go
body := runtime.EncodeOrDie(clientscheme.Codecs.LegacyCodec(v1.SchemeGroupVersion), &v1.Pod{ObjectMeta: metav1.ObjectMeta{Name: "empty_pod"}}) fakeHandler := utiltesting.FakeHandler{ StatusCode: 200, ResponseBody: string(body), } testServer := httptest.NewServer(&fakeHandler) defer testServer.Close()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 39.4K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set_test.go
// Setup a test server so we can lie about the current state of pods logger, ctx := ktesting.NewTestContext(t) fakeHandler := utiltesting.FakeHandler{ StatusCode: 200, ResponseBody: "{}", SkipRequestFn: skipListerFunc, T: t, } testServer := httptest.NewServer(&fakeHandler) defer testServer.Close()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 69.2K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller_test.go
} store.Add(p) } } func makeTestServer(t *testing.T, namespace string) (*httptest.Server, *utiltesting.FakeHandler) { fakeEndpointsHandler := utiltesting.FakeHandler{ StatusCode: http.StatusOK, ResponseBody: runtime.EncodeOrDie(clientscheme.Codecs.LegacyCodec(v1.SchemeGroupVersion), &v1.Endpoints{}), } mux := http.NewServeMux()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 87.7K bytes - Viewed (0)