- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 198 for datadir (0.26 sec)
-
cmd/erasure-healing-common_test.go
} } partsMetadata[0] = partsMetadataBackup // Revert before going to the next test // Test 3: Not synchronized DataDir partsMetadataBackup = partsMetadata[1] partsMetadata[1].DataDir = "foo-random" errs = make([]error, len(erasureDisks)) filteredDisks, _, _ = disksWithAllParts(ctx, erasureDisks, partsMetadata, errs, fi, bucket, object, madmin.HealDeepScan)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 23K bytes - Viewed (0) -
pkg/volume/csi/csi_attacher.go
// Setup var driverName, volID string dataDir := filepath.Dir(deviceMountPath) data, err := loadVolumeData(dataDir, volDataFileName) if err == nil { driverName = data[volDataKey.driverName] volID = data[volDataKey.volHandle] } else { if errors.Is(err, os.ErrNotExist) { klog.V(4).Info(log("attacher.UnmountDevice skipped because volume data file [%s] does not exist", dataDir)) return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 03 07:38:14 UTC 2023 - 25.9K bytes - Viewed (0) -
cmd/xl-storage-format-v2_gen.go
err = msgp.WrapError(err, "ObjectV2") return } switch msgp.UnsafeString(field) { case "DDir": err = dc.ReadExactBytes((z.ObjectV2.DataDir)[:]) if err != nil { err = msgp.WrapError(err, "ObjectV2", "DataDir") return } default: err = dc.Skip() if err != nil { err = msgp.WrapError(err, "ObjectV2") return }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 29 19:14:09 UTC 2024 - 53.8K bytes - Viewed (0) -
cmd/erasure-multipart.go
// Removes part.meta given by partName belonging to a multipart upload from minioMetaBucket func (er erasureObjects) removePartMeta(bucket, object, uploadID, dataDir string, partNumber int) { uploadIDPath := er.getUploadIDDir(bucket, object, uploadID) curpartPath := pathJoin(uploadIDPath, dataDir, fmt.Sprintf("part.%d", partNumber)) storageDisks := er.getDisks() g := errgroup.WithNErrs(len(storageDisks)) for index, disk := range storageDisks {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 44.8K bytes - Viewed (0) -
cmd/xl-storage-format-utils.go
versionID = fi.VersionID if versionID == "" { versionID = nullVersionID } fi.Data = inData.find(versionID) if len(fi.Data) == 0 { // PR #11758 used DataDir, preserve it // for users who might have used master // branch fi.Data = inData.find(fi.DataDir) } return fi, nil } // hashDeterministicString will return a deterministic hash for the map values.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 22:18:44 UTC 2024 - 5.5K bytes - Viewed (0) -
pkg/volume/csi/csi_block_test.go
} // Check that all directories have been cleaned // Check that all metadata / staging / publish directories were deleted dataDir := getVolumeDeviceDataDir(pv.ObjectMeta.Name, plug.host) if _, err := os.Stat(dataDir); err == nil { t.Errorf("volume publish data directory %s was not deleted", dataDir) } devDir := getVolumeDeviceDataDir(pv.ObjectMeta.Name, plug.host) if _, err := os.Stat(devDir); err == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 11 06:07:40 UTC 2023 - 26.5K bytes - Viewed (0) -
cmd/kubeadm/app/apis/kubeadm/v1beta4/defaults.go
func SetDefaults_Etcd(obj *ClusterConfiguration) { if obj.Etcd.External == nil && obj.Etcd.Local == nil { obj.Etcd.Local = &LocalEtcd{} } if obj.Etcd.Local != nil { if obj.Etcd.Local.DataDir == "" { obj.Etcd.Local.DataDir = DefaultEtcdDataDir } } } // SetDefaults_JoinConfiguration assigns default values to a regular node func SetDefaults_JoinConfiguration(obj *JoinConfiguration) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 16 08:34:39 UTC 2024 - 9.3K bytes - Viewed (0) -
cmd/kubeadm/app/util/staticpod/utils_linux_test.go
} verifyFilePermissions(t, updatedFiles, wantUpdateFiles) } func TestRunEtcdAsNonRoot(t *testing.T) { cfg := &kubeadm.ClusterConfiguration{ Etcd: kubeadm.Etcd{ Local: &kubeadm.LocalEtcd{ DataDir: "/var/lib/etcd/data", }, }, } pod := ComponentPod(v1.Container{Name: "etcd"}, nil, nil) var runAsUser, runAsGroup int64 = 1000, 1001 updatedFiles := map[string]ownerAndPermissions{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 11 14:41:12 UTC 2023 - 7.4K bytes - Viewed (0) -
pkg/kubelet/certificate/kubelet_test.go
cert, key, err := cert.GenerateSelfSignedCertKey("k8s.io", nil, nil) if err != nil { return "", "", nil } var certKeyPathFn = func(dataDir string) (string, string, string) { outputDir := filepath.Join(certDir, dataDir) return outputDir, filepath.Join(outputDir, "kubelet.cert"), filepath.Join(outputDir, "kubelet.key") } writeDir, writeCertPath, writeKeyPath := certKeyPathFn("identity.tmp")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 03:07:40 UTC 2024 - 7.4K bytes - Viewed (0) -
cmd/xl-storage-free-version_test.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Mar 02 05:11:03 UTC 2024 - 7.8K bytes - Viewed (0)