Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 23 for MkdirAll (0.08 sec)

  1. internal/store/queuestore.go

    		entries:    make(map[string]int64, limit),
    	}
    }
    
    // Open - Creates the directory if not present.
    func (store *QueueStore[_]) Open() error {
    	store.Lock()
    	defer store.Unlock()
    
    	if err := os.MkdirAll(store.directory, os.FileMode(0o770)); err != nil {
    		return err
    	}
    
    	files, err := store.list()
    	if err != nil {
    		return err
    	}
    
    	for _, file := range files {
    		if file.IsDir() {
    			continue
    		}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  2. cmd/os_windows.go

    )
    
    func access(name string) error {
    	_, err := os.Lstat(name)
    	return err
    }
    
    func osMkdirAll(dirPath string, perm os.FileMode, _ string) error {
    	// baseDir is not honored in windows platform
    	return os.MkdirAll(dirPath, perm)
    }
    
    // readDirFn applies the fn() function on each entries at dirPath, doesn't recurse into
    // the directory itself, if the dirPath doesn't exist this function doesn't return
    // an error.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Oct 18 18:08:15 UTC 2023
    - 5.1K bytes
    - Viewed (0)
  3. cmd/prepare-storage.go

    		storageLogIf(GlobalContext, fmt.Errorf("unable to rename (%s -> %s) %w, drive may be faulty, please investigate",
    			pathJoin(diskPath, minioMetaTmpBucket),
    			tmpOld,
    			osErrToFileErr(err)))
    	}
    
    	if err := mkdirAll(pathJoin(diskPath, minioMetaTmpDeletedBucket), 0o777, diskPath); err != nil {
    		storageLogIf(GlobalContext, fmt.Errorf("unable to create (%s) %w, drive may be faulty, please investigate",
    			pathJoin(diskPath, minioMetaTmpBucket),
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  4. cmd/data-usage_test.go

    				t.Error("got histogram", e.ObjSizes, "want", w.oSizes)
    			}
    		})
    	}
    }
    
    func createUsageTestFiles(t *testing.T, base, bucket string, files []usageTestFile) {
    	for _, f := range files {
    		err := os.MkdirAll(filepath.Dir(filepath.Join(base, bucket, f.name)), os.ModePerm)
    		if err != nil {
    			t.Fatal(err)
    		}
    		err = os.WriteFile(filepath.Join(base, bucket, f.name), make([]byte, f.size), os.ModePerm)
    		if err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  5. internal/logger/logrotate.go

    	}
    
    	w.f = f
    
    	return nil
    }
    
    // NewDir creates a new concurrency safe Writer which performs log rotation.
    func NewDir(opts Options) (io.WriteCloser, error) {
    	if err := os.MkdirAll(opts.Directory, os.ModePerm); err != nil {
    		return nil, fmt.Errorf("directory %v does not exist and could not be created: %w", opts.Directory, err)
    	}
    
    	if opts.FileNameFunc == nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  6. cmd/format-erasure_test.go

    	m.Erasure.Disk = mustGetUUID()
    	m.Erasure.JBOD = []string{m.Erasure.Disk, mustGetUUID(), mustGetUUID(), mustGetUUID()}
    
    	b, err := json.Marshal(m)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	if err = os.MkdirAll(pathJoin(rootPath, minioMetaBucket), os.FileMode(0o755)); err != nil {
    		t.Fatal(err)
    	}
    
    	if err = os.WriteFile(pathJoin(rootPath, minioMetaBucket, formatConfigFile), b, os.FileMode(0o644)); err != nil {
    		t.Fatal(err)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Apr 15 08:25:46 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  7. cmd/xl-storage.go

    	if err != nil {
    		return path, err
    	}
    
    	fi, err := Lstat(path)
    	if err != nil && !osIsNotExist(err) {
    		return path, err
    	}
    	if osIsNotExist(err) {
    		// Disk not found create it.
    		if err = mkdirAll(path, 0o777, ""); err != nil {
    			return path, err
    		}
    	}
    	if fi != nil && !fi.IsDir() {
    		return path, errDiskNotDir
    	}
    
    	return path, nil
    }
    
    // Make Erasure backend meta volumes.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (2)
  8. cmd/erasure-healing_test.go

    		t.Fatal("HealObject failed")
    	}
    
    	uuid, _ := uuid2.NewRandom()
    	for _, drive := range fsDirs {
    		dir := path.Join(drive, bucket, object, uuid.String())
    		err = os.MkdirAll(dir, os.ModePerm)
    		if err != nil {
    			t.Fatal(err)
    		}
    		err = os.WriteFile(pathJoin(dir, "part.1"), []byte("some data"), os.ModePerm)
    		if err != nil {
    			t.Fatal(err)
    		}
    	}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  9. istioctl/pkg/workload/workload.go

    func createConfig(kubeClient kube.CLIClient, wg *clientnetworking.WorkloadGroup, istioNamespace, clusterID, ingressIP, internalIP,
    	externalIP string, outputDir string, out io.Writer,
    ) error {
    	if err := os.MkdirAll(outputDir, filePerms); err != nil {
    		return err
    	}
    	var (
    		err         error
    		proxyConfig *meshconfig.ProxyConfig
    	)
    	revision := kubeClient.Revision()
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Thu Aug 15 16:31:46 UTC 2024
    - 25.3K bytes
    - Viewed (0)
  10. api/except.txt

    pkg os, const ModeType = 2399666176
    pkg os, const ModeType FileMode
    pkg os, func Chmod(string, FileMode) error
    pkg os, func Lstat(string) (FileInfo, error)
    pkg os, func Mkdir(string, FileMode) error
    pkg os, func MkdirAll(string, FileMode) error
    pkg os, func OpenFile(string, int, FileMode) (*File, error)
    pkg os, func SameFile(FileInfo, FileInfo) bool
    pkg os, func Stat(string) (FileInfo, error)
    pkg os, method (*File) Chmod(FileMode) error
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Sun Jun 16 23:08:08 UTC 2024
    - 34.8K bytes
    - Viewed (0)
Back to top