Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for Walker (0.18 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 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 80.1K 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 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 76.9K bytes
    - Viewed (2)
  3. cmd/xl-storage-format-v2.go

    }
    
    // xlMetaV2DeleteMarker defines the data struct for the delete marker journal type
    type xlMetaV2DeleteMarker struct {
    	VersionID [16]byte          `json:"ID" msg:"ID"`                               // Version ID for delete marker
    	ModTime   int64             `json:"MTime" msg:"MTime"`                         // Object delete marker modified time
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 23 05:07:37 GMT 2024
    - 63.6K bytes
    - Viewed (1)
  4. analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/components/KtFirReferenceShortener.kt

                // The class with name `classId.shortClassName` happens to be the same class referenced by this qualified access.
                availableClassifier.symbol.classIdIfExists == qualifierClassId -> {
                    // Respect caller's request to use star import, if it's not already star-imported.
                    return when {
                        availableClassifier.importKind == ImportKind.EXPLICIT && importAllInParent -> {
    Plain Text
    - Registered: Fri Apr 26 08:18:10 GMT 2024
    - Last Modified: Thu Apr 25 18:51:33 GMT 2024
    - 69.5K bytes
    - Viewed (0)
  5. cmd/batch-handlers.go

    		ctx, cancel := context.WithCancel(ctx)
    		// one of source/target is s3, skip delete marker and all versions under the same object name.
    		s3Type := r.Target.Type == BatchJobReplicateResourceS3 || r.Source.Type == BatchJobReplicateResourceS3
    
    		if err := api.Walk(ctx, r.Source.Bucket, r.Source.Prefix, walkCh, WalkOptions{
    			Marker:   lastObject,
    			Filter:   selectObj,
    			AskDisks: walkQuorum,
    		}); err != nil {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 08 14:11:38 GMT 2024
    - 55.2K bytes
    - Viewed (0)
  6. cmd/xl-storage.go

    				sizeS.deleteMarkers++
    			}
    			if oi.VersionID != "" && sz == actualSz {
    				sizeS.versions++
    			}
    			sizeS.totalSize += sz
    
    			// Skip tier accounting if object version is a delete-marker or a free-version
    			// tracking deleted transitioned objects
    			switch {
    			case oi.DeleteMarker, oi.TransitionedObject.FreeVersion:
    				continue
    			}
    			tier := oi.StorageClass
    			if tier == "" {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  7. cmd/iam-store.go

    // Assumes that c.Lock is held by caller.
    func (c *iamCache) buildUserGroupMemberships() {
    	for group, gi := range c.iamGroupsMap {
    		c.updateGroupMembershipsMap(group, &gi)
    	}
    }
    
    // updateGroupMembershipsMap - updates the memberships map for a
    // group. IMPORTANT: Assumes c.Lock() is held by caller.
    func (c *iamCache) updateGroupMembershipsMap(group string, gi *GroupInfo) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Apr 27 10:04:10 GMT 2024
    - 75.2K bytes
    - Viewed (2)
  8. android/guava/src/com/google/common/base/Preconditions.java

     *
     * <p>If the precondition is not met, the {@code Preconditions} method throws an unchecked exception
     * of a specified type, which helps the method in which the exception was thrown communicate that
     * its caller has made a mistake. This allows constructs such as
     *
     * <pre>{@code
     * public static double sqrt(double value) {
     *   if (value < 0) {
     *     throw new IllegalArgumentException("input is negative: " + value);
     *   }
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Apr 11 11:52:14 GMT 2024
    - 52.9K bytes
    - Viewed (0)
  9. cmd/bucket-handlers.go

    		return
    	}
    
    	if maxUploads < 0 {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrInvalidMaxUploads), r.URL)
    		return
    	}
    
    	if keyMarker != "" {
    		// Marker not common with prefix is not implemented.
    		if !HasPrefix(keyMarker, prefix) {
    			writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrNotImplemented), r.URL)
    			return
    		}
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 16:27:27 GMT 2024
    - 61.6K bytes
    - Viewed (0)
  10. istioctl/pkg/describe/describe.go

    // When the config has no selector labels, this method will treat it as qualified namespace level
    // config. So configs passed into this method should only contains workload's namespaces configs
    // and rootNamespaces configs, caller should be responsible for controlling configs passed
    // in.
    func findMatchedConfigs(podsLabels klabels.Set, configs []*config.Config) []*config.Config {
    	var cfgs []*config.Config
    
    	for _, cfg := range configs {
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Sat Apr 13 05:23:38 GMT 2024
    - 50.4K bytes
    - Viewed (0)
Back to top