- Sort Score
- Num 10 results
- Language All
Results 11 - 20 of 39 for rebalance (0.08 seconds)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)