- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 54 for hopper (0.15 sec)
-
cmd/admin-handlers-pools.go
}{ID: id}) if err != nil { writeErrorResponseJSON(ctx, w, toAPIError(ctx, err), r.URL) return } writeSuccessResponseJSON(w, b) // Notify peers to load rebalance.bin and start rebalance routine if they happen to be // participating pool's leader node globalNotificationSys.LoadRebalanceMeta(ctx, true) } func (a adminAPIHandlers) RebalanceStatus(w http.ResponseWriter, r *http.Request) { ctx := r.Context()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 10.9K bytes - Viewed (0) -
internal/config/identity/plugin/config.go
case reqTimeMinute.Equal(h.currentMinute.statsTime): entry = &h.currentMinute case reqTimeMinute.Equal(h.lastFullMinute.statsTime): entry = &h.lastFullMinute default: // This request is too old, it should never happen, ignore it as we // cannot return an error. return } // Update stats if isSuccess { if entry.maxRttMs < rttMs { entry.maxRttMs = rttMs } entry.rttMsSum += rttMs
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 13.3K bytes - Viewed (3) -
cmd/endpoint.go
// where there are situations same endpoints with multiple disks // come online indicating either one of them is local and some // of them are not local. This situation can never happen and // its only a possibility in orchestrated deployments with dynamic // DNS. Following code ensures that we treat if one of the endpoint // says its local for a given host - it is true for all endpoints
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 34.1K bytes - Viewed (0) -
cmd/object-api-utils_test.go
if result != test.expectedResult { t.Fatalf("test %d failed: expected: result=%v, got=%v", i+1, test.expectedResult, result) } } } // TestIsMinioBucketName - Tests isMinioBucketName helper function. func TestIsMinioMetaBucketName(t *testing.T) { testCases := []struct { bucket string result bool }{ // MinIO meta bucket. { bucket: minioMetaBucket, result: true, },
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 23.4K bytes - Viewed (0) -
docs/bucket/notifications/README.md
``` Open another terminal and upload a JPEG image into `images` bucket. ``` mc cp gopher.jpg myminio/images ``` You should receive the following event notification via NSQ once the upload completes. ```
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 84K bytes - Viewed (2) -
cmd/utils.go
} return object } func isDirObject(object string) bool { if obj := encodeDirObject(object); obj != object { object = obj } return HasSuffix(object, globalDirSuffix) } // Helper method to return total number of nodes in cluster func totalNodeCount() int { totalNodesCount := len(globalEndpoints.Hostnames()) if totalNodesCount == 0 { totalNodesCount = 1 // For standalone erasure coding }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 31.4K bytes - Viewed (0) -
cmd/xl-storage_test.go
if err := xl.WriteMetadata(ctx, "", volume, object, fi); err != nil { t.Fatalf("Unable to create object, %s", err) } } var deleted [len(versions)]bool checkVerExist := func(t testing.TB) { t.Helper() for i := range versions { shouldExist := !deleted[i] fi, err := xl.ReadVersion(ctx, "", volume, object, versions[i], ReadOptions{}) if shouldExist { if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 17:45:28 GMT 2024 - 66.7K bytes - Viewed (0) -
internal/http/response-recorder.go
// ... otherwise we return the <GZIP> place holder return gzippedBody } // If there was an error response or body logging is enabled // then we return the body contents if (lrw.LogErrBody && lrw.StatusCode >= http.StatusBadRequest) || lrw.LogAllBody { return lrw.body.Bytes() } // ... otherwise we return the <BLOB> place holder return blobBody } // WriteHeader - writes http status code
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 02 00:13:19 GMT 2023 - 4.9K bytes - Viewed (0) -
cmd/bitrot-streaming.go
return nil } func (b *streamingBitrotReader) ReadAt(buf []byte, offset int64) (int, error) { var err error if offset%b.shardSize != 0 { // Offset should always be aligned to b.shardSize // Can never happen unless there are programmer bugs return 0, errUnexpected } if b.rc == nil { // For the first ReadAt() call we need to open the stream for reading. b.currOffset = offset
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jan 31 02:11:45 GMT 2024 - 5.8K bytes - Viewed (0) -
cmd/xl-storage-free-version_test.go
} fivs = fivs[:n] return fivs, nil } func TestFreeVersion(t *testing.T) { fatalErr := func(err error) { t.Helper() if err != nil { t.Fatal(err) } } // Add a version with tiered content, one with local content xl := xlMetaV2{} counter := 1 report := func() { t.Helper() // t.Logf("versions (%d): len = %d", counter, len(xl.versions)) counter++ } fi := FileInfo{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Mar 02 05:11:03 GMT 2024 - 7.8K bytes - Viewed (0)