- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 453 for curr (0.19 sec)
-
staging/src/k8s.io/apimachinery/pkg/api/meta/restmapper.go
resources, err := m.ResourcesFor(partialResource) if err != nil { return resourceType, err } singular := schema.GroupVersionResource{} for _, curr := range resources { currSingular, ok := m.pluralToSingular[curr] if !ok { continue } if singular.Empty() { singular = currSingular continue } if currSingular.Resource != singular.Resource {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 17 01:55:47 UTC 2021 - 16.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/interfaces.go
// // current contents for "myKey" in database. // curr := input.(*MyType) // Guaranteed to succeed. // // // Make the modification // curr.Counter++ // // // Return the modified object - return an error to stop iterating. Return // // a uint64 to alter the TTL on the object, or nil to keep it the same value. // return cur, nil, nil // }, cachedExistingObject // )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 07:53:48 UTC 2024 - 14.8K bytes - Viewed (0) -
src/cmd/vendor/github.com/google/pprof/internal/report/report.go
// to indicate it is relative, or * for the same address. func callgrindAddress(prevInfo *graph.NodeInfo, curr uint64) string { abs := fmt.Sprintf("%#x", curr) if prevInfo == nil { return abs } prev := prevInfo.Address if prev == curr { return "*" } diff := int64(curr - prev) relative := fmt.Sprintf("%+d", diff)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 31 19:48:28 UTC 2024 - 37.5K bytes - Viewed (0) -
src/cmd/link/internal/ld/dwarf.go
} dsu := d.ldr.MakeSymbolUpdater(syms[len(syms)-1]) dsu.AddUint8(0) } return syms } func reverselist(list **dwarf.DWDie) { curr := *list var prev *dwarf.DWDie for curr != nil { next := curr.Link curr.Link = prev prev = curr curr = next } *list = prev } func reversetree(list **dwarf.DWDie) { reverselist(list) for die := *list; die != nil; die = die.Link {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 16:25:18 UTC 2024 - 72.4K bytes - Viewed (0) -
pkg/proxy/endpointschangetracker_test.go
for i := range tc.previousEndpointSlices { prev, curr := tc.previousEndpointSlices[i], tc.currentEndpointSlices[i] switch { case prev == nil && curr == nil: continue case prev == nil: fp.addEndpointSlice(curr) case curr == nil: fp.deleteEndpointSlice(prev) default: fp.updateEndpointSlice(prev, curr) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 21 14:44:08 UTC 2023 - 79.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/aggregate/controller_test.go
if clusterID == "cluster1" { counter = registry1Counter } if clusterID == "cluster2" { counter = registry2Counter } ctrl.AppendServiceHandlerForCluster(clusterID, func(_, curr *model.Service, event model.Event) { counter.Add(1) }) ctrl.AddRegistry(r) } if l := len(ctrl.registries); l != 3 { t.Fatalf("Expected length of the registries slice should be 3, got %d", l) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 14.5K bytes - Viewed (0) -
cmd/metrics-v2.go
if qs.QStats.Avg.Count > 0 || qs.QStats.Curr.Count > 0 { qt := qs.QStats currInQueueBytes.Value = qt.Curr.Bytes currInQueueCount.Value = qt.Curr.Count avgQueueBytes.Value = qt.Avg.Bytes avgQueueCount.Value = qt.Avg.Count maxQueueBytes.Value = qt.Max.Bytes maxQueueCount.Value = qt.Max.Count } activeWorkersCount.Value = float64(qs.ActiveWorkers.Curr)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:54 UTC 2024 - 131.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller_test.go
name: "target ports changed", prev: &svc, curr: &updatedSvc, prevConv: kube.ConvertService(svc, constants.DefaultClusterLocalDomain, "", nil), currConv: kube.ConvertService(updatedSvc, constants.DefaultClusterLocalDomain, "", nil), expect: true, }, testcase{ name: "target ports unchanged", prev: &svc, curr: &svc,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 85K bytes - Viewed (0) -
cmd/site-replication.go
sm.ActiveWorkers.Curr += peer.ActiveWorkers.Curr if peer.ActiveWorkers.Max > sm.ActiveWorkers.Max { sm.ActiveWorkers.Max += peer.ActiveWorkers.Max } sm.Queued.Avg.Bytes += peer.Queued.Avg.Bytes sm.Queued.Avg.Count += peer.Queued.Avg.Count sm.Queued.Curr.Bytes += peer.Queued.Curr.Bytes sm.Queued.Curr.Count += peer.Queued.Curr.Count if peer.Queued.Max.Count > sm.Queued.Max.Count {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 184.3K bytes - Viewed (0) -
pkg/proxy/nftables/proxier_test.go
} for i := range tc.previousEndpoints { prev, curr := tc.previousEndpoints[i], tc.currentEndpoints[i] switch { case prev == nil: fp.OnEndpointSliceAdd(curr) case curr == nil: fp.OnEndpointSliceDelete(prev) default: fp.OnEndpointSliceUpdate(prev, curr) } } result := fp.endpointsMap.Update(fp.endpointsChanges)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 01:31:57 UTC 2024 - 173.5K bytes - Viewed (0)