Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 78 for Ongoing (0.05 sec)

  1. cmd/bucket-lifecycle.go

    // Otherwise returns zero value of time.Time and false.
    func (r restoreObjStatus) Expiry() (time.Time, bool) {
    	if r.Ongoing() {
    		return time.Time{}, false
    	}
    	return r.expiry, true
    }
    
    // Ongoing returns true if restore-object is ongoing.
    func (r restoreObjStatus) Ongoing() bool {
    	return r.ongoing
    }
    
    // OnDisk returns true if restored object contents exist in MinIO. Otherwise returns false.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 33.7K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool-rebalance.go

    // rebalanceMeta contains information pertaining to an ongoing rebalance operation.
    type rebalanceMeta struct {
    	cancel          context.CancelFunc `msg:"-"` // to be invoked on rebalance-stop
    	lastRefreshedAt time.Time          `msg:"-"`
    	StoppedAt       time.Time          `msg:"stopTs"` // Time when rebalance-stop was issued.
    	ID              string             `msg:"id"`     // ID of the ongoing rebalance operation
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Sep 04 20:47:24 UTC 2025
    - 28.9K bytes
    - Viewed (0)
  3. docs/bucket/lifecycle/DESIGN.md

    ```
    ...
            "MetaUsr": {
             "X-Amz-Restore-Expiry-Days": "4",
              "X-Amz-Restore-Request-Date": "Mon, 22 Feb 2021 21:10:09 GMT",
              "x-amz-restore": "ongoing-request=false, expiry-date=Sat, 27 Feb 2021 00:00:00 GMT",
    ...
    ```
    
    ### Encrypted/Object locked objects
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  4. cmd/rebalance-admin.go

    }
    
    // rebalanceAdminStatus holds rebalance status related information exported to mc, console, etc.
    type rebalanceAdminStatus struct {
    	ID        string                // identifies the ongoing rebalance operation by a uuid
    	Pools     []rebalancePoolStatus `json:"pools"` // contains all pools, including inactive
    	StoppedAt time.Time             `json:"stoppedAt"`
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 3.8K bytes
    - Viewed (0)
  5. cmd/erasure-metadata.go

    	// set restore status for transitioned object
    	restoreHdr, ok := fi.Metadata[xhttp.AmzRestore]
    	if ok {
    		if restoreStatus, err := parseRestoreObjStatus(restoreHdr); err == nil {
    			objInfo.RestoreOngoing = restoreStatus.Ongoing()
    			objInfo.RestoreExpires, _ = restoreStatus.Expiry()
    		}
    	}
    	objInfo.Checksum = fi.Checksum
    	objInfo.decryptPartsChecksums(nil)
    	objInfo.Inlined = fi.InlineData()
    	// Success.
    	return objInfo
    }
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 21.3K bytes
    - Viewed (0)
  6. cmd/bucket-replication-utils.go

    	ReplicateDecisionStr       string                            // stringified representation of replication decision for each target
    	Targets                    map[string]replication.StatusType // map of ARN->replication status for ongoing replication activity
    	PurgeTargets               map[string]VersionPurgeStatusType // map of ARN->VersionPurgeStatus for all the targets
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 26K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

           */
          private final AbstractService service;
    
          /**
           * This lock is used to ensure safe and correct cancellation, it ensures that a new task is
           * not scheduled while a cancel is ongoing. Also it protects the currentFuture variable to
           * ensure that it is assigned atomically with being scheduled.
           */
          private final ReentrantLock lock = new ReentrantLock();
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.8K bytes
    - Viewed (0)
  8. cmd/admin-handlers-pools.go

    		return
    	}
    
    	pools, ok := objectAPI.(*erasureServerPools)
    	if !ok {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrNotImplemented), r.URL)
    		return
    	}
    
    	// Cancel any ongoing rebalance operation
    	globalNotificationSys.StopRebalance(r.Context())
    	writeSuccessResponseHeadersOnly(w)
    	adminLogIf(ctx, pools.saveRebalanceStats(GlobalContext, 0, rebalSaveStoppedAt))
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Sep 04 20:47:24 UTC 2025
    - 11K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

           */
          private final AbstractService service;
    
          /**
           * This lock is used to ensure safe and correct cancellation, it ensures that a new task is
           * not scheduled while a cancel is ongoing. Also it protects the currentFuture variable to
           * ensure that it is assigned atomically with being scheduled.
           */
          private final ReentrantLock lock = new ReentrantLock();
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.7K bytes
    - Viewed (0)
  10. cmd/erasure-multipart.go

    	}
    	if strings.Contains(part.Error, errErasureReadQuorum.Error()) {
    		return errErasureReadQuorum
    	}
    	return errors.New(part.Error)
    }
    
    // CompleteMultipartUpload - completes an ongoing multipart
    // transaction after receiving all the parts indicated by the client.
    // Returns an md5sum calculated by concatenating all the individual
    // md5sums of all the parts.
    //
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
Back to top