Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 106 for Walker (0.18 sec)

  1. cmd/metacache-entries.go

    		// If separator is not found or is last entry, ok.
    		return idx == -1 || idx == len(ext)-len(separator)
    	}
    	return false
    }
    
    // isLatestDeletemarker returns whether the latest version is a delete marker.
    // If metadata is NOT versioned false will always be returned.
    // If v2 and UNABLE to load metadata true will be returned.
    func (e *metaCacheEntry) isLatestDeletemarker() bool {
    	if e.cached != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:43:43 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  2. cmd/metacache-marker.go

    import (
    	"context"
    	"fmt"
    	"strconv"
    	"strings"
    )
    
    // markerTagVersion is the marker version.
    // Should not need to be updated unless a fundamental change is made to the marker format.
    const markerTagVersion = "v2"
    
    // parseMarker will parse a marker possibly encoded with encodeMarker
    func (o *listPathOptions) parseMarker() {
    	s := o.Marker
    	if !strings.Contains(s, "[minio_cache:"+markerTagVersion) {
    		return
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 2.5K bytes
    - Viewed (0)
  3. cmd/object-api-interface.go

    	Expires              time.Time // Is only used in POST/PUT operations
    
    	DeleteMarker            bool // Is only set in DELETE operations for delete marker replication
    	CheckDMReplicationReady bool // Is delete marker ready to be replicated - set only during HEAD
    	Tagging                 bool // Is only in GET/HEAD operations to return tagging metadata along with regular metadata and body.
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 17K bytes
    - Viewed (0)
  4. cmd/metacache-set.go

    }
    
    // findFirstPart will find the part with 0 being the first that corresponds to the marker in the options.
    // io.ErrUnexpectedEOF is returned if the place containing the marker hasn't been scanned yet.
    // io.EOF indicates the marker is beyond the end of the stream and does not exist.
    func (o *listPathOptions) findFirstPart(fi FileInfo) (int, error) {
    	search := o.Marker
    	if search == "" {
    		search = o.Prefix
    	}
    	if search == "" {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:59:08 GMT 2024
    - 30.4K bytes
    - Viewed (0)
  5. cmd/api-resources.go

    			return
    		}
    	} else {
    		maxkeys = maxObjectList
    	}
    
    	prefix = values.Get("prefix")
    	marker = values.Get("marker")
    	delimiter = values.Get("delimiter")
    	encodingType = values.Get("encoding-type")
    	return
    }
    
    func getListBucketObjectVersionsArgs(values url.Values) (prefix, marker, delimiter string, maxkeys int, encodingType, versionIDMarker string, errCode APIErrorCode) {
    	errCode = ErrNone
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Jun 07 18:25:26 GMT 2023
    - 4.3K bytes
    - Viewed (0)
  6. internal/bucket/lifecycle/lifecycle.go

    	for _, rule := range lc.FilterRules(obj) {
    		if obj.ExpiredObjectDeleteMarker() {
    			if rule.Expiration.DeleteMarker.val {
    				// Indicates whether MinIO will remove a delete marker with no noncurrent versions.
    				// Only latest marker is removed. If set to true, the delete marker will be expired;
    				// if set to false the policy takes no action. This cannot be specified with Days or
    				// Date in a Lifecycle Expiration Policy.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:11:10 GMT 2024
    - 17.5K bytes
    - Viewed (0)
  7. internal/dsync/drwmutex.go

    				noQuorum, err := refreshLock(ctx, dm.clnt, id, source, quorum)
    				if err == nil && noQuorum {
    					// Clean the lock locally and in remote nodes
    					forceUnlock(ctx, dm.clnt, id)
    					// Execute the caller lock loss callback
    					if lockLossCallback != nil {
    						lockLossCallback()
    					}
    					return
    				}
    
    				refreshTimer.Reset(dm.refreshInterval)
    			}
    		}
    	}()
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 19.7K bytes
    - Viewed (0)
  8. cmd/os_other.go

    					return err
    				}
    
    				// Ignore symlinked directories.
    				if fi.IsDir() {
    					continue
    				}
    			}
    			if err = filter(fi.Name(), fi.Mode()); err == errDoneForNow {
    				// filtering requested to return by caller.
    				return nil
    			}
    		}
    	}
    	return nil
    }
    
    // Return entries at the directory dirPath.
    func readDirWithOpts(dirPath string, opts readDirOpts) (entries []string, err error) {
    	d, err := Open(dirPath)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Sep 13 15:14:36 GMT 2023
    - 4K bytes
    - Viewed (0)
  9. cmd/xl-storage-format-utils.go

    	fivs, err := getAllFileInfoVersions(xlMetaBuf, volume, path, allParts)
    	if err != nil {
    		return fivs, err
    	}
    	n := 0
    	for _, fi := range fivs.Versions {
    		// Filter our tier object delete marker
    		if !fi.TierFreeVersion() {
    			fivs.Versions[n] = fi
    			n++
    		} else {
    			fivs.FreeVersions = append(fivs.FreeVersions, fi)
    		}
    	}
    	fivs.Versions = fivs.Versions[:n]
    	// Update numversions
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 11 17:45:28 GMT 2024
    - 4.7K bytes
    - Viewed (0)
  10. cmd/bucket-listobjects-handlers.go

    // Special conditions required by MinIO server are as below
    //   - delimiter if set should be equal to '/', otherwise the request is rejected.
    //   - marker if set should have a common prefix with 'prefix' param, otherwise
    //     the request is rejected.
    func validateListObjectsArgs(prefix, marker, delimiter, encodingType string, maxKeys int) APIErrorCode {
    	// Max keys cannot be negative.
    	if maxKeys < 0 {
    		return ErrInvalidMaxKeys
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 11.4K bytes
    - Viewed (0)
Back to top