Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 107 for Walker (0.24 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 77.8K 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 76.3K bytes
    - Viewed (2)
  3. cmd/metacache-set_gen.go

    			}
    		case "FilterPrefix":
    			z.FilterPrefix, err = dc.ReadString()
    			if err != nil {
    				err = msgp.WrapError(err, "FilterPrefix")
    				return
    			}
    		case "Marker":
    			z.Marker, err = dc.ReadString()
    			if err != nil {
    				err = msgp.WrapError(err, "Marker")
    				return
    			}
    		case "Limit":
    			z.Limit, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "Limit")
    				return
    			}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Mar 19 20:23:12 GMT 2024
    - 13.8K bytes
    - Viewed (0)
  4. internal/s3select/message.go

    	//
    	// 1. If a writer.write() returns false, select loop below exits and
    	// closes `doneCh` to indicate to caller to also exit.
    	//
    	// 2. If caller (Evaluate()) has an error, it sends an error
    	// message and waits for this go-routine to quit in
    	// FinishWithError()
    	//
    	// 3. If caller is done, it waits for this go-routine to exit
    	// in Finish()
    
    	quitFlag := false
    	for !quitFlag {
    		select {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Aug 30 15:26:43 GMT 2022
    - 15.2K bytes
    - Viewed (0)
  5. 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 20.7K bytes
    - Viewed (0)
  6. cmd/storage-errors.go

    // errLessData - returned when less data available than what was requested.
    var errLessData = StorageErr("less data available than what was requested")
    
    // errMoreData = returned when more data was sent by the caller than what it was supposed to.
    var errMoreData = StorageErr("more data was sent than what was advertised")
    
    // indicates readDirFn to return without further applying the fn()
    var errDoneForNow = errors.New("done for now")
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6.4K bytes
    - Viewed (0)
  7. docs/debugging/s3-check-md5/main.go

    				continue
    			}
    			if !minModTime.IsZero() && object.LastModified.Before(minModTime) {
    				continue
    			}
    			if object.IsDeleteMarker {
    				log.Println("SKIPPED: DELETE marker object:", objFullPath(object))
    				continue
    			}
    			if _, ok := object.UserMetadata["X-Amz-Server-Side-Encryption-Customer-Algorithm"]; ok {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat Feb 17 01:15:57 GMT 2024
    - 6.3K bytes
    - Viewed (0)
  8. 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 18.7K bytes
    - Viewed (0)
  9. cmd/signature-v4-utils.go

    // client did not calculate sha256 of the payload and there is a trailer.
    const unsignedPayloadTrailer = "STREAMING-UNSIGNED-PAYLOAD-TRAILER"
    
    // skipContentSha256Cksum returns true if caller needs to skip
    // payload checksum, false if not.
    func skipContentSha256Cksum(r *http.Request) bool {
    	var (
    		v  []string
    		ok bool
    	)
    
    	if isRequestPresignedSignatureV4(r) {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed Jan 31 18:56:45 GMT 2024
    - 9K bytes
    - Viewed (0)
  10. 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 26.5K bytes
    - Viewed (0)
Back to top