- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 474 for Code (0.14 sec)
-
cmd/erasure-server-pool-rebalance.go
} participants[i] = ps.Participating } z.rebalMu.RUnlock() for poolIdx, doRebalance := range participants { if !doRebalance { continue } // nothing to do if this node is not pool's first node (i.e pool's rebalance 'leader'). if !globalEndpoints[poolIdx].Endpoints[0].IsLocal { continue } go func(idx int) { stopfn := globalRebalanceMetrics.log(rebalanceMetricRebalanceBuckets, idx)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 19:29:28 GMT 2024 - 27.2K bytes - Viewed (0) -
internal/lock/lock_nix.go
Err: syscall.EISDIR, } } return &LockedFile{File: f}, nil } // TryLockedOpenFile - tries a new write lock, functionality // it is similar to LockedOpenFile with with syscall.LOCK_EX // mode but along with syscall.LOCK_NB such that the function // doesn't wait forever but instead returns if it cannot // acquire a write lock. func TryLockedOpenFile(path string, flag int, perm os.FileMode) (*LockedFile, error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Aug 19 01:35:22 GMT 2021 - 2.8K bytes - Viewed (0) -
cmd/object-api-deleteobject_test.go
package cmd import ( "context" "crypto/md5" "encoding/hex" "strings" "testing" ) // Wrapper for calling DeleteObject tests for both Erasure multiple disks and single node setup. func TestDeleteObject(t *testing.T) { ExecObjectLayerTest(t, testDeleteObject) } // Unit test for DeleteObject in general. func testDeleteObject(obj ObjectLayer, instanceType string, t TestErrHandler) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Dec 23 15:46:00 GMT 2022 - 3.9K bytes - Viewed (0) -
cmd/metrics.go
) // MinIO Offline Disks per node ch <- prometheus.MustNewConstMetric( prometheus.NewDesc( prometheus.BuildFQName(minioNamespace, "disks", "offline"), "Total number of offline drives in current MinIO server instance", nil, nil), prometheus.GaugeValue, float64(offlineDisks.Sum()), ) // MinIO Total Disks per node ch <- prometheus.MustNewConstMetric( prometheus.NewDesc(
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 06:48:36 GMT 2024 - 16.9K bytes - Viewed (0) -
cmd/object-api-getobjectinfo_test.go
package cmd import ( "bytes" "context" "testing" ) // Wrapper for calling GetObjectInfo tests for both Erasure multiple disks and single node setup. func TestGetObjectInfo(t *testing.T) { ExecObjectLayerTest(t, testGetObjectInfo) } // Testing GetObjectInfo(). func testGetObjectInfo(obj ObjectLayer, instanceType string, t TestErrHandler) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Dec 23 15:46:00 GMT 2022 - 5.6K bytes - Viewed (0) -
cmd/storage-errors.go
// to proceed to next entry. var errSkipFile = errors.New("skip this file") var errIgnoreFileContrib = errors.New("ignore this file's contribution toward data-usage") // errXLBackend XL drive mode requires fresh deployment. var errXLBackend = errors.New("XL backend requires fresh drive") // StorageErr represents error generated by xlStorage call. type StorageErr string func (h StorageErr) Error() string {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.4K bytes - Viewed (0) -
helm/minio/templates/statefulset.yaml
{{- if eq .Values.mode "distributed" }} {{ $poolCount := .Values.pools | int }} {{ $nodeCount := .Values.replicas | int }} {{ $replicas := mul $poolCount $nodeCount }} {{ $drivesPerNode := .Values.drivesPerNode | int }} {{ $scheme := .Values.tls.enabled | ternary "https" "http" }} {{ $mountPath := .Values.mountPath }} {{ $bucketRoot := or ($.Values.bucketRoot) ($.Values.mountPath) }} {{ $subPath := .Values.persistence.subPath }}
Others - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 07:50:24 GMT 2024 - 10.7K bytes - Viewed (0) -
docs/config/README.md
sufficient to heal the content after drive replacements. Setting `max_sleep` to a *lower* value and setting `max_io` to a *higher* value would make heal go faster. Each node is responsible of healing its local drives; Each drive will have multiple heal workers which is the quarter of the number of CPU cores of the node or the quarter of the configured nr_requests of the drive (https://www.kernel.org/doc/Documentation/block/queue-sysfs.txt). It is also possible to provide a custom number of workers...
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 11 21:48:54 GMT 2023 - 17.7K bytes - Viewed (0) -
docs/sts/web-identity.md
there are more than one) has a unique domain name, this redirection should work automatically with no further configuration. For example, if the MinIO service is being accessed by the browser at the URL `https://minio-node-1.example.org`, the redirect URL will be `https://minio-node-1.example.org/oauth_callback` and all is well. For deployments with a load-balancer (LB), it is required that the LB is configured to send requests from the same user/client-app to the same backend MinIO server...
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 19.2K bytes - Viewed (1) -
cmd/auth-handler.go
var retSet bool if cred.AccessKey == "" { return ErrAccessDenied } conditions := getConditionValues(r, "", cred) conditions["object-lock-mode"] = []string{string(retMode)} conditions["object-lock-retain-until-date"] = []string{retDate.UTC().Format(time.RFC3339)} if retDays > 0 { conditions["object-lock-remaining-retention-days"] = []string{strconv.Itoa(retDays)}
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 26K bytes - Viewed (0)