Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 35 for iter (0.16 sec)

  1. cmd/data-scanner_test.go

    		VersioningConfigUpdatedAt: now,
    		LifecycleConfigUpdatedAt:  now,
    		lifecycleConfig:           &lc,
    		versioningConfig:          &vcfg,
    	}
    	globalBucketMetadataSys.Set(bucket, meta)
    	item := scannerItem{
    		Path:       obj,
    		bucket:     bucket,
    		prefix:     "",
    		objectName: obj,
    		lifeCycle:  &lc,
    	}
    
    	modTime := time.Now()
    	uuids := make([]uuid.UUID, 5)
    	for i := range uuids {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 11:18:58 GMT 2024
    - 6.9K bytes
    - Viewed (0)
  2. cmd/metrics-v2.go

    		Help:      "Total bytes transitioned to a tier",
    		Type:      gaugeMetric,
    	}
    }
    
    func getClusterTransitionedObjectsMD() MetricDescription {
    	return MetricDescription{
    		Namespace: clusterMetricNamespace,
    		Subsystem: ilmSubsystem,
    		Name:      transitionedObjects,
    		Help:      "Total number of objects transitioned to a tier",
    		Type:      gaugeMetric,
    	}
    }
    
    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)
  3. cmd/erasure-object.go

    	}
    
    	return tags.ParseObjectTags(oi.UserTags)
    }
    
    // TransitionObject - transition object content to target tier.
    func (er erasureObjects) TransitionObject(ctx context.Context, bucket, object string, opts ObjectOptions) error {
    	tgtClient, err := globalTierConfigMgr.getDriver(ctx, opts.Transition.Tier)
    	if err != nil {
    		return err
    	}
    
    	// Acquire write lock before starting to transition the object.
    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)
  4. cmd/object-api-errors.go

    func (e BucketReplicationSourceNotVersioned) Error() string {
    	return "Replication source does not have versioning enabled: " + e.Bucket
    }
    
    // TransitionStorageClassNotFound remote tier not configured.
    type TransitionStorageClassNotFound GenericError
    
    func (e TransitionStorageClassNotFound) Error() string {
    	return "Transition storage class not 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)
  5. cmd/iam.go

    		iamFilesListing := iamOS.cachedIAMListing.Load().(map[string][]string)
    		listKey := policyDBSTSUsersListKey
    		if isGroup {
    			listKey = policyDBGroupsListKey
    		}
    		for _, item := range iamFilesListing[listKey] {
    			stsUserName := strings.TrimSuffix(item, ".json")
    			entityKeysInStorage.Add(stsUserName)
    		}
    	} else {
    		// For non-iam object store, we copy the mapping keys from the cache.
    		cache := sys.store.rlock()
    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)
  6. cmd/api-errors.go

    		HTTPStatusCode: http.StatusServiceUnavailable,
    	},
    	ErrSiteReplicationIAMError: {
    		Code:           "XMinioSiteReplicationIAMError",
    		Description:    "Error while replicating an IAM item",
    		HTTPStatusCode: http.StatusServiceUnavailable,
    	},
    	ErrSiteReplicationConfigMissing: {
    		Code:           "XMinioSiteReplicationConfigMissingError",
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 91.4K bytes
    - Viewed (7)
  7. cmd/erasure-server-pool.go

    	if err != nil {
    		return nil, err
    	}
    
    	return tags.ParseObjectTags(oi.UserTags)
    }
    
    // TransitionObject - transition object content to target tier.
    func (z *erasureServerPools) TransitionObject(ctx context.Context, bucket, object string, opts ObjectOptions) error {
    	object = encodeDirObject(object)
    	if z.SinglePool() {
    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)
  8. cmd/object-handlers.go

    	// Make a copy of the supplied metadata to avoid
    	// to change the original one.
    	defaultMeta := make(map[string]string, len(userMeta))
    	for k, v := range userMeta {
    		// skip tier metadata when copying metadata from source object
    		switch k {
    		case metaTierName, metaTierStatus, metaTierObjName, metaTierVersionID:
    			continue
    		}
    		defaultMeta[k] = v
    	}
    
    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)
  9. cmd/xl-storage.go

    				tier = oi.TransitionedObject.Tier
    			}
    			if sizeS.tiers != nil {
    				if st, ok := sizeS.tiers[tier]; ok {
    					sizeS.tiers[tier] = st.add(oi.tierStats())
    				}
    			}
    		}
    
    		// apply tier sweep action on free versions
    		for _, freeVersion := range fivs.FreeVersions {
    			oi := freeVersion.ToObjectInfo(item.bucket, item.objectPath(), versioned)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  10. cmd/warm-backend.go

    	case madmin.Azure:
    		d, err = newWarmBackendAzure(*tier.Azure, tier.Name)
    	case madmin.GCS:
    		d, err = newWarmBackendGCS(*tier.GCS, tier.Name)
    	case madmin.MinIO:
    		d, err = newWarmBackendMinIO(*tier.MinIO, tier.Name)
    	default:
    		return nil, errTierTypeUnsupported
    	}
    	if err != nil {
    		return nil, errTierTypeUnsupported
    	}
    
    	if probe {
    		if err = checkWarmBackend(ctx, d); err != nil {
    			return nil, err
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 3.9K bytes
    - Viewed (0)
Back to top