- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 210 for prober (0.16 sec)
-
pilot/cmd/pilot-agent/status/server.go
} if prober.HTTPGet != nil && prober.HTTPGet.Port.Type != apimirror.Int { return fmt.Errorf("invalid prober config for %v, the port must be int type", path) } if prober.TCPSocket != nil && prober.TCPSocket.Port.Type != apimirror.Int { return fmt.Errorf("invalid prober config for %v, the port must be int type", path) } return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 31.1K bytes - Viewed (1) -
pkg/kubelet/prober/prober_manager_test.go
m.CleanupPods(desiredPods) removedProbes := []probeKey{ {"pod_cleanup", "prober1", readiness}, {"pod_cleanup", "prober2", liveness}, {"pod_cleanup", "prober3", startup}, } expectedProbes := []probeKey{ {"pod_keep", "prober1", readiness}, {"pod_keep", "prober2", liveness}, {"pod_keep", "prober3", startup}, } if err := waitForWorkerExit(t, m, removedProbes); err != nil { t.Fatal(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 18.8K bytes - Viewed (0) -
pilot/cmd/pilot-agent/status/server_test.go
testCases := []struct { name string probes []ready.Prober err error }{ { name: "success probe", probes: []ready.Prober{rp}, err: nil, }, { name: "not ready probe", probes: []ready.Prober{urp}, err: errors.New("not ready"), }, { name: "both probes", probes: []ready.Prober{rp, urp}, err: errors.New("not ready"),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 42.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/etcd3.go
} if err != nil { clientErr = err return false, nil } prober = newProber clientErr = nil return true, nil }, stopCh) // Close the client on shutdown. go func() { defer utilruntime.HandleCrash() <-stopCh lock.Lock() defer lock.Unlock() if prober != nil { prober.Close() clientErr = fmt.Errorf("server is shutting down") } }()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 07:56:39 UTC 2024 - 15.1K bytes - Viewed (0) -
pkg/volume/plugins.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:13:15 UTC 2024 - 38.2K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/desired_state_of_world_test.go
Plugin: volumetesting.FakeVolumePlugin{ PluginName: "attachable", }, }, }, }, } volumePluginMgr := volume.VolumePluginMgr{} volumePluginMgr.InitPlugins(plugins, nil /* prober */, fakeVolumeHost) seLinuxTranslator := util.NewFakeSELinuxLabelTranslator() dsw := NewDesiredStateOfWorld(&volumePluginMgr, seLinuxTranslator) testcases := map[string]struct { pod1 *v1.Pod pod2 *v1.Pod
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 34K bytes - Viewed (0) -
pkg/volume/git_repo/git_repo_test.go
} func TestCanSupport(t *testing.T) { plugMgr := volume.VolumePluginMgr{} tempDir, host := newTestHost(t) defer os.RemoveAll(tempDir) plugMgr.InitPlugins(ProbeVolumePlugins(), nil /* prober */, host) plug, err := plugMgr.FindPluginByName("kubernetes.io/git-repo") if err != nil { t.Fatal("Can't find the plugin by name") } if plug.GetPluginName() != "kubernetes.io/git-repo" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 08:26:26 UTC 2024 - 12K bytes - Viewed (0) -
pkg/kubelet/volume_host.go
kubelet *Kubelet, secretManager secret.Manager, configMapManager configmap.Manager, tokenManager *token.Manager, clusterTrustBundleManager clustertrustbundle.Manager, plugins []volume.VolumePlugin, prober volume.DynamicPluginProber) (*volume.VolumePluginMgr, error) { // Initialize csiDriverLister before calling InitPlugins var informerFactory informers.SharedInformerFactory var csiDriverLister storagelisters.CSIDriverLister
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 10K bytes - Viewed (0) -
pkg/volume/testing/volume_host.go
host.hostUtil = hostutil.NewFakeHostUtil(pathToTypeMap) host.exec = &testingexec.FakeExec{DisableScripts: true} host.pluginMgr = &VolumePluginMgr{} if err := host.pluginMgr.InitPlugins(plugins, nil /* prober */, host); err != nil { t.Fatalf("Failed to init plugins while creating fake volume host: %v", err) } host.subpather = &subpath.FakeSubpath{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 16.5K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager_test.go
} fakeRecorder := &record.FakeRecorder{} plugMgr := &volume.VolumePluginMgr{} // TODO (#51147) inject mock prober fakeVolumeHost := volumetest.NewFakeKubeletVolumeHost(t, tmpDir, kubeClient, nil) fakeVolumeHost.WithNode(node) plugMgr.InitPlugins([]volume.VolumePlugin{attachablePlug, unattachablePlug}, nil /* prober */, fakeVolumeHost) stateProvider := &fakePodStateProvider{} fakePathHandler := volumetest.NewBlockVolumePathHandler()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.1K bytes - Viewed (0)