- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 2,475 for happen (0.12 sec)
-
pkg/kube/util.go
if !ok { // shouldn't happen return obj, nil } // ManagedFields is large and we never use it t.GetObjectMeta().SetManagedFields(nil) // only container ports can be used if pod := obj.(*corev1.Pod); pod != nil { containers := []corev1.Container{} for _, c := range pod.Spec.Containers { if len(c.Ports) > 0 { containers = append(containers, corev1.Container{ Ports: c.Ports,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 18.6K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r73/DependencyArtifactDownloadProgressEventCrossVersionTest.groovy
brokenDownloads.each { assert it.failed it.assertIsDownload(modules.projectC.pom.uri, 0) } } def "attaches parent to events for downloads that happen during project configuration"() { def modules = setupBuildWithArtifactDownloadDuringConfiguration() when: def events = ProgressEvents.create()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 16 10:10:39 UTC 2024 - 11.4K bytes - Viewed (0) -
pkg/controller/storageversiongc/gc_controller.go
return } // Identity lease deletion and storageversion update don't happen too often. Start one // worker for each of them. // runLeaseWorker handles legit identity lease deletion, while runStorageVersionWorker // handles storageversion creation/update with non-existing id. The latter should rarely // happen. It's okay for the two workers to conflict on update.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 10K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/tlsconfig.go
// we allow removing all client ca bundles because the server is still secure when this happens. it just means // that there isn't a hint to clients about which client-cert to used. this happens when there is no client-ca // yet known for authentication, which can happen in aggregated apiservers and some kube-apiserver deployment modes. newContent.clientCA = caBundleContent{caBundle: currClientCABundle} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 10.3K bytes - Viewed (0) -
cmd/kube-proxy/app/server_linux.go
if config.Mode == proxyconfigapi.ProxyModeIPTables { logger.Info("Using iptables Proxier") if dualStack { ipt, _ := getIPTables(s.PrimaryIPFamily) // TODO this has side effects that should only happen when Run() is invoked. proxier, err = iptables.NewDualStackProxier( ctx, ipt, utilsysctl.New(), exec.New(), config.IPTables.SyncPeriod.Duration,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 18.1K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
log.Warnf("failed to sync host IPset: %v", err) consErr = append(consErr, err) } podsByUID := slices.GroupUnique(ambientPods, (*corev1.Pod).GetUID) if err := s.buildZtunnelSnapshot(podsByUID); err != nil { log.Warnf("failed to construct initial ztunnel snapshot: %v", err) consErr = append(consErr, err) } return errors.Join(consErr...) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 13.4K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/topology_hints.go
deviceHints[resource] = nil continue } // Short circuit to regenerate the same hints if there are already // devices allocated to the Container. This might happen after a // kubelet restart, for example. allocated := m.podDevices.containerDevices(string(pod.UID), container.Name, resource) if allocated.Len() > 0 { if allocated.Len() != requested {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jan 27 02:10:25 UTC 2024 - 9.9K bytes - Viewed (0) -
tests/update_test.go
t.Errorf("Not error should happen when updating with gorm expr, but got %v", err) } if err := DB.Model(&results[1]).Clauses(clause.Returning{Columns: []clause.Column{{Name: "age"}}}).Updates(map[string]interface{}{"age": gorm.Expr("age + ?", 100)}).Error; err != nil { t.Errorf("Not error should happen when updating with gorm expr, but got %v", err) }
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Mon Dec 04 03:50:58 UTC 2023 - 30.3K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/labels.go
func getIntValueFromLabel(labels map[string]string, label string) (int, error) { if strValue, found := labels[label]; found { intValue, err := strconv.Atoi(strValue) if err != nil { // This really should not happen. Just set value to 0 to handle this abnormal case return 0, err } return intValue, nil } // Do not report error, because there should be many old containers without label now.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 22 02:01:31 UTC 2024 - 10.9K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/classloader/TransformReplacer.java
// The close() on this loader will block until this method completes. JarEntry classEntry = jarFile.getJarEntry(classNameToPath(className)); if (classEntry == null) { // This can happen if the class was "injected" into the classloader, e.g. when decorated class is generated by the ObjectFactory. // Injected classes reuse the protection domain. See ClassLoaderUtils.define and defineDecorator.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 12.7K bytes - Viewed (0)