- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 85 for errp (0.23 sec)
-
cmd/xl-storage-disk-id-check.go
startTime := time.Now() trace := globalTrace.NumSubscribers(madmin.TraceStorage) > 0 return func(sz int64, errp *error) { duration := time.Since(startTime) var err error if errp != nil && *errp != nil { err = *errp } atomic.AddUint64(&p.apiCalls[s], 1) if IsErr(err, []error{ errFaultyDisk, errFaultyRemoteDisk,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 33.4K bytes - Viewed (0) -
cmd/test-utils_test.go
req, err := newTestStreamingRequest(method, urlStr, contentLength, chunkSize, body) if err != nil { return nil, err } currTime := UTCNow() signature, err := signStreamingRequest(req, accessKey, secretKey, currTime) if err != nil { return nil, err } req, err = assembleStreamingChunks(req, body, chunkSize, secretKey, signature, currTime)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 76.9K bytes - Viewed (0) -
pkg/test/framework/components/istio/configmap.go
cfgMap, err := ic.getConfigMap(c, ic.configMapName()) if err != nil { return nil, err } // Get the MeshConfig yaml from the config map. icYAML, err := getInjectConfigYaml(cfgMap, "config") if err != nil { return nil, err } // Parse the YAML. myic, err = yamlToInjectConfig(icYAML) if err != nil { return nil, err } // Save the updated mesh config.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 12.8K bytes - Viewed (0) -
pkg/test/framework/components/istio/cleanup.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 5K bytes - Viewed (0) -
cmd/erasure-healing_test.go
if err != nil { t.Fatal(err) } // Checking abandoned parts should do nothing err = er.checkAbandonedParts(ctx, bucket, object, madmin.HealOpts{ScanMode: madmin.HealNormalScan, Remove: true}) if err != nil { t.Fatal(err) } _, err = er.HealObject(ctx, bucket, object, "", madmin.HealOpts{ScanMode: madmin.HealNormalScan}) if err != nil { t.Fatal(err) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 49K bytes - Viewed (0) -
pkg/test/framework/components/namespace/kube.go
perCluster := make([]map[string]string, len(n.ctx.AllClusters())) if err := n.forEachCluster(func(i int, c cluster.Cluster) error { ns, err := c.Kube().CoreV1().Namespaces().Get(context.TODO(), n.Name(), metav1.GetOptions{}) if err != nil { return err } perCluster[i] = ns.Labels return nil }); err != nil { return nil, err } for i, clusterLabels := range perCluster { if i == 0 { continue
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 9K bytes - Viewed (0) -
pkg/test/kube/dump.go
// add a retry loop since sometimes reserving a port fails err := retry.UntilSuccess(func() error { var err error fw, err = c.NewPortForwarder(pod.Name, pod.Namespace, "", 0, port) if err != nil { return err } if err = fw.Start(); err != nil { return err } return nil }, retry.MaxAttempts(5), retry.Delay(time.Millisecond*10)) return fw, err } var dumpClient = &http.Client{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 22.2K bytes - Viewed (0) -
pkg/test/framework/components/istio/kube.go
fetchFn := testKube.NewSinglePodFetch(c, i.cfg.SystemNamespace, "istio=pilot") pods, err := testKube.WaitUntilPodsAreReady(fetchFn) if err != nil { return "", err } pod := pods[0] fw, err := c.NewPortForwarder(pod.Name, pod.Namespace, "", 0, 15012) if err != nil { return "", err } if err := fw.Start(); err != nil { return "", err } return fw.Address(), nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 31.1K bytes - Viewed (0) -
cmd/erasure-healing.go
errs, bucket, object, versionID), err } readQuorum, _, err := objectQuorumFromMeta(ctx, partsMetadata, errs, er.defaultParityCount) if err != nil { m, derr := er.deleteIfDangling(ctx, bucket, object, partsMetadata, errs, nil, ObjectOptions{ VersionID: versionID, }) errs = make([]error, len(errs)) if derr == nil { derr = errFileNotFound if versionID != "" { derr = errFileVersionNotFound
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 33.8K bytes - Viewed (0) -
pkg/config/validation/validation.go
if src := from.GetSource(); src != nil { errs = appendErrors(errs, check(len(src.Namespaces) != 0, "From.Namespaces")) errs = appendErrors(errs, check(len(src.NotNamespaces) != 0, "From.NotNamespaces")) errs = appendErrors(errs, check(len(src.Principals) != 0, "From.Principals")) errs = appendErrors(errs, check(len(src.NotPrincipals) != 0, "From.NotPrincipals"))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 04:03:33 UTC 2024 - 107.2K bytes - Viewed (0)