- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 53 for prober (0.23 sec)
-
pkg/probe/exec/exec.go
"k8s.io/kubernetes/pkg/probe" "k8s.io/klog/v2" "k8s.io/utils/exec" ) const ( maxReadLength = 10 * 1 << 10 // 10KB ) // New creates a Prober. func New() Prober { return execProber{} } // Prober is an interface defining the Probe object for container readiness/liveness checks. type Prober interface { Probe(e exec.Cmd) (probe.Result, string, error) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 08:58:18 UTC 2024 - 2.2K bytes - Viewed (0) -
pkg/probe/exec/exec_test.go
err error }{ // Ok {probe.Success, false, true, "OK", "OK", nil}, // Ok {probe.Success, false, true, "OK", "OK", &fakeExitError{true, 0}}, // Ok - truncated output {probe.Success, false, true, elevenKilobyte, tenKilobyte, nil}, // Run returns error {probe.Unknown, true, true, "", "", fmt.Errorf("test error")}, // Unhealthy {probe.Failure, false, true, "Fail", "", &fakeExitError{true, 1}},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 08:58:18 UTC 2024 - 3.8K bytes - Viewed (0) -
pkg/volume/plugins_test.go
func newTestPlugin() []VolumePlugin { return []VolumePlugin{&testPlugins{}} } func TestVolumePluginMgrFunc(t *testing.T) { vpm := VolumePluginMgr{} var prober DynamicPluginProber = nil // TODO (#51147) inject mock vpm.InitPlugins(newTestPlugin(), prober, nil) plug, err := vpm.FindPluginByName(testPluginName) if err != nil { t.Fatal("Can't find the plugin by name") } if plug.GetPluginName() != testPluginName {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 4.3K bytes - Viewed (0) -
pkg/kubemark/hollow_kubelet.go
"k8s.io/kubernetes/pkg/kubelet/cadvisor" "k8s.io/kubernetes/pkg/kubelet/cm" containertest "k8s.io/kubernetes/pkg/kubelet/container/testing" probetest "k8s.io/kubernetes/pkg/kubelet/prober/testing" kubetypes "k8s.io/kubernetes/pkg/kubelet/types" kubeletutil "k8s.io/kubernetes/pkg/kubelet/util" "k8s.io/kubernetes/pkg/util/oom" "k8s.io/kubernetes/pkg/volume" "k8s.io/kubernetes/pkg/volume/configmap"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:10:54 UTC 2024 - 7.8K bytes - Viewed (0) -
pkg/kube/apimirror/probe.go
URISchemeHTTP URIScheme = "HTTP" // URISchemeHTTPS means that the scheme used will be https:// URISchemeHTTPS URIScheme = "HTTPS" ) // HTTPHeader describes a custom header to be used in HTTP probes type HTTPHeader struct { // The header field name Name string `json:"name" protobuf:"bytes,1,opt,name=name"` // The header field value Value string `json:"value" protobuf:"bytes,2,opt,name=value"` }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 4.4K bytes - Viewed (0) -
hack/testdata/pod-with-metadata-and-probes.yaml
- image: registry.k8s.io/nginx:1.7.9 name: target readinessProbe: exec: command: ["/bin/sh", "-c", "cat probe"] livenessProbe: exec: command: ["/bin/sh", "-c", "cat probe"] startupProbe: exec: command: ["/bin/sh", "-c", "cat probe"] initContainers: - image: busybox
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 16 17:26:20 UTC 2024 - 471 bytes - Viewed (0) -
src/net/ipsock_posix.go
// and we don't need to probe the capability. probes = probes[:1] } for i := range probes { s, err := sysSocket(syscall.AF_INET6, syscall.SOCK_STREAM, syscall.IPPROTO_TCP) if err != nil { continue } defer poll.CloseFunc(s) syscall.SetsockoptInt(s, syscall.IPPROTO_IPV6, syscall.IPV6_V6ONLY, probes[i].value) sa, err := probes[i].laddr.sockaddr(syscall.AF_INET6) if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 8.6K bytes - Viewed (0) -
platforms/ide/problems-api/src/main/java/org/gradle/api/problems/internal/Problem.java
/** * A long description detailing the problem. * <p> * Details can elaborate on the problem, and provide more information about the problem. * They can be multiple lines long, but should not detail solutions; for that, use {@link #getSolutions()}. */ @Nullable String getDetails(); /** * Return the location data associated available for this problem. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 09:03:53 UTC 2024 - 2.1K bytes - Viewed (0) -
internal/http/dial_linux.go
// TCP starts sending keepalive probes _ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, syscall.TCP_KEEPIDLE, 15) // Number of probes. // ~ cat /proc/sys/net/ipv4/tcp_keepalive_probes (defaults to 9, we reduce it to 5) _ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, syscall.TCP_KEEPCNT, 5) // Wait time after successful probe in seconds.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 4.8K bytes - Viewed (3) -
cmd/kubelet/app/plugins.go
allPlugins = append(allPlugins, local.ProbeVolumePlugins()...) allPlugins = append(allPlugins, csi.ProbeVolumePlugins()...) return allPlugins, nil } // GetDynamicPluginProber gets the probers of dynamically discoverable plugins // for kubelet. // Currently only Flexvolume plugins are dynamically discoverable. func GetDynamicPluginProber(pluginDir string, runner exec.Interface) volume.DynamicPluginProber {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 13 21:09:52 UTC 2024 - 3.1K bytes - Viewed (0)