Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 191 for healCh (0.09 sec)

  1. cmd/bucket-replication.go

    			}
    		}
    		return
    	}
    
    	var ch, healCh chan<- ReplicationWorkerOperation
    	switch ri.OpType {
    	case replication.HealReplicationType, replication.ExistingObjectReplicationType:
    		ch = p.mrfReplicaCh
    		healCh = p.getWorkerCh(ri.Name, ri.Bucket, ri.Size)
    	default:
    		ch = p.getWorkerCh(ri.Name, ri.Bucket, ri.Size)
    	}
    	if ch == nil && healCh == nil {
    		return
    	}
    
    	select {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  2. cmd/background-heal-ops.go

    	"runtime"
    	"strconv"
    	"time"
    
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/pkg/v3/env"
    )
    
    // healTask represents what to heal along with options
    //
    //	path: '/' =>  Heal disk formats along with metadata
    //	path: 'bucket/' or '/bucket/' => Heal bucket
    //	path: 'bucket/object' => Heal object
    type healTask struct {
    	bucket    string
    	object    string
    	versionID string
    	opts      madmin.HealOpts
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  3. cmd/background-newdisks-heal-ops.go

    			}
    			continue
    		}
    		if t.HealID == tracker.HealID {
    			t.Finished = true
    			t.update(ctx)
    		}
    	}
    
    	return nil
    }
    
    // monitorLocalDisksAndHeal - ensures that detected new disks are healed
    //  1. Only the concerned erasure set will be listed and healed
    //  2. Only the node hosting the disk is responsible to perform the heal
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  4. cmd/admin-heal-ops.go

    	healFinishedStatus                     = "finished"
    )
    
    const (
    	// a heal sequence with this many un-consumed heal result
    	// items blocks until heal-status consumption resumes or is
    	// aborted due to timeout.
    	maxUnconsumedHealResultItems = 1000
    
    	// if no heal-results are consumed (via the heal-status API)
    	// for this timeout duration, the heal sequence is aborted.
    	healUnconsumedTimeout = 24 * time.Hour
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  5. cmd/healthcheck-handler.go

    	}
    	result := objLayer.Health(ctx, opts)
    	w.Header().Set(xhttp.MinIOWriteQuorum, strconv.Itoa(result.WriteQuorum))
    	w.Header().Set(xhttp.MinIOStorageClassDefaults, strconv.FormatBool(result.UsingDefaults))
    	// return how many drives are being healed if any
    	if result.HealingDrives > 0 {
    		w.Header().Set(xhttp.MinIOHealingDrives, strconv.Itoa(result.HealingDrives))
    	}
    	if !result.Healthy {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 26 07:44:34 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  6. cmd/global-heal.go

    	}
    
    	// Last sanity check
    	if len(tracker.QueuedBuckets) > 0 {
    		return fmt.Errorf("not all buckets were healed: %v", tracker.QueuedBuckets)
    	}
    
    	return nil
    }
    
    func healBucket(bucket string, scan madmin.HealScanMode) error {
    	// Get background heal sequence to send elements to heal
    	bgSeq, ok := globalBackgroundHealState.getHealSequenceByToken(bgHealingUUID)
    	if ok {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  7. cmd/metrics-v3-cluster-erasure-set.go

    		poolIDL, setIDL)
    	erasureSetReadHealthMD = NewGaugeMD(erasureSetReadHealth,
    		"Health of the erasure set in a pool for read operations (1=healthy, 0=unhealthy)",
    		poolIDL, setIDL)
    	erasureSetWriteHealthMD = NewGaugeMD(erasureSetWriteHealth,
    		"Health of the erasure set in a pool for write operations (1=healthy, 0=unhealthy)",
    		poolIDL, setIDL)
    )
    
    func b2f(v bool) float64 {
    	if v {
    		return 1
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 14 07:25:56 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  8. cmd/erasure-healing.go

    						tillOffset, DefaultBitrotAlgorithm, erasure.ShardSize())
    				}
    			}
    
    			// Heal each part. erasure.Heal() will write the healed
    			// part to .minio/tmp/uuid/ which needs to be renamed
    			// later to the final location.
    			err = erasure.Heal(ctx, writers, readers, partSize, prefer)
    			closeBitrotReaders(readers)
    			closeBitrotWriters(writers)
    			if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  9. cmd/metrics-v3-cluster-health.go

    		"Count of offline nodes in the cluster")
    	healthNodesOnlineCountMD = NewGaugeMD(healthNodesOnlineCount,
    		"Count of online nodes in the cluster")
    )
    
    // loadClusterHealthNodeMetrics - `MetricsLoaderFn` for cluster health node
    // metrics.
    func loadClusterHealthNodeMetrics(ctx context.Context, m MetricValues,
    	c *metricsCache,
    ) error {
    	nodesUpDown, _ := c.nodesUpDown.Get()
    
    	m.Set(healthNodesOfflineCount, float64(nodesUpDown.Offline))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Mar 10 09:15:15 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  10. docs/metrics/v3.md

    | `minio_cluster_erasure_set_read_health`          | Health of the erasure set in a pool for read operations (1=healthy, 0=unhealthy). <br><br>Type: gauge   | `pool_id`, `set_id` |
    | `minio_cluster_erasure_set_write_health`         | Health of the erasure set in a pool for write operations (1=healthy, 0=unhealthy). <br><br>Type: gauge  | `pool_id`, `set_id` |
    
    #### `/cluster/health`
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 02 22:30:11 UTC 2024
    - 45.2K bytes
    - Viewed (0)
Back to top