- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 72 for Peal (0.23 sec)
-
internal/crypto/metadata_test.go
t.Errorf("Test %d: sealed KMS data mismatch: got '%v' - want '%v'", i, kmsKey, test.SealedDataKey) } if sealedKey.Algorithm != test.SealedKey.Algorithm { t.Errorf("Test %d: seal algorithm mismatch: got '%s' - want '%s'", i, sealedKey.Algorithm, test.SealedKey.Algorithm) } if !bytes.Equal(sealedKey.IV[:], test.SealedKey.IV[:]) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 02 00:13:57 GMT 2024 - 18.7K bytes - Viewed (0) -
cmd/metrics.go
}, []string{ // current version "version", // commit-id of the current version "commit", }, ) ) const ( healMetricsNamespace = "self_heal" cacheNamespace = "cache" s3Namespace = "s3" bucketNamespace = "bucket" minioNamespace = "minio" diskNamespace = "disk" interNodeNamespace = "internode" ) func init() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 06:48:36 GMT 2024 - 16.9K bytes - Viewed (0) -
cmd/xl-storage.go
return err } var w *os.File // Create file if not found. Not doing O_DIRECT here to avoid the code that does buffer aligned writes. // AppendFile() is only used by healing code to heal objects written in old format. w, err = s.openFileSync(filePath, os.O_CREATE|os.O_APPEND|os.O_WRONLY, volumeDir) if err != nil { return err } defer w.Close() n, err := w.Write(buf)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 84.7K bytes - Viewed (0) -
internal/disk/stat_linux.go
if err != nil { // Mostly not found error // Check if there is a parent device: // e.g. if the mount is based on /dev/nvme0n1p1, let's calculate the // real device name (nvme0n1) to get its sysfs information parentDevPath, e := os.Readlink("/sys/class/block/" + devName) if e == nil { parentDev := filepath.Base(filepath.Dir(parentDevPath))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 26 19:34:50 GMT 2024 - 4.8K bytes - Viewed (0) -
istioctl/pkg/wait/wait_test.go
ns := action.GetNamespace() watch, err := fc.Tracker().Watch(gvr, ns) if err != nil { return false, nil, err } // Kubernetes Fake watches do not add initial state, but real server does // https://kubernetes.io/docs/reference/using-api/api-concepts/#semantics-for-watch // Tracking in https://github.com/kubernetes/kubernetes/issues/123109 gvk := gvk.MustFromGVR(gvr).Kubernetes()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 08:28:50 GMT 2024 - 6.8K bytes - Viewed (0) -
cmd/naughty-disk_test.go
// specified by the developer. The purpose is to simulate errors // that are hard to simulate in practice like DiskNotFound. // Programmed errors are stored in errors field. type naughtyDisk struct { // The real disk disk StorageAPI // Programmed errors: API call number => error to return errors map[int]error // The error to return when no error value is programmed defaultErr error // The current API call number
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 9.3K bytes - Viewed (0) -
cmd/globals.go
ptr := globalDeploymentIDPtr.Load() if ptr == nil { return "" } return *ptr } globalAllHealState = newHealState(GlobalContext, true) // The always present healing routine ready to heal objects globalBackgroundHealRoutine = newHealRoutine() globalBackgroundHealState = newHealState(GlobalContext, false) globalMRFState = mrfState{ opCh: make(chan partialOperation, mrfOpsQueueSize), }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 16.5K bytes - Viewed (0) -
cmd/api-errors.go
}, ErrHealNotImplemented: { Code: "XMinioHealNotImplemented", Description: "This server does not implement heal functionality.", HTTPStatusCode: http.StatusBadRequest, }, ErrHealNoSuchProcess: { Code: "XMinioHealNoSuchProcess", Description: "No such heal process is running on the server", HTTPStatusCode: http.StatusBadRequest, }, ErrHealInvalidClientToken: {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 91.4K bytes - Viewed (6) -
cmd/erasure-server-pool.go
} var countNoHeal int for _, pool := range z.serverPools { result, err := pool.HealFormat(ctx, dryRun) if err != nil && !errors.Is(err, errNoHealRequired) { healingLogOnceIf(ctx, err, "erasure-heal-format") continue } // Count errNoHealRequired across all serverPools, // to return appropriate error to the caller if errors.Is(err, errNoHealRequired) { countNoHeal++ }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
istioctl/pkg/workload/workload.go
return err } serviceAccount := wg.Spec.Template.ServiceAccount tokenPath := filepath.Join(dir, "istio-token") token := &authenticationv1.TokenRequest{ // ObjectMeta isn't required in real k8s, but needed for tests ObjectMeta: metav1.ObjectMeta{ Name: serviceAccount, Namespace: wg.Namespace, }, Spec: authenticationv1.TokenRequestSpec{ Audiences: []string{"istio-ca"},
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Apr 17 20:06:41 GMT 2024 - 25.5K bytes - Viewed (0)