- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 1,729 for info2 (0.1 sec)
-
pkg/kubelet/stats/cadvisor_stats_provider_test.go
} for _, name := range nostatsOverrides { info, found := infos[name] if !found { t.Errorf("No container defined with name %v", name) } info.Spec.Memory = cadvisorapiv2.MemorySpec{} info.Spec.Cpu = cadvisorapiv2.CpuSpec{} info.Spec.HasMemory = false info.Spec.HasCpu = false info.Spec.HasNetwork = false infos[name] = info } options := cadvisorapiv2.RequestOptions{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 30.2K bytes - Viewed (0) -
cmd/kubeadm/app/discovery/token/token.go
klog.V(1).Infof("[discovery] Created cluster-info discovery client, requesting info from %q", endpoint) insecureClusterInfo, err := getClusterInfo(client, insecureBootstrapConfig, token, interval, timeout) if err != nil { return nil, err } // Validate the token in the cluster info insecureKubeconfigBytes, err := validateClusterInfoToken(insecureClusterInfo, token)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 14 13:07:56 UTC 2024 - 10.1K bytes - Viewed (0) -
pkg/kubelet/stats/cadvisor_stats_provider.go
// 1. info.spec both cpu memory and network are false conditions // 2. info.Stats both network and cpu or memory are nil // 3. both zero CPU instantaneous usage zero memory RSS usage and zero network usage, // and false otherwise. func isContainerTerminated(info *cadvisorapiv2.ContainerInfo) bool { if !info.Spec.HasCpu && !info.Spec.HasMemory && !info.Spec.HasNetwork { return true }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 16 13:34:22 UTC 2023 - 18.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/memory/discovery.go
} func (sd *ServiceDiscovery) AddWorkloadInfo(infos ...*model.WorkloadInfo) { sd.mutex.Lock() defer sd.mutex.Unlock() for _, info := range infos { sd.addresses[info.ResourceName()] = workloadToAddressInfo(info.Workload) } } func (sd *ServiceDiscovery) RemoveWorkloadInfo(info *model.WorkloadInfo) { sd.mutex.Lock() defer sd.mutex.Unlock() delete(sd.addresses, info.ResourceName()) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 23:10:01 UTC 2024 - 12.4K bytes - Viewed (0) -
src/go/token/position_test.go
t.Run(test.name, func(t *testing.T) { fs := NewFileSet() f := fs.AddFile(filename, -1, filesize) for _, info := range test.infos { f.AddLineColumnInfo(info.Offset, info.Filename, info.Line, info.Column) } if !reflect.DeepEqual(f.infos, test.want) { t.Errorf("\ngot %+v, \nwant %+v", f.infos, test.want) } }) } } func TestIssue57490(t *testing.T) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 31 20:26:14 UTC 2024 - 14.3K bytes - Viewed (0) -
security/pkg/pki/ca/selfsignedcarootcertrotator.go
select { case <-time.After(rotator.backOffTime): rootCertRotatorLog.Infof("Jitter complete, start rotator.") case <-stopCh: rootCertRotatorLog.Info("Received stop signal, so stop the root cert rotator.") return } } ticker := time.NewTicker(rotator.config.CheckInterval) for { select { case <-ticker.C: rootCertRotatorLog.Info("Check and rotate root cert.") rotator.checkAndRotateRootCert()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Nov 30 19:33:26 UTC 2023 - 10.4K bytes - Viewed (0) -
pkg/proxy/serviceport.go
if ingFamily := proxyutil.GetIPFamilyFromIP(ip); ingFamily == ipFamily { info.loadBalancerVIPs = append(info.loadBalancerVIPs, ip) } else { invalidIPs = append(invalidIPs, ip) } } if len(invalidIPs) > 0 { klog.V(4).InfoS("Service change tracker ignored the following load balancer ingress IPs for given Service as they don't match the IP Family",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jan 09 08:17:56 UTC 2024 - 10.7K bytes - Viewed (0) -
pkg/volume/csi/csi_mounter.go
dataFile := filepath.Join(volPath, volDataFileName) klog.V(4).Info(log("also deleting volume info data file [%s]", dataFile)) if err := os.Remove(dataFile); err != nil && !os.IsNotExist(err) { return errors.New(log("failed to delete volume data file [%s]: %v", dataFile, err)) } // remove volume path klog.V(4).Info(log("deleting volume path [%s]", volPath))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jan 30 10:47:59 UTC 2024 - 21K bytes - Viewed (1) -
staging/src/k8s.io/apimachinery/pkg/util/net/interface.go
if len(addrs) > 0 { for i := range addrs { klog.V(4).Infof("Checking addr %s.", addrs[i].String()) ip, _, err := netutils.ParseCIDRSloppy(addrs[i].String()) if err != nil { return nil, err } if memberOf(ip, family) { if ip.IsGlobalUnicast() { klog.V(4).Infof("IP found %v", ip) return ip, nil } else { klog.V(4).Infof("Non-global unicast address found %v", ip) } } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 27 07:07:03 UTC 2022 - 14.7K bytes - Viewed (0) -
pilot/test/mock/config.go
} log.Info("Created mock descriptor") // create configuration objects elts := make(map[int]config2.Config) for i := 0; i < n; i++ { elts[i] = Make(namespace, i) } log.Info("Make mock objects") // post all elements for _, elt := range elts { if _, err := r.Create(elt); err != nil { t.Error(err) } } log.Info("Created mock objects")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 13.2K bytes - Viewed (0)