- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 41 for DRAINING (0.23 sec)
-
staging/src/k8s.io/apiserver/plugin/pkg/audit/buffered/buffered.go
// This lets the batching routine continue draining the queue immediately. b.delegateBackend.ProcessEvents(events...) }() } else { func() { defer runtime.HandleCrash() // Execute the real processing in a goroutine to keep it from blocking. // This lets the batching routine continue draining the queue immediately. b.delegateBackend.ProcessEvents(events...) }() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 9.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) -
pkg/envoy/proxy.go
} func (e *envoy) Drain(skipExit bool) error { adminPort := uint32(e.AdminPort) err := DrainListeners(adminPort, e.Sidecar, skipExit) if err != nil { log.Infof("failed draining listeners for Envoy on port %d: %v", adminPort, err) } return err } func (e *envoy) UpdateConfig(config []byte) error { return os.WriteFile(e.ConfigPath, config, 0o666) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 10:02:56 UTC 2024 - 6.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/interface.go
// same value `X`. If the QueuingConfig's DesiredNumQueues field // is zero then the other queuing-specific config parameters are // not changed, so that the queues continue draining as before. // In any case, reconfiguration does not discard any queue unless // and until it is undesired and empty. BeginConfigChange(QueuingConfig) (QueueSetCompleter, error)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 26 12:55:23 UTC 2023 - 6.4K bytes - Viewed (0) -
pilot/cmd/pilot-agent/options/options.go
exitOnZeroActiveConnectionsEnv = env.Register("EXIT_ON_ZERO_ACTIVE_CONNECTIONS", false, "When set to true, terminates proxy when number of active connections become zero during draining").Get() useExternalWorkloadSDSEnv = env.Register("USE_EXTERNAL_WORKLOAD_SDS", false, "When set to true, the istio-agent will require an external SDS and will throw an error if the workload SDS socket is not found").Get()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 09 19:21:50 UTC 2024 - 8.1K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 33K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cache_watcher.go
func (c *cacheWatcher) stopLocked() { if !c.stopped { c.stopped = true // stop without draining the input channel was requested. if !c.drainInputBuffer { close(c.done) } close(c.input) } // Even if the watcher was already stopped, if it previously was // using draining mode and it's not using it now we need to // close the done channel now. Otherwise we could leak the
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 12:22:41 UTC 2023 - 18.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cache_watcher_test.go
ResourceVersion: fmt.Sprintf("%d", rv), }, }, ResourceVersion: rv, } } // TestCacheWatcherDraining verifies the cacheWatcher.process goroutine is properly cleaned up when draining was requested func TestCacheWatcherDraining(t *testing.T) { var lock sync.RWMutex var w *cacheWatcher count := 0 filter := func(string, labels.Set, fields.Set) bool { return true }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 22.9K bytes - Viewed (0)