- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 41 for DRAINING (0.16 sec)
-
tests/integration/ambient/baseline_test.go
if opt.Scheme != scheme.TCP { return } // Ensure we don't get stuck on old connections with old RBAC rules. This causes 45s test times // due to draining. opt.NewConnectionPerRequest = true t.NewSubTest("permissive").Run(func(t framework.TestContext) { t.ConfigIstio().Eval(apps.Namespace.Name(), map[string]string{ "Destination": dst.Config().Service,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 00:07:28 UTC 2024 - 78.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Striped.java
if (existing != null) { return existing; } } drainQueue(); return created; } // N.B. Draining the queue is only necessary to ensure that we don't accumulate empty references // in the array. We could skip this if we decide we don't care about holding on to Reference // objects indefinitely.
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 10 20:55:18 UTC 2023 - 20.3K bytes - Viewed (0) -
pilot/pkg/model/service.go
} // Endpoint health status. type HealthStatus int32 const ( // Healthy. Healthy HealthStatus = 1 // Unhealthy. UnHealthy HealthStatus = 2 // Draining - the constant matches envoy Draining HealthStatus = 3 ) // IstioEndpoint defines a network address (IP:port) associated with an instance of the // service. A service has one or more instances each running in a
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 02:03:58 UTC 2024 - 46.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Striped.java
if (existing != null) { return existing; } } drainQueue(); return created; } // N.B. Draining the queue is only necessary to ensure that we don't accumulate empty references // in the array. We could skip this if we decide we don't care about holding on to Reference // objects indefinitely.
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 10 20:55:18 UTC 2023 - 20.3K bytes - Viewed (0) -
pkg/bootstrap/config.go
rbacEnvoyStatsMatcherInclusionSuffix = "rbac.allowed,rbac.denied,shadow_allowed,shadow_denied" requiredEnvoyStatsMatcherInclusionSuffixes = rbacEnvoyStatsMatcherInclusionSuffix + ",downstream_cx_active" // Needed for draining. // required for metrics based on stat_prefix in virtual service. requiredEnvoyStatsMatcherInclusionRegexes = `vhost\.*\.route\.*` // Prefixes of V2 metrics. // "reporter" prefix is for istio standard metrics.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 17:02:38 UTC 2024 - 27.6K bytes - Viewed (0) -
cluster/gce/upgrade.sh
if [[ "${kubectl_rc}" != 0 ]]; then echo "== FAILED to get bootID ${instance} ==" echo "${boot_id}" return ${kubectl_rc} fi # Drain node echo "== Draining ${instance}. == " >&2 local drain_rc "${KUBE_ROOT}/cluster/kubectl.sh" drain --delete-emptydir-data --force --ignore-daemonsets "${instance}" \ && drain_rc=$? || drain_rc=$? if [[ "${drain_rc}" != 0 ]]; then
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 21:13:22 UTC 2024 - 25.2K bytes - Viewed (0) -
src/runtime/mgc.go
// Preemption must not occur here, or another G might see // p.gcMarkWorkerMode. // Disable preemption so we can use the gcw. If the // scheduler wants to preempt us, we'll stop draining, // dispose the gcw, and then preempt. node.m.set(acquirem()) pp := gp.m.p.ptr() // P can't change with preemption disabled. if gcBlackenEnabled == 0 { println("worker mode", pp.gcMarkWorkerMode)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 16:25:21 UTC 2024 - 62K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/genericapiserver_graceful_termination_test.go
config, _ := setUp(t) config.ShutdownDelayDuration = 100 * time.Millisecond config.ShutdownSendRetryAfter = keepListening // we enable watch draining, any positive value will do that config.ShutdownWatchTerminationGracePeriod = 2 * time.Second config.AuditPolicyRuleEvaluator = fAudit config.AuditBackend = fAudit
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 38.3K bytes - Viewed (0) -
pkg/features/kube_features.go
KubeletTracing featuregate.Feature = "KubeletTracing" // owner: @alexanderConstantinescu // kep: http://kep.k8s.io/3836 // alpha: v1.28 // beta: v1.30 // // Implement connection draining for terminating nodes for // `externalTrafficPolicy: Cluster` services. KubeProxyDrainingTerminatingNodes featuregate.Feature = "KubeProxyDrainingTerminatingNodes" // owner: @yt2985 // kep: http://kep.k8s.io/2799
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 22:51:23 UTC 2024 - 45.2K bytes - Viewed (0) -
pilot/pkg/networking/core/gateway.go
log.Warnf("Gateway missing for route %s. This is normal if gateway was recently deleted.", routeName) // This can happen when a gateway has recently been deleted. Envoy will still request route // information due to the draining of listeners, so we should not return an error. return &route.RouteConfiguration{ Name: routeName, VirtualHosts: []*route.VirtualHost{}, ValidateClusters: proto.BoolFalse, } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 04:44:06 UTC 2024 - 46.4K bytes - Viewed (0)