Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. 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(t.Context(), "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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  2. cmd/metacache-set.go

    }
    
    const metacachePrefix = ".metacache"
    
    func metacachePrefixForID(bucket, id string) string {
    	return pathJoin(bucketMetaPrefix, bucket, metacachePrefix, id)
    }
    
    // objectPath returns the object path of the cache.
    func (o *listPathOptions) objectPath(block int) string {
    	return pathJoin(metacachePrefixForID(o.Bucket, o.ID), "block-"+strconv.Itoa(block)+".s2")
    }
    
    func (o *listPathOptions) SetFilter() {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 30.7K 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 Sep 07 19:28:11 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.3K 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 33.7K bytes
    - Viewed (0)
  6. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 21.3K bytes
    - Viewed (0)
  7. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.7K 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 33.3K bytes
    - Viewed (0)
Back to top