Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 58 for pathJoin (0.08 sec)

  1. cmd/erasure-server-pool-decom.go

    	// Create .minio.sys/config, .minio.sys/buckets paths if missing,
    	// this code is present to avoid any missing meta buckets on other
    	// pools.
    	for _, metaBucket := range []string{
    		pathJoin(minioMetaBucket, minioConfigPrefix),
    		pathJoin(minioMetaBucket, bucketMetaPrefix),
    	} {
    		var bucketExists BucketExists
    		if err = z.MakeBucket(ctx, metaBucket, MakeBucketOptions{}); err != nil {
    			if !errors.As(err, &bucketExists) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  2. cmd/storage-rest_test.go

    			t.Fatalf("case %v: error: expected: %v, got: %v", i+1, errUnformattedDisk, err)
    		}
    	}
    }
    
    func testStorageAPIStatInfoFile(t *testing.T, storage StorageAPI) {
    	err := storage.AppendFile(context.Background(), "foo", pathJoin("myobject", xlStorageFormatFile), []byte("foo"))
    	if err != nil {
    		t.Fatalf("unexpected error %v", err)
    	}
    
    	testCases := []struct {
    		volumeName string
    		objectName string
    		expectErr  bool
    	}{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 22 07:04:48 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  3. cmd/erasure-sets.go

    				return nil
    			}
    			volsInfo, err := storageDisks[index].ListDir(ctx, "", minioMetaBucket, pathJoin(bucketMetaPrefix, deletedBucketsPrefix), -1)
    			if err != nil {
    				if errors.Is(err, errFileNotFound) {
    					return nil
    				}
    				return err
    			}
    			for _, volName := range volsInfo {
    				vi, err := storageDisks[index].StatVol(ctx, pathJoin(minioMetaBucket, bucketMetaPrefix, deletedBucketsPrefix, volName))
    				if err == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
  4. cmd/bucket-lifecycle.go

    	sz, _ := oi.GetActualSize()
    	return madmin.TraceInfo{
    		TraceType: madmin.TraceILM,
    		Time:      startTime,
    		NodeName:  globalLocalNodeName,
    		FuncName:  event,
    		Duration:  duration,
    		Path:      pathJoin(oi.Bucket, oi.Name),
    		Bytes:     sz,
    		Error:     err,
    		Message:   getSource(4),
    		Custom:    metadata,
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  5. cmd/handler-utils.go

    			continue
    		}
    		if !strings.HasSuffix(xhost.Name, "."+domain) {
    			continue
    		}
    		bucket := strings.TrimSuffix(xhost.Name, "."+domain)
    		return SlashSeparator + pathJoin(bucket, path), nil
    	}
    	return path, nil
    }
    
    var regexVersion = regexp.MustCompile(`^/minio.*/(v\d+)/.*`)
    
    func extractAPIVersion(r *http.Request) string {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  6. cmd/data-usage-cache.go

    		// drive timeout by default is 2 minutes, we do not need to wait longer.
    		ctx, cancel := context.WithTimeout(ctx, timeout)
    		defer cancel()
    
    		r, err := store.GetObjectNInfo(ctx, minioMetaBucket, pathJoin(bucketMetaPrefix, name), nil, http.Header{}, ObjectOptions{NoLock: true})
    		if err != nil {
    			switch err.(type) {
    			case ObjectNotFound, BucketNotFound:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  7. cmd/storage-datatypes.go

    //     hang-around in-case we need some form of recovery.
    type RenameDataResp struct {
    	Sign       []byte `msg:"s"`
    	OldDataDir string `msg:"od"` // contains '<uuid>', it is designed to be passed as value to Delete(bucket, pathJoin(object, dataDir))
    }
    
    const (
    	checkPartUnknown int = iota
    
    	// Changing the order can cause a data loss
    	// when running two nodes with incompatible versions
    	checkPartSuccess
    	checkPartDiskNotFound
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  8. cmd/erasure-metadata.go

    			if mErrs[index] != nil {
    				continue
    			}
    			index := index
    			ng.Go(func() error {
    				if disks[index] == nil {
    					return errDiskNotFound
    				}
    				return disks[index].Delete(ctx, bucket, pathJoin(prefix, xlStorageFormatFile), DeleteOptions{
    					Recursive: true,
    				})
    			}, index)
    		}
    		ng.Wait()
    	}
    
    	return evalDisks(disks, mErrs), err
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 21.3K bytes
    - Viewed (0)
  9. cmd/bucket-replication.go

    		rc, err := localDrive.ReadFileStream(p.ctx, minioMetaBucket, pathJoin(replicationMRFDir, globalLocalNodeNameHex+".bin"), 0, -1)
    		if err != nil {
    			continue
    		}
    
    		mrfRec, err = loadMRF(rc)
    		if err != nil {
    			continue
    		}
    
    		// finally delete the file after processing mrf entries
    		localDrive.Delete(p.ctx, minioMetaBucket, pathJoin(replicationMRFDir, globalLocalNodeNameHex+".bin"), DeleteOptions{})
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  10. cmd/object-handlers.go

    	}
    
    	dstOpts, err = copyDstOpts(ctx, r, dstBucket, dstObject, nil)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    	cpSrcDstSame := isStringEqual(pathJoin(srcBucket, srcObject), pathJoin(dstBucket, dstObject))
    
    	getObjectNInfo := objectAPI.GetObjectNInfo
    
    	checkCopyPrecondFn := func(o ObjectInfo) bool {
    		if _, err := DecryptObjectInfo(&o, r); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 05 05:16:15 UTC 2024
    - 117.4K bytes
    - Viewed (0)
Back to top