- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 576 for probs (0.05 sec)
-
pilot/cmd/pilot-agent/status/ready/probe_test.go
probe := Probe{AdminPort: uint16(server.Listener.Addr().(*net.TCPAddr).Port)} probe.Context = ctx err := probe.Check() g.Expect(err).To(HaveOccurred()) g.Expect(probe.atleastOnceReady).Should(BeFalse()) err = probe.Check() g.Expect(err).To(HaveOccurred()) g.Expect(probe.atleastOnceReady).Should(BeFalse()) server.Close() server = testserver.CreateAndStartServer(liveServerStats)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 5.9K bytes - Viewed (0) -
pkg/kubelet/prober/prober_test.go
}, { // No handler probe: &v1.Probe{}, expectError: true, expectedResult: results.Failure, }, { // Probe fails probe: execProbe, execResult: probe.Failure, expectedResult: results.Failure, }, { // Probe succeeds probe: execProbe, execResult: probe.Success, expectedResult: results.Success, }, { // Probe result is warning
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 07:17:35 UTC 2023 - 9.7K bytes - Viewed (0) -
platforms/core-runtime/build-configuration/src/test/groovy/org/gradle/internal/buildconfiguration/UpdateDaemonJvmModifierTest.groovy
then: def props = daemonJvmPropertiesFile.properties props.size() == 3 props[DaemonJvmPropertiesDefaults.TOOLCHAIN_VERSION_PROPERTY] == "11" props[DaemonJvmPropertiesDefaults.TOOLCHAIN_VENDOR_PROPERTY] == "IBM" props[DaemonJvmPropertiesDefaults.TOOLCHAIN_IMPLEMENTATION_PROPERTY] == "vendor-specific"
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 25 13:41:21 UTC 2024 - 4.6K bytes - Viewed (0) -
src/runtime/proc_runtime_test.go
// same pos+inc twice. for procs := 2; procs <= 64; procs++ { ord.reset(uint32(procs)) checked := make([]bool, procs*procs) // We want at least procs*len(ord.coprimes) different pos+inc values // before we start repeating. for i := 0; i < procs*len(ord.coprimes); i++ { enum := ord.start(uint32(i)) j := enum.pos*uint32(procs) + enum.inc if checked[j] { println("procs:", procs, "pos:", enum.pos, "inc:", enum.inc)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 01 18:43:08 UTC 2022 - 1.4K bytes - Viewed (0) -
pkg/registry/core/componentstatus/validator.go
req, err := httpprober.NewProbeRequest(url, nil) if err != nil { return probe.Unknown, "", fmt.Errorf("failed to construct probe request: %w", err) } result, data, err := server.Prober.Probe(req, probeTimeOut) if err != nil { return probe.Unknown, "", err } if result == probe.Failure { return probe.Failure, data, err } if server.Validate != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 20 13:08:41 UTC 2023 - 2.9K bytes - Viewed (0) -
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) -
src/runtime/mgclimit_test.go
// // fill + (window * procs * gcBackgroundUtilization - window * procs * (1-gcBackgroundUtilization)) = n // fill = n - (window * procs * gcBackgroundUtilization - window * procs * (1-gcBackgroundUtilization)) // fill = n + window * procs * ((1-gcBackgroundUtilization) - gcBackgroundUtilization) // fill = n + window * procs * (1-2*gcBackgroundUtilization) // window = (fill - n) / (procs * (1-2*gcBackgroundUtilization))) //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 13 16:02:20 UTC 2022 - 9K bytes - Viewed (0) -
src/main/java/org/codelibs/core/io/PropertiesUtil.java
* </p> * * @param props * プロパティセット。{@literal null}であってはいけません * @param in * 入力ストリーム。{@literal null}であってはいけません */ public static void load(final Properties props, final InputStream in) { assertArgumentNotNull("props", props); assertArgumentNotNull("in", in); try { props.load(in); } catch (final IOException e) {
Registered: Wed Jun 12 12:50:12 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 8.9K bytes - Viewed (0) -
pkg/probe/grpc/grpc.go
klog.V(4).ErrorS(err, "rpc probe failed") } } else { klog.V(4).ErrorS(err, "health rpc probe failed") } return probe.Failure, fmt.Sprintf("error: health rpc probe failed: %+v", err), nil } if resp.GetStatus() != grpchealth.HealthCheckResponse_SERVING { return probe.Failure, fmt.Sprintf("service unhealthy (responded with %q)", resp.GetStatus().String()), nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 25 19:28:03 UTC 2023 - 4K bytes - Viewed (0) -
cmd/admin-server-info.go
}, MinioEnvVars: make(map[string]string, 10), } for poolNumber := range poolNumbers { props.PoolNumbers = append(props.PoolNumbers, poolNumber) } sort.Ints(props.PoolNumbers) props.PoolNumber = func() int { if len(props.PoolNumbers) == 1 { return props.PoolNumbers[0] } return math.MaxInt // this indicates that its unset. }() sensitive := map[string]struct{}{
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.9K bytes - Viewed (0)