- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for shuttingDown (0.17 sec)
-
pkg/kube/informerfactory/factory.go
startedInformers sets.Set[informerKey] // wg tracks how many goroutines were started. wg sync.WaitGroup // shuttingDown is true when Shutdown has been called. It may still be running // because it needs to wait for goroutines. shuttingDown bool } var _ InformerFactory = &informerFactory{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 7.9K bytes - Viewed (0) -
pilot/pkg/xds/pushqueue_test.go
Name: fmt.Sprintf("%d", eds), }), }) } } }() done := make(chan struct{}) mu := sync.RWMutex{} go func() { for { con, info, shuttingdown := p.Dequeue() if shuttingdown { return } for eds := range model.ConfigNamesOfKind(info.ConfigsUpdated, kind.ServiceEntry) { mu.Lock() delete(expected, key(con, eds)) mu.Unlock() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 8.8K bytes - Viewed (0) -
pilot/pkg/xds/pushqueue.go
// If model.PushRequest is not nil, it will be Enqueued again once MarkDone has been called. processing map[*Connection]*model.PushRequest shuttingDown bool } func NewPushQueue() *PushQueue { return &PushQueue{ pending: make(map[*Connection]*model.PushRequest), processing: make(map[*Connection]*model.PushRequest),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Sep 16 01:37:15 UTC 2021 - 3.8K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/factory.go
startedInformers map[reflect.Type]bool // wg tracks how many goroutines were started. wg sync.WaitGroup // shuttingDown is true when Shutdown has been called. It may still be running // because it needs to wait for goroutines. shuttingDown bool } // WithCustomResyncConfig sets a custom resync period for the specified informer types.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 18 18:31:26 UTC 2023 - 8.9K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/client/informers/externalversions/factory.go
startedInformers map[reflect.Type]bool // wg tracks how many goroutines were started. wg sync.WaitGroup // shuttingDown is true when Shutdown has been called. It may still be running // because it needs to wait for goroutines. shuttingDown bool } // WithCustomResyncConfig sets a custom resync period for the specified informer types.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 18 18:31:26 UTC 2023 - 9K bytes - Viewed (0) -
pkg/queue/instance.go
q.metrics.latency.Record(time.Since(task.enqueueTime).Seconds()) return task, false } func (q *queueImpl) processNextItem() bool { // Wait until there is a new item in the queue task, shuttingdown := q.get() if shuttingdown { return false } // Run the task. if err := task.task(); err != nil { delay := q.delay log.Infof("Work item handle failed (%v), retry after delay %v", err, delay)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jul 21 16:30:36 UTC 2023 - 4.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/request/server_shutdown_signal.go
// the request handler logic has access to signals rlated to // the server shutdown events type ServerShutdownSignal interface { // Signaled when the apiserver is not receiving any new request ShuttingDown() <-chan struct{} } // ServerShutdownSignalFrom returns the ServerShutdownSignal instance // associated with the request context. // If there is no ServerShutdownSignal asscoaied with the context, // nil is returned.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 27 15:49:30 UTC 2023 - 1.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/lifecycle_signals.go
MuxAndDiscoveryComplete lifecycleSignal } // ShuttingDown returns the lifecycle signal that is signaled when // the server is not accepting any new requests. // this is the lifecycle event that is exported to the request handler // logic to indicate that the server is shutting down. func (s lifecycleSignals) ShuttingDown() <-chan struct{} { return s.NotAcceptingNewRequest.Signaled() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 27 15:49:30 UTC 2023 - 7.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/watch_termination_test.go
} }) } } type fakeServerShutdownSignal struct{} func (fakeServerShutdownSignal) ShuttingDown() <-chan struct{} { return nil } type fakeRequestWaitGroup struct { waiting bool invoked, inflight int } func (f *fakeRequestWaitGroup) Add(delta int) error { f.invoked++
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 27 15:49:49 UTC 2023 - 5.2K bytes - Viewed (0) -
pilot/pkg/xds/discovery.go
// This limits the number of pushes that can happen concurrently semaphore <- struct{}{} // Get the next proxy to push. This will block if there are no updates required. client, push, shuttingdown := queue.Dequeue() if shuttingdown { return } recordPushTriggers(push.Reason) // Signals that a push is done by reading from the semaphore, allowing another send on it. doneFunc := func() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 20:21:09 UTC 2024 - 19K bytes - Viewed (0)