- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 924 for prober (0.11 sec)
-
pkg/kubelet/prober/scale_test.go
// causing conntrack entries and ephemeral ports to be hold for 60 seconds // despite the probe may have finished in less than 1 second. // If the rate of probes is higher than the rate the OS recycles the ports used, // it can consume a considerable number of ephemeral ports or conntrack entries. // These tests verify that after certain period the probes keep working, if the probes // don't close the sockets faster, they will start to fail.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 16 16:33:01 UTC 2023 - 8.2K bytes - Viewed (0) -
pkg/volume/secret/secret_test.go
} func TestCanSupport(t *testing.T) { pluginMgr := volume.VolumePluginMgr{} tempDir, host := newTestHost(t, nil) defer os.RemoveAll(tempDir) pluginMgr.InitPlugins(ProbeVolumePlugins(), nil /* prober */, host) plugin, err := pluginMgr.FindPluginByName(secretPluginName) if err != nil { t.Fatal("Can't find the plugin by name") } if plugin.GetPluginName() != secretPluginName {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 01 15:56:32 UTC 2022 - 19.5K bytes - Viewed (0) -
pkg/volume/flexvolume/fake_watcher.go
import ( "github.com/fsnotify/fsnotify" utilfs "k8s.io/kubernetes/pkg/util/filesystem" ) // Mock filesystem watcher type fakeWatcher struct { watches []string // List of watches added by the prober, ordered from least recent to most recent. eventHandler utilfs.FSEventHandler } var _ utilfs.FSWatcher = &fakeWatcher{} func newFakeWatcher() *fakeWatcher { return &fakeWatcher{ watches: nil, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 20 17:33:45 UTC 2018 - 1.4K 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) -
helm/minio/templates/servicemonitor.yaml
tlsConfig: ca: secret: name: {{ .Values.tls.certSecret }} key: {{ .Values.tls.publicCrt }} serverName: {{ template "minio.fullname" . }} {{- end }} prober: url: {{ template "minio.fullname" . }}.{{ .Release.Namespace }}:{{ .Values.service.port }} path: /minio/v2/metrics/cluster {{- if .Values.tls.enabled }} scheme: https {{- else }} scheme: http
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Apr 17 06:04:15 UTC 2023 - 3.8K bytes - Viewed (0) -
pkg/probe/http/request.go
"strconv" "strings" v1 "k8s.io/api/core/v1" "k8s.io/component-base/version" "k8s.io/kubernetes/pkg/probe" ) // NewProbeRequest returns an http.Request suitable for use as a request for a // probe. func NewProbeRequest(url *url.URL, headers http.Header) (*http.Request, error) { return newProbeRequest(url, headers, "probe") } // NewRequestForHTTPGetAction returns an http.Request derived from httpGet.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 07:39:55 UTC 2023 - 3.3K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/fake_kuberuntime_manager.go
kubecontainer "k8s.io/kubernetes/pkg/kubelet/container" "k8s.io/kubernetes/pkg/kubelet/images" "k8s.io/kubernetes/pkg/kubelet/lifecycle" "k8s.io/kubernetes/pkg/kubelet/logs" proberesults "k8s.io/kubernetes/pkg/kubelet/prober/results" utilpointer "k8s.io/utils/pointer" ) const ( fakeSeccompProfileRoot = "/fakeSeccompProfileRoot" fakeNodeAllocatableMemory = "32Gi" fakeNodeAllocatableCPU = "16"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 17:55:59 UTC 2024 - 5.1K bytes - Viewed (0) -
pkg/volume/downwardapi/downwardapi_test.go
} func TestCanSupport(t *testing.T) { pluginMgr := volume.VolumePluginMgr{} tmpDir, host := newTestHost(t, nil) defer os.RemoveAll(tmpDir) pluginMgr.InitPlugins(ProbeVolumePlugins(), nil /* prober */, host) plugin, err := pluginMgr.FindPluginByName(downwardAPIPluginName) if err != nil { t.Fatal("Can't find the plugin by name") } if plugin.GetPluginName() != downwardAPIPluginName {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 02 04:48:49 UTC 2023 - 11.2K 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)