- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 160 for Probe (0.06 sec)
-
cmd/server-rlimit.go
"github.com/minio/minio/internal/logger" "github.com/minio/pkg/v3/sys" ) func oldLinux() bool { currentKernel, err := kernel.CurrentVersion() if err != nil { // Could not probe the kernel version return false } if currentKernel == 0 { // We could not get any valid value return false return false } // legacy linux indicator for printing warnings
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 30 11:58:12 UTC 2024 - 2.9K bytes - Viewed (0) -
pilot/pkg/autoregistration/internal/health/controller.go
c.healthCondition.Add(condition) } func transformHealthEvent(proxy *model.Proxy, entryName string, event HealthEvent) HealthCondition { cond := &v1alpha1.IstioCondition{ Type: status.ConditionHealthy, // last probe and transition are the same because // we only send on transition in the agent LastProbeTime: timestamppb.Now(), LastTransitionTime: timestamppb.Now(), } out := HealthCondition{ proxy: proxy,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Sep 19 20:41:55 UTC 2023 - 3.4K bytes - Viewed (0) -
platforms/core-execution/file-watching/src/main/java/org/gradle/internal/watch/registry/impl/WatchableHierarchies.java
public class WatchableHierarchies { private static final Logger LOGGER = LoggerFactory.getLogger(WatchableHierarchies.class); public static final String INVALIDATING_HIERARCHY_MESSAGE = "Invalidating hierarchy because watch probe hasn't been triggered"; private final FileWatcherProbeRegistry probeRegistry; private final Predicate<String> immutableLocationsFilter; /** * Files that can be watched. *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jan 25 17:02:39 UTC 2024 - 15.8K bytes - Viewed (0) -
pkg/proxy/metrics/metrics.go
Help: "Cumulative proxy nftables cleanup failures", StabilityLevel: metrics.ALPHA, }, ) // ProxyHealthzTotal is the number of returned HTTP Status for each // healthz probe. ProxyHealthzTotal = metrics.NewCounterVec( &metrics.CounterOpts{ Subsystem: kubeProxySubsystem, Name: "proxy_healthz_total", Help: "Cumulative proxy healthz HTTP status",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 13.7K bytes - Viewed (0) -
prow/config/metrics/metrics.yaml
# Created with `curl -Ls https://github.com/kubernetes-sigs/metrics-server/releases/download/v0.7.1/components.yaml > prow/config/metrics/metrics.yaml` # With a startup probe and `--kubelet-insecure-tls` added. apiVersion: v1 kind: ServiceAccount metadata: labels: k8s-app: metrics-server name: metrics-server namespace: kube-system --- apiVersion: rbac.authorization.k8s.io/v1 kind: ClusterRole metadata: labels:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 11 20:51:38 UTC 2024 - 4.6K bytes - Viewed (0) -
platforms/jvm/jvm-services/src/main/java/org/gradle/internal/jvm/inspection/MetadataProbe.java
thing.write(probeClass.get()); } }); } catch (FileNotFoundException e) { throw new GradleException("Unable to write Java probe file", e); } return probeFile; } private static byte[] createProbeClass() { ClassWriter cw = new ClassWriter(0); createClassHeader(cw); createConstructor(cw);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Sep 28 15:09:49 UTC 2023 - 4.7K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 13.4K bytes - Viewed (0) -
internal/http/dial_linux.go
// 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. // ~ cat /proc/sys/net/ipv4/tcp_keepalive_intvl (defaults to 75 secs, we reduce it to 15 secs) _ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, syscall.TCP_KEEPINTVL, 15) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 4.8K bytes - Viewed (0) -
src/runtime/iface.go
// Returns nil if the given interface/type pair isn't present. func (t *itabTableType) find(inter *interfacetype, typ *_type) *itab { // Implemented using quadratic probing. // Probe sequence is h(i) = h0 + i*(i+1)/2 mod 2^k. // We're guaranteed to hit all table entries using this probe sequence. mask := t.size - 1 h := itabHashFunc(inter, typ) & mask for i := uintptr(1); ; i++ { p := (**itab)(add(unsafe.Pointer(&t.entries), h*goarch.PtrSize))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 22.5K bytes - Viewed (0) -
tools/istio-iptables/pkg/validation/validator.go
echo(conn, []byte(strconv.Itoa(int(port)))) // Handle connections // Since the write amount is small it should fit in sock buffer and never blocks. if port != config.ServerOriginalPort { // This could be probe request from no where continue } // Server recovers the magical original port c <- DONE return } } func (s *Service) Run() error { // at most 2 message: ipv4 and ipv6
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Nov 01 04:37:36 UTC 2023 - 5.5K bytes - Viewed (0)