Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 47 for Walker (0.16 sec)

  1. cmd/erasure-server-pool.go

    	var loi ListObjectsInfo
    	opts := listPathOptions{
    		V1:          v1,
    		Bucket:      bucket,
    		Prefix:      prefix,
    		Separator:   delimiter,
    		Limit:       maxKeysPlusOne(maxKeys, marker != ""),
    		Marker:      marker,
    		InclDeleted: false,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  2. cmd/erasure-object.go

    				// Bucket is versioned and no version was explicitly
    				// mentioned for deletes, create a delete marker instead.
    				vr.ModTime = UTCNow()
    				vr.Deleted = true
    				// Versioning suspended means that we add a `null` version
    				// delete marker, if not add a new version for this delete
    				// marker.
    				if versioned {
    					vr.VersionID = mustGetUUID()
    				}
    			}
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  3. cmd/object-api-errors.go

    	return "Bucket exists: " + e.Bucket
    }
    
    // InvalidUploadIDKeyCombination - invalid upload id and key marker combination.
    type InvalidUploadIDKeyCombination struct {
    	UploadIDMarker, KeyMarker string
    }
    
    func (e InvalidUploadIDKeyCombination) Error() string {
    	return fmt.Sprintf("Invalid combination of uploadID marker '%s' and marker '%s'", e.UploadIDMarker, e.KeyMarker)
    }
    
    // BucketPolicyNotFound - no bucket policy found.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 21.3K bytes
    - Viewed (0)
  4. cmd/update.go

    		// CRI-O, Containerd etc..
    		// Fallback to our container specific ENVs if they are set.
    		return env.IsSet("MINIO_ACCESS_KEY_FILE")
    	}
    
    	// Log error, as we will not propagate it to caller
    	internalLogIf(GlobalContext, err)
    
    	return err == nil
    }
    
    // IsDCOS returns true if minio is running in DCOS.
    func IsDCOS() bool {
    	// http://mesos.apache.org/documentation/latest/docker-containerizer/
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 18.7K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool-rebalance.go

    				}
    
    				// Apply lifecycle rules on the objects that are expired.
    				if filterLifecycle(bucket, version.Name, version) {
    					expired++
    					continue
    				}
    
    				// any object with only single DEL marker we don't need
    				// to rebalance, just skip it, this also includes
    				// any other versions that have already expired.
    				remainingVersions := len(fivs.Versions) - expired
    				if version.Deleted && remainingVersions == 1 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
  6. cmd/object-handlers.go

    	gopts.NoLock = true // We already have a lock, we can live with it.
    	objInfo, err := getObjectInfo(ctx, bucket, object, gopts)
    	if err != nil {
    		// Versioning enabled quite possibly object is deleted might be delete-marker
    		// if present set the headers, no idea why AWS S3 sets these headers.
    		if objInfo.VersionID != "" && objInfo.DeleteMarker {
    			w.Header()[xhttp.AmzVersionID] = []string{objInfo.VersionID}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 20:15:54 GMT 2024
    - 125.2K bytes
    - Viewed (0)
  7. cmd/metrics-v2.go

    	return MetricDescription{
    		Namespace: clusterMetricNamespace,
    		Subsystem: usageSubsystem,
    		Name:      versionTotal,
    		Help:      "Total number of versions (includes delete marker) in a cluster",
    		Type:      gaugeMetric,
    	}
    }
    
    func getClusterUsageDeleteMarkersTotalMD() MetricDescription {
    	return MetricDescription{
    		Namespace: clusterMetricNamespace,
    		Subsystem: usageSubsystem,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 132.6K bytes
    - Viewed (0)
  8. cmd/api-errors.go

    		HTTPStatusCode: http.StatusBadRequest,
    	},
    	ErrInvalidPrefixMarker: {
    		Code:           "InvalidPrefixMarker",
    		Description:    "Invalid marker prefix combination",
    		HTTPStatusCode: http.StatusBadRequest,
    	},
    	ErrBadRequest: {
    		Code:           "BadRequest",
    		Description:    "400 BadRequest",
    		HTTPStatusCode: http.StatusBadRequest,
    	},
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 91.4K bytes
    - Viewed (6)
  9. cmd/iam.go

    		return nil, ctx.Err()
    	}
    }
    
    // PolicyDBSet - sets a policy for a user or group in the PolicyDB. This does
    // not validate if the user/group exists - that is the responsibility of the
    // caller.
    func (sys *IAMSys) PolicyDBSet(ctx context.Context, name, policy string, userType IAMUserType, isGroup bool) (updatedAt time.Time, err error) {
    	if !sys.Initialized() {
    		return updatedAt, errServerNotInitialized
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 71.1K bytes
    - Viewed (1)
  10. cmd/storage-datatypes.go

    }
    
    // GetDataDir returns an expected dataDir given FileInfo
    //   - deleteMarker returns "delete-marker"
    //   - returns "legacy" if FileInfo is XLV1 and DataDir is
    //     empty, returns DataDir otherwise
    //   - returns "dataDir"
    func (fi FileInfo) GetDataDir() string {
    	if fi.Deleted {
    		return "delete-marker"
    	}
    	if fi.XLV1 && fi.DataDir == "" {
    		return "legacy"
    	}
    	return fi.DataDir
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 15.3K bytes
    - Viewed (0)
Back to top