- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 315 for Pods (0.04 sec)
-
src/internal/coverage/cfile/testsupport.go
return err } } // Collect pods from test run. For the majority of cases we would // expect to see a single pod here, but allow for multiple pods in // case the test harness is doing extra work to collect data files // from builds that it kicks off as part of the testing. podlist, err := pods.CollectPods([]string{dir}, false) if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 09:57:47 UTC 2024 - 8.7K bytes - Viewed (0) -
pkg/kubelet/eviction/types.go
// statsFunc returns the usage stats if known for an input pod. type statsFunc func(pod *v1.Pod) (statsapi.PodStats, bool) // rankFunc sorts the pods in eviction order type rankFunc func(pods []*v1.Pod, stats statsFunc) // signalObservation is the observed resource usage type signalObservation struct { // The resource capacity capacity *resource.Quantity // The available resource available *resource.Quantity
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 18:46:33 UTC 2023 - 7.1K bytes - Viewed (0) -
operator/pkg/verifier/k8s_util.go
return fmt.Errorf("DaemonSet is not ready: %s/%s. %d out of %d expected pods have been scheduled", daemonSet.Namespace, daemonSet.Name, daemonSet.Status.UpdatedNumberScheduled, daemonSet.Status.DesiredNumberScheduled) } case appsv1.RollingUpdateDaemonSetStrategyType: if daemonSet.Status.DesiredNumberScheduled <= 0 { return fmt.Errorf("DaemonSet %s/%s is not ready. Initializing, no pods are running", daemonSet.Namespace, daemonSet.Name)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Nov 28 16:26:13 UTC 2023 - 4K bytes - Viewed (0) -
pkg/config/analysis/analyzers/injection/injection-image.go
} } return true }) for ns, pods := range namespaceMismatchedPods { sort.Strings(pods) c.Report(gvk.Namespace, msg.NewPodsIstioProxyImageMismatchInNamespace(namespaceResources[ns], pods)) } } // GetIstioProxyImage retrieves the proxy image name defined in the sidecar injector // configuration.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun May 05 03:44:57 UTC 2024 - 4.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/util_test.go
return server, storage } server, etcdStorage := newEtcdTestStorage(t, "") defer server.Terminate(t)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 11 12:07:39 UTC 2024 - 6.3K bytes - Viewed (0) -
cmd/kube-controller-manager/app/apps.go
ctx, controllerContext.InformerFactory.Apps().V1().DaemonSets(), controllerContext.InformerFactory.Apps().V1().ControllerRevisions(), controllerContext.InformerFactory.Core().V1().Pods(), controllerContext.InformerFactory.Core().V1().Nodes(), controllerContext.ClientBuilder.ClientOrDie("daemon-set-controller"), flowcontrol.NewBackOff(1*time.Second, 15*time.Minute), ) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 4.5K bytes - Viewed (0) -
pkg/apis/scheduling/types.go
metav1.ObjectMeta // value represents the integer value of this priority class. This is the actual priority that pods // receive when they have the name of this class in their pod spec. Value int32 // globalDefault specifies whether this PriorityClass should be considered as // the default priority for pods that do not have any priority class. // Only one PriorityClass can be marked as `globalDefault`. However, if more than
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 07 23:13:00 UTC 2024 - 3.7K bytes - Viewed (0) -
pkg/kubelet/secret/secret_manager.go
} } // NewWatchingSecretManager creates a manager that keeps a cache of all secrets // necessary for registered pods. // It implements the following logic: // - whenever a pod is created or updated, we start individual watches for all // referenced objects that aren't referenced from other registered pods // - every GetObject() returns a value from local cache propagated via watches
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 5.3K bytes - Viewed (0) -
cluster/gce/upgrade-aliases.sh
--format='value(secondaryIpRanges)') if [[ "${secondary_ranges}" =~ "pods-default" && "${secondary_ranges}" =~ "services-default" ]]; then echo "${secondary_ranges} already contains both pods-default and services-default secondary ranges" return fi echo "Adding secondary ranges: pods-default (${CLUSTER_IP_RANGE}), services-default (${SERVICE_CLUSTER_IP_RANGE})"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 03:36:35 UTC 2024 - 6K bytes - Viewed (0) -
pkg/controller/serviceaccount/tokengetter.go
} func (c clientGetter) GetPod(namespace, name string) (*v1.Pod, error) { if pod, err := c.podLister.Pods(namespace).Get(name); err == nil { return pod, nil } return c.client.CoreV1().Pods(namespace).Get(context.TODO(), name, metav1.GetOptions{}) } func (c clientGetter) GetSecret(namespace, name string) (*v1.Secret, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 21:15:10 UTC 2023 - 3K bytes - Viewed (0)