- Sort Score
- Result 10 results
- Languages All
Results 191 - 200 of 285 for errf (0.03 sec)
-
tests/integration/operator/switch_cr_test.go
status := &api.InstallStatus{} if err := protomarshal.UnmarshalAllowUnknown(iopStatusString, status); err != nil { return fmt.Errorf("failed to unmarshal istioOperator status: %v", err) } errs := util.Errors{} unhealthyCN = []string{} if status.Status != api.InstallStatus_HEALTHY { errs = util.AppendErr(errs, fmt.Errorf("got IstioOperator status: %v", status.Status)) } for cn, cnstatus := range status.ComponentStatus {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 10 20:33:28 UTC 2024 - 17.5K bytes - Viewed (0) -
pkg/controller/util/node/controller_utils.go
if _, err := kubeClient.CoreV1().Pods(pod.Namespace).UpdateStatus(ctx, pod, metav1.UpdateOptions{}); err != nil { if apierrors.IsNotFound(err) { // NotFound error means that pod was already deleted. // There is nothing left to do with this pod. continue } logger.Info("Failed to update status for pod", "pod", klog.KObj(pod), "err", err) errs = append(errs, err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 05 23:39:52 UTC 2023 - 10.6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/fields/selector_test.go
func TestDeterministicParse(t *testing.T) { s1, err := ParseSelector("x=a,a=x") s2, err2 := ParseSelector("a=x,x=a") if err != nil || err2 != nil { t.Errorf("Unexpected parse error") } if s1.String() != s2.String() { t.Errorf("Non-deterministic parse") } } func expectMatch(t *testing.T, selector string, ls Set) { lq, err := ParseSelector(selector) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 27 08:00:38 UTC 2017 - 11.2K bytes - Viewed (0) -
pkg/config/analysis/analyzers/schema/validation_test.go
) func TestCorrectArgs(t *testing.T) { g := NewWithT(t) m1 := &v1alpha3.VirtualService{} testSchema := schemaWithValidateFn(func(cfg config.Config) (warnings validation.Warning, errs error) { g.Expect(cfg.Name).To(Equal("name")) g.Expect(cfg.Namespace).To(Equal("ns")) g.Expect(cfg.Spec).To(Equal(m1)) return nil, nil }) ctx := &fixtures.Context{ Resources: []*resource.Instance{ {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 08:32:06 UTC 2024 - 4.5K bytes - Viewed (0) -
pkg/kube/client.go
return nil, err } c.mapper, err = clientFactory.mapper.Get() if err != nil { return nil, err } c.informerFactory = informerfactory.NewSharedInformerFactory() c.kube, err = kubernetes.NewForConfig(c.config) if err != nil { return nil, err } c.metadata, err = metadata.NewForConfig(c.config) if err != nil { return nil, err } c.dynamic, err = dynamic.NewForConfig(c.config)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 39K bytes - Viewed (0) -
src/testing/slogtest/slogtest.go
c.f(l) } // Collect and check the results. var errs []error res := results() if g, w := len(res), len(cases); g != w { return fmt.Errorf("got %d results, want %d", g, w) } for i, got := range results() { c := cases[i] for _, check := range c.checks { if problem := check(got); problem != "" { errs = append(errs, fmt.Errorf("%s: %s", problem, c.explanation)) } } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Nov 08 17:55:47 UTC 2023 - 9.8K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/status/naming_controller.go
continue } if err := equalToAcceptedOrFresh(shortName, "", allResources); err != nil { errs = append(errs, err) } } if err := utilerrors.NewAggregate(errs); err != nil { namesAcceptedCondition.Status = apiextensionsv1.ConditionFalse namesAcceptedCondition.Reason = "ShortNamesConflict" namesAcceptedCondition.Message = err.Error() } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.2K bytes - Viewed (0) -
cmd/erasure-common.go
context.Canceled, } ignoredErrs = append(ignoredErrs, objectOpIgnoredErrs...) errs := g.Wait() for index, err := range errs { if err == nil { continue } if !IsErr(err, ignoredErrs...) { storageLogOnceIf(ctx, fmt.Errorf("Drive %s, path (%s/%s) returned an error (%w)", disks[index], req.Bucket, req.Prefix, err), disks[index].String()) } } // Return all the metadata.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.6K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager.go
return func(_ context.Context) (done bool, err error) { if errs := vm.desiredStateOfWorld.PopPodErrors(podName); len(errs) > 0 { return true, errors.New(strings.Join(errs, "; ")) } return len(vm.getUnmountedVolumes(podName, expectedVolumes)) == 0, nil } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 21.5K bytes - Viewed (0) -
pkg/kubelet/config/http_test.go
internalPod := &api.Pod{} if err := k8s_api_v1.Convert_v1_Pod_To_core_Pod(pod, internalPod, nil); err != nil { t.Fatalf("%s: Cannot convert pod %#v, %#v", testCase.desc, pod, err) } if errs := validation.ValidatePodCreate(internalPod, validation.PodValidationOptions{}); len(errs) != 0 { t.Errorf("%s: Expected no validation errors on %#v, Got %v", testCase.desc, pod, errs.ToAggregate()) } } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 14 09:38:23 UTC 2022 - 11.2K bytes - Viewed (0)