- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,062 for draining (0.14 sec)
-
pilot/cmd/pilot-agent/status/ready/probe.go
} return err } type ServerInfoState int32 const ( // Server is live and serving traffic. Live ServerInfoState = 0 // Server is draining listeners in response to external health checks failing. Draining ServerInfoState = 1 // Server has not yet completed cluster manager initialization. PreInitializing ServerInfoState = 2
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 00:35:05 UTC 2024 - 4.5K bytes - Viewed (0) -
android/guava/src/com/google/common/io/ReaderInputStream.java
int totalBytesRead = 0; boolean doneEncoding = endOfInput; DRAINING: while (true) { // We stay in draining mode until there are no bytes left in the output buffer. Then we go // back to encoding/flushing. if (draining) { totalBytesRead += drain(b, off + totalBytesRead, len - totalBytesRead); if (totalBytesRead == len || doneFlushing) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 28 20:13:02 UTC 2023 - 9.3K bytes - Viewed (0) -
guava/src/com/google/common/io/ReaderInputStream.java
int totalBytesRead = 0; boolean doneEncoding = endOfInput; DRAINING: while (true) { // We stay in draining mode until there are no bytes left in the output buffer. Then we go // back to encoding/flushing. if (draining) { totalBytesRead += drain(b, off + totalBytesRead, len - totalBytesRead); if (totalBytesRead == len || doneFlushing) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 28 20:13:02 UTC 2023 - 9.3K bytes - Viewed (0) -
istioctl/pkg/util/configdump/listener.go
return nil, err } dal := make([]*admin.ListenersConfigDump_DynamicListener, 0) for _, l := range listenerDump.DynamicListeners { // If a listener was reloaded, it would contain both the active and draining state // delete the draining state for proper comparison l.DrainingState = nil if l.ActiveState != nil { dal = append(dal, l) } } // Support v2 or v3 in config dump. See ads.go:RequestedTypes for more info.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Nov 03 08:41:32 UTC 2022 - 2.5K bytes - Viewed (0) -
pkg/envoy/agent.go
} func (a *Agent) DisableDraining() { a.skipDrain.Store(true) } func (a *Agent) DrainNow() { log.Infof("Agent draining proxy") err := a.proxy.Drain(true) if err != nil { log.Warnf("Error in invoking drain listeners endpoint: %v", err) } // If we drained now, skip draining + waiting later // When we terminate, we will instead exit immediately a.DisableDraining() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 24 16:04:22 UTC 2024 - 9K bytes - Viewed (0) -
pilot/pkg/features/experimental.go
"If not empty, services with this label will use header based persistent sessions", ).Get() DrainingLabel = env.Register( "PILOT_DRAINING_LABEL", "istio.io/draining", "If not empty, endpoints with the label value present will be sent with status DRAINING.", ).Get() EnableDistributionTracking = env.Register( "PILOT_ENABLE_CONFIG_DISTRIBUTION_TRACKING", false,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 17:02:38 UTC 2024 - 10.2K bytes - Viewed (0) -
pilot/pkg/xds/endpoints/endpoint_builder.go
if !features.SendUnhealthyEndpoints.Load() && ep.HealthStatus == model.UnHealthy { return false } // Draining endpoints are only sent to 'persistent session' clusters. draining := ep.HealthStatus == model.Draining || features.DrainingLabel != "" && ep.Labels[features.DrainingLabel] != "" if draining { persistentSession := b.service.Attributes.Labels[features.PersistentSessionLabel] != "" if !persistentSession {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 02:18:19 UTC 2024 - 26.1K bytes - Viewed (0) -
src/time/tick_test.go
// When using Go 1.23 sync timers/tickers, draining is never needed // (that's the whole point of the sync timer/ticker change). drain1 := func() { for range drainTries { select { case <-C: return default: } Sleep(sched) } } // drainAsync removes potential stale time values after Stop/Reset. // When using Go 1 async timers, draining one or two values
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 17:10:37 UTC 2024 - 14.7K bytes - Viewed (0) -
pilot/pkg/networking/grpcgen/grpcgen_test.go
} if len(ep.GetEndpoints()) == 0 { t.Fatal("No endpoint not found for persistent session cluster") } lbep1 := ep.GetEndpoints()[0] if lbep1.LbEndpoints[0].HealthStatus.Number() != 3 { t.Fatal("Draining status not included") } }) t.Run("gRPC-dial", func(t *testing.T) { for _, host := range []string{ testSvcHost, //"istiod.istio-system.svc", //"istiod.istio-system", //"istiod",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 09:04:02 UTC 2024 - 16.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/endpointslice.go
svc != nil && svc.Attributes.Labels[features.PersistentSessionLabel] != "" && (e.Conditions.Serving == nil || *e.Conditions.Serving) && (e.Conditions.Terminating == nil || *e.Conditions.Terminating) { return model.Draining } return model.UnHealthy } func (esc *endpointSliceController) updateEndpointCacheForSlice(hostName host.Name, slice *v1.EndpointSlice) { var endpoints []*model.IstioEndpoint
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 16.9K bytes - Viewed (0)