Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 58 for PathJoin (0.15 sec)

  1. cmd/erasure-object_test.go

    		})
    		switch statErr.(type) {
    		case VersionNotFound:
    		default:
    			t.Fatalf("Object %s is not removed", test.bucket+SlashSeparator+test.object)
    		}
    	}
    
    	if _, err = os.ReadFile(pathJoin(fsDirs[0], bucketName, "dir/obj1", "xl.meta")); err == nil {
    		t.Fatalf("xl.meta still present after removal")
    	}
    }
    
    func TestErasureDeleteObjectsErasureSet(t *testing.T) {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 38.3K bytes
    - Viewed (0)
  2. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 42.2K bytes
    - Viewed (1)
  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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37K bytes
    - Viewed (1)
  4. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 16.4K bytes
    - Viewed (1)
  5. cmd/bucket-lifecycle.go

    	}
    	metadata["version-id"] = oi.VersionID
    	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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 33.7K 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 34.7K bytes
    - Viewed (0)
  7. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 21.3K bytes
    - Viewed (0)
  8. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 17.4K bytes
    - Viewed (0)
  9. cmd/bucket-handlers.go

    				// Load updated bucket metadata into memory.
    				globalNotificationSys.LoadBucketMetadata(GlobalContext, bucket)
    
    				// Make sure to add Location information here only for bucket
    				w.Header().Set(xhttp.Location, pathJoin(SlashSeparator, bucket))
    
    				writeSuccessResponseHeadersOnly(w)
    
    				sendEvent(eventArgs{
    					EventName:    event.BucketCreated,
    					BucketName:   bucket,
    					ReqParams:    extractReqParams(r),
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 63.9K bytes
    - Viewed (0)
  10. cmd/admin-bucket-handlers.go

    		bucketQuotaConfigFile,
    		objectLockConfig,
    		bucketVersioningConfig,
    		bucketReplicationConfig,
    		bucketTargetsFile,
    	}
    	for _, bi := range buckets {
    		for _, cfgFile := range cfgFiles {
    			cfgPath := pathJoin(bi.Name, cfgFile)
    			bucket := bi.Name
    			switch cfgFile {
    			case bucketPolicyConfig:
    				config, _, err := globalBucketMetadataSys.GetBucketPolicy(bucket)
    				if err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 33.3K bytes
    - Viewed (0)
Back to top