Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 39 for rebalance (0.05 seconds)

  1. cmd/api-errors.go

    	},
    	ErrAdminRebalanceAlreadyStarted: {
    		Code:           "XMinioAdminRebalanceAlreadyStarted",
    		Description:    "Pool rebalance is already started",
    		HTTPStatusCode: http.StatusConflict,
    	},
    	ErrAdminRebalanceNotStarted: {
    		Code:           "XMinioAdminRebalanceNotStarted",
    		Description:    "Pool rebalance is not started",
    		HTTPStatusCode: http.StatusNotFound,
    	},
    	ErrMaximumExpires: {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Apr 16 07:34:24 GMT 2025
    - 93K bytes
    - Click Count (3)
  2. cmd/erasure-metadata.go

    			}
    			// Previously we checked if we had quorum on DataDir value.
    			// We have removed this check to allow reading objects with different DataDir
    			// values in a few drives (due to a rebalance-stop race bug)
    			// provided their their etags or ModTimes match.
    
    			if !meta.Deleted && meta.Size != 0 {
    				fmt.Fprintf(h, "%v+%v", meta.Erasure.DataBlocks, meta.Erasure.ParityBlocks)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 21.3K bytes
    - Click Count (0)
  3. cmd/object-api-errors.go

    }
    
    func isReplicationPermissionCheck(err error) bool {
    	_, ok := err.(ReplicationPermissionCheck)
    	return ok
    }
    
    // DataMovementOverwriteErr - captures the error when a data movement activity
    // like rebalance incorrectly tries to overwrite an object.
    type DataMovementOverwriteErr GenericError
    
    func (de DataMovementOverwriteErr) Error() string {
    	objInfoStr := fmt.Sprintf("bucket=%s object=%s", de.Bucket, de.Object)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 09 02:05:14 GMT 2024
    - 22.1K bytes
    - Click Count (0)
  4. cmd/erasure-server-pool.go

    	nSets := make([]int, len(z.serverPools))
    	g := errgroup.WithNErrs(len(z.serverPools))
    	for index := range z.serverPools {
    		// Skip suspended pools or pools participating in rebalance for any new
    		// I/O.
    		if z.IsSuspended(index) || z.IsPoolRebalancing(index) {
    			continue
    		}
    		pool := z.serverPools[index]
    		nSets[index] = pool.setCount
    		g.Go(func() error {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 89.2K bytes
    - Click Count (0)
  5. cmd/rebalancemetric_string.go

    // Code generated by "stringer -type=rebalanceMetric -trimprefix=rebalanceMetric erasure-server-pool-rebalance.go"; DO NOT EDIT.
    
    package cmd
    
    import "strconv"
    
    func _() {
    	// An "invalid array index" compiler error signifies that the constant values have changed.
    	// Re-run the stringer command to generate them again.
    	var x [1]struct{}
    	_ = x[rebalanceMetricRebalanceBuckets-0]
    	_ = x[rebalanceMetricRebalanceBucket-1]
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Oct 25 19:36:57 GMT 2022
    - 988 bytes
    - Click Count (0)
  6. cmd/rebalstatus_string.go

    // Code generated by "stringer -type=rebalStatus -trimprefix=rebal erasure-server-pool-rebalance.go"; DO NOT EDIT.
    
    package cmd
    
    import "strconv"
    
    func _() {
    	// An "invalid array index" compiler error signifies that the constant values have changed.
    	// Re-run the stringer command to generate them again.
    	var x [1]struct{}
    	_ = x[rebalNone-0]
    	_ = x[rebalStarted-1]
    	_ = x[rebalCompleted-2]
    	_ = x[rebalStopped-3]
    	_ = x[rebalFailed-4]
    }
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Oct 25 19:36:57 GMT 2022
    - 795 bytes
    - Click Count (0)
  7. cmd/erasure-healing.go

    // from healObject)
    func (fi FileInfo) Healing() bool {
    	_, ok := fi.Metadata[xMinIOHealing]
    	return ok
    }
    
    // SetDataMov marks object (version) as being currently
    // in movement, such as decommissioning or rebalance.
    func (fi *FileInfo) SetDataMov() {
    	if fi.Metadata == nil {
    		fi.Metadata = make(map[string]string)
    	}
    	fi.Metadata[xMinIODataMov] = "true"
    }
    
    // DataMov returns true if object is being in movement
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 34.7K bytes
    - Click Count (0)
  8. src/main/java/jcifs/smb/SmbSessionImpl.java

         */
        private void handleNodeAvailable(WitnessNotification notification) {
            log.info("Node available: {}", notification.getResourceName());
            // Node is back online - could rebalance connections
        }
    
        /**
         * Schedule a reconnection attempt
         *
         * @param delayMs delay in milliseconds
         */
        private void scheduleReconnection(long delayMs) {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 68.9K bytes
    - Click Count (0)
  9. cmd/data-scanner.go

    // This keeps the cache size at a reasonable size for all buckets.
    //
    // Whenever a branch is scanned, it is assumed that it will be un-compacted
    // before it hits any of the above limits.
    // This will make the branch rebalance itself when scanned if the distribution of objects has changed.
    
    // scanDataFolder will scanner the basepath+cache.Info.Name and return an updated cache.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 45.5K bytes
    - Click Count (0)
  10. tests/joins_test.go

    	iv := DB.Table(`table_invoices`).Select(`seller, SUM(total) as total, SUM(paid) as paid, SUM(balance) as balance`).Group(`seller`)
    	stmt = dryDB.Table(`table_employees`).Select(`id, name, iv.total, iv.paid, iv.balance`).Joins(`LEFT JOIN (?) AS iv ON iv.seller = table_employees.id`, iv).Scan(&user).Statement
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Sun May 25 07:40:40 GMT 2025
    - 15K bytes
    - Click Count (0)
Back to Top