- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 3,678 for Gone (0.07 sec)
-
platforms/documentation/docs/src/docs/userguide/authoring-builds/logging.adoc
[[logging]] = Logging The log serves as the primary 'UI' of a build tool. If it becomes overly verbose, important warnings and issues can be obscured. However, it is essential to have relevant information to determine if something has gone wrong. Gradle defines six log levels, detailed in <<#logLevels,Log levels>>. In addition to the standard log levels, Gradle introduces two specific levels: _QUIET_ and _LIFECYCLE_.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 23 18:32:47 UTC 2024 - 10.3K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
} if util.PodRedirectionEnabled(ns, pod) { return pod, nil } return nil, nil } func (s *InformerHandlers) Start() { kube.WaitForCacheSync("informer", s.ctx.Done(), s.pods.HasSynced, s.namespaces.HasSynced) go s.queue.Run(s.ctx.Done()) } // Gets a point-in-time snapshot of all pods that are CURRENTLY ambient enabled // (as per control plane annotation)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 21:31:35 UTC 2024 - 11.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_serviceentry_test.go
CanonicalRevision: "latest", ServiceAccount: "sa1", WorkloadType: workloadapi.WorkloadType_POD, WorkloadName: "pod1", Services: nil, // vips for pod1 should be gone now }, }, }, }}) assert.Equal(t, s.lookup(s.addrXdsName("240.240.34.56")), []model.AddressInfo{{ Address: &workloadapi.Address{ Type: &workloadapi.Address_Workload{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 03:01:04 UTC 2024 - 12.9K bytes - Viewed (0) -
pkg/proxy/endpointschangetracker.go
// ensure that no further traffic for the Service gets delivered to them. DeletedUDPEndpoints []ServiceEndpoint // NewlyActiveUDPServices identifies UDP Services that have just gone from 0 to // non-0 endpoints. Existing conntrack entries caching the fact that these // services are black holes must be deleted to ensure that traffic can immediately // begin flowing to the new endpoints.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 21 14:44:08 UTC 2023 - 13.2K bytes - Viewed (0) -
pkg/controller/namespace/deletion/namespaced_resources_deleter.go
// ensure that the status is up to date on the namespace // if we get a not found error, we assume the namespace is truly gone namespace, err = d.retryOnConflictError(ctx, namespace, d.updateNamespaceStatusFunc) if err != nil { if errors.IsNotFound(err) { return nil } return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 20 07:34:23 UTC 2023 - 25.2K bytes - Viewed (0) -
cmd/erasure-healing.go
if isAllNotFound(errs) { err := errFileNotFound if versionID != "" { err = errFileVersionNotFound } // Nothing to do, file is already gone. return er.defaultHealResult(FileInfo{}, storageDisks, storageEndpoints, errs, bucket, object, versionID), err } readQuorum, _, err := objectQuorumFromMeta(ctx, partsMetadata, errs, er.defaultParityCount)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 33.8K bytes - Viewed (0) -
pkg/controller/resourceclaim/controller.go
defer eventBroadcaster.Shutdown() if !cache.WaitForNamedCacheSync("resource_claim", ctx.Done(), ec.podSynced, ec.podSchedulingSynced, ec.claimsSynced, ec.templatesSynced) { return } for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, ec.runWorker, time.Second) } <-ctx.Done() } func (ec *Controller) runWorker(ctx context.Context) { for ec.processNextWorkItem(ctx) { }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 37.1K bytes - Viewed (0) -
pkg/controller/storageversiongc/gc_controller.go
<-ctx.Done() } func (c *Controller) runLeaseWorker(ctx context.Context) { for c.processNextLease(ctx) { } } func (c *Controller) processNextLease(ctx context.Context) bool { key, quit := c.leaseQueue.Get() if quit { return false } defer c.leaseQueue.Done(key) err := c.processDeletedLease(ctx, key) if err == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 10K bytes - Viewed (0) -
cmd/object-lambda-handlers.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 10.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/secure_serving.go
ctx, cancel := context.WithCancel(context.Background()) go func() { select { case <-stopCh: cancel() // stopCh closed, so cancel our context case <-ctx.Done(): } }() // start controllers if possible if controller, ok := s.ClientCA.(dynamiccertificates.ControllerRunner); ok { // runonce to try to prime data. If this fails, it's ok because we fail closed.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 12 20:54:07 UTC 2023 - 10.3K bytes - Viewed (0)