- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 42 for Cur (0.02 sec)
-
pkg/controller/daemon/daemon_controller.go
// When a pod is updated, figure out what sets manage it and wake them // up. If the labels of the pod have changed we need to awaken both the old // and new set. old and cur must be *v1.Pod types. func (dsc *DaemonSetsController) updatePod(logger klog.Logger, old, cur interface{}) { curPod := cur.(*v1.Pod) oldPod := old.(*v1.Pod) if curPod.ResourceVersion == oldPod.ResourceVersion { // Periodic resync will send update events for all known pods.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.3K bytes - Viewed (0) -
src/expvar/expvar.go
} // Add adds delta to v. func (v *Float) Add(delta float64) { for { cur := v.f.Load() curVal := math.Float64frombits(cur) nxtVal := curVal + delta nxt := math.Float64bits(nxtVal) if v.f.CompareAndSwap(cur, nxt) { return } } } // Set sets v to value. func (v *Float) Set(value float64) { v.f.Store(math.Float64bits(value))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 21:32:11 UTC 2024 - 9.1K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/deploymentcontroller.go
return cur, false, false } if curNum > ControllerVersion { // A newer version owns this gateway, let them handle it return cur, false, false } if curNum == ControllerVersion { // We already manage this at this version // We will manage it, but no need to attempt to apply the version annotation, which could race with newer versions return cur, false, true }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 21:43:20 UTC 2024 - 26.3K bytes - Viewed (0) -
pkg/controller/deployment/deployment_controller.go
// is updated and wake them up. If the anything of the ReplicaSets have changed, we need to // awaken both the old and new deployments. old and cur must be *apps.ReplicaSet // types. func (dc *DeploymentController) updateReplicaSet(logger klog.Logger, old, cur interface{}) { curRS := cur.(*apps.ReplicaSet) oldRS := old.(*apps.ReplicaSet) if curRS.ResourceVersion == oldRS.ResourceVersion {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.2K bytes - Viewed (0) -
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/text/TreeFormatter.java
return " - "; } } private static class NumberedPrefixer implements Prefixer { private int cur = 0; @Override public String nextPrefix() { return " " + ++cur + ". "; } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 22 14:04:39 UTC 2024 - 11.8K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller.go
// and what services it will be a member of, and enqueue the union of these. // old and cur must be *v1.Pod types. func (e *Controller) updatePod(old, cur interface{}) { services := endpointsliceutil.GetServicesToUpdateOnPodChange(e.serviceLister, old, cur) for key := range services { e.queue.AddAfter(key, e.endpointUpdatesBatchPeriod) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 26.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller.go
if c.opts.SystemNamespace != "" { registerHandlers[*v1.Namespace]( c, c.namespaces, "Namespaces", func(old *v1.Namespace, cur *v1.Namespace, event model.Event) error { if cur.Name == c.opts.SystemNamespace { return c.onSystemNamespaceEvent(old, cur, event) } return nil }, nil, ) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0) -
pkg/xds/server.go
// Envoy can send two DiscoveryRequests with same version and nonce. // when it detects a new resource. We should respond if they change. prev := sets.New(previousResources...) cur := sets.New(request.ResourceNames...) removed := prev.Difference(cur) added := cur.Difference(prev) // We should always respond "alwaysRespond" marked requests to let Envoy finish warming // even though Nonce match and it looks like an ACK.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 16.3K bytes - Viewed (0) -
pkg/controller/ttlafterfinished/ttlafterfinished_controller.go
if job.DeletionTimestamp == nil && needsCleanup(job) { tc.enqueue(logger, job) } } func (tc *Controller) updateJob(logger klog.Logger, old, cur interface{}) { job := cur.(*batch.Job) logger.V(4).Info("Updating job", "job", klog.KObj(job)) if job.DeletionTimestamp == nil && needsCleanup(job) { tc.enqueue(logger, job) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 23:59:28 UTC 2024 - 10.4K bytes - Viewed (0) -
pkg/controller/disruption/disruption.go
logger.V(4).Info("Add DB", "podDisruptionBudget", klog.KObj(pdb)) dc.enqueuePdb(logger, pdb) } func (dc *DisruptionController) updateDB(logger klog.Logger, old, cur interface{}) { // TODO(mml) ignore updates where 'old' is equivalent to 'cur'. pdb := cur.(*policy.PodDisruptionBudget) logger.V(4).Info("Update DB", "podDisruptionBudget", klog.KObj(pdb)) dc.enqueuePdb(logger, pdb) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.1K bytes - Viewed (0)