- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 46 for RSs (0.03 sec)
-
pkg/controller/replicaset/replica_set.go
// them to see if anyone wants to adopt it. // DO NOT observe creation because no controller should be waiting for an // orphan. rss := rsc.getPodReplicaSets(pod) if len(rss) == 0 { return } logger.V(4).Info("Orphan Pod created", "pod", klog.KObj(pod), "detail", pod) for _, rs := range rss { rsc.enqueueRS(rs) } } // When a pod is updated, figure out what replica set/s manage it and wake them
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.2K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set_test.go
for _, r := range c.inRSs { informers.Apps().V1().ReplicaSets().Informer().GetIndexer().Add(r) } if rss := manager.getPodReplicaSets(c.pod); rss != nil { if len(rss) != 1 { t.Errorf("len(rss) = %v, want %v", len(rss), 1) continue } rs := rss[0] if c.outRSName != rs.Name { t.Errorf("Got replica set %+v expected %+v", rs.Name, c.outRSName) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 69.2K bytes - Viewed (0) -
pkg/proxy/ipvs/graceful_termination.go
func (m *GracefulTerminationManager) deleteRsFunc(rsToDelete *listItem) (bool, error) { klog.V(5).InfoS("Trying to delete real server", "realServer", rsToDelete) rss, err := m.ipvs.GetRealServers(rsToDelete.VirtualServer) if err != nil { return false, err } for _, rs := range rss { if rsToDelete.RealServer.Equal(rs) { // For UDP and SCTP traffic, no graceful termination, we immediately delete the RS
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 19 01:20:51 UTC 2023 - 6.6K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/entity/SitemapFile.java
* */ public class SitemapFile implements Sitemap { private static final long serialVersionUID = 1L; /** * Identifies the location of the Sitemap. This location can be a Sitemap, * an Atom file, RSS file or a simple text file. */ private String loc; /** * Identifies the time that the corresponding Sitemap file was modified. It
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 2.7K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/helper/spread.go
sl corelisters.ServiceLister, cl corelisters.ReplicationControllerLister, rsl appslisters.ReplicaSetLister, ssl appslisters.StatefulSetLister, ) labels.Selector { labelSet := make(labels.Set) // Since services, RCs, RSs and SSs match the pod, they won't have conflicting // labels. Merging is safe. if services, err := GetPodServices(sl, pod); err == nil { for _, service := range services {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 25 20:04:48 UTC 2021 - 3.4K bytes - Viewed (0) -
src/runtime/mgcscavenge.go
) // heapRetained returns an estimate of the current heap RSS. func heapRetained() uint64 { return gcController.heapInUse.load() + gcController.heapFree.load() } // gcPaceScavenger updates the scavenger's pacing, particularly // its rate and RSS goal. For this, it requires the current heapGoal, // and the heapGoal for the previous GC cycle. // // The RSS goal is based on the current heap goal with a small overhead
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:48:45 UTC 2024 - 52.3K bytes - Viewed (0) -
pkg/kubelet/stats/provider_test.go
func getTerminatedContainerInfo(seed int, podName string, podNamespace string, containerName string) cadvisorapiv2.ContainerInfo { cinfo := getTestContainerInfo(seed, podName, podNamespace, containerName) cinfo.Stats[0].Memory.RSS = 0 cinfo.Stats[0].CpuInst.Usage.Total = 0 cinfo.Stats[0].Network = &cadvisorapiv2.NetworkStats{ Interfaces: []cadvisorapiv1.InterfaceStats{{ Name: "eth0", RxBytes: 0, RxErrors: 0,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 20K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance_gen.go
err = msgp.WrapError(err, "ID") return } case "pf": z.PercentFreeGoal, err = dc.ReadFloat64() if err != nil { err = msgp.WrapError(err, "PercentFreeGoal") return } case "rss": var zb0002 uint32 zb0002, err = dc.ReadArrayHeader() if err != nil { err = msgp.WrapError(err, "PoolStats") return } if cap(z.PoolStats) >= int(zb0002) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Mar 21 17:21:35 UTC 2024 - 26.8K bytes - Viewed (0) -
pkg/controller/deployment/rolling_test.go
readyPodsFromOldRS: 9, readyPodsFromNewRS: 0, scaleExpected: true, expectedOldReplicas: 8, }, { // the unavailable pods from the newRS would not make us scale down old RSs in a further step deploymentReplicas: 10, maxUnavailable: intstr.FromInt32(2), oldReplicas: 8, newReplicas: 2, readyPodsFromOldRS: 8, readyPodsFromNewRS: 0,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 08 09:10:50 UTC 2023 - 11K bytes - Viewed (0) -
src/encoding/xml/read_test.go
} } // hget http://codereview.appspot.com/rss/mine/rsc const atomFeedString = ` <?xml version="1.0" encoding="utf-8"?>
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 29.1K bytes - Viewed (0)