- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 103 for Mover (0.14 sec)
-
cmd/bucket-stats_gen_test.go
} left, err := v.UnmarshalMsg(bts) if err != nil { t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after UnmarshalMsg(): %q", len(left), left) } left, err = msgp.Skip(bts) if err != nil { t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after Skip(): %q", len(left), left) } } func BenchmarkMarshalMsgBucketReplicationStat(b *testing.B) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Aug 30 08:00:59 GMT 2023 - 20.5K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance_gen_test.go
} left, err := v.UnmarshalMsg(bts) if err != nil { t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after UnmarshalMsg(): %q", len(left), left) } left, err = msgp.Skip(bts) if err != nil { t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after Skip(): %q", len(left), left) } } func BenchmarkMarshalMsgrebalanceInfo(b *testing.B) { v := rebalanceInfo{}
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Oct 25 19:36:57 GMT 2022 - 11K bytes - Viewed (0) -
cmd/batch-handlers_gen_test.go
} left, err := v.UnmarshalMsg(bts) if err != nil { t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after UnmarshalMsg(): %q", len(left), left) } left, err = msgp.Skip(bts) if err != nil { t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after Skip(): %q", len(left), left) } } func BenchmarkMarshalMsgBatchJobRequest(b *testing.B) { v := BatchJobRequest{}
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Aug 29 18:27:23 GMT 2023 - 4.5K bytes - Viewed (0) -
docs/sts/.gitignore
*.manifest *.spec # Installer logs pip-log.txt pip-delete-this-directory.txt # Unit test / coverage reports htmlcov/ .tox/ .coverage .coverage.* .cache nosetests.xml coverage.xml *.cover .hypothesis/ .pytest_cache/ # Translations *.mo *.pot # Django stuff: *.log local_settings.py db.sqlite3 # Flask stuff: instance/ .webassets-cache # Scrapy stuff: .scrapy
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Jul 15 11:55:55 GMT 2020 - 1.2K bytes - Viewed (0) -
cmd/bucket-policy-handlers_test.go
accessKey: credentials.AccessKey, secretKey: credentials.SecretKey, expectedRespStatus: http.StatusBadRequest, }, } // Iterating over the test cases, calling the function under test and asserting the response. for i, testCase := range testCases { // obtain the put bucket policy request body.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 32.7K bytes - Viewed (0) -
internal/kms/kes.go
func (c *kesClient) DeleteKey(ctx context.Context, keyID string) error { c.lock.RLock() defer c.lock.RUnlock() return c.client.DeleteKey(ctx, keyID) } // ListKeys returns an iterator over all key names. func (c *kesClient) ListKeys(ctx context.Context) (*kes.ListIter[string], error) { c.lock.RLock() defer c.lock.RUnlock() return &kes.ListIter[string]{ NextFunc: c.client.ListKeys, }, nil
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Apr 16 15:43:39 GMT 2024 - 14.9K bytes - Viewed (0) -
docs/metrics/README.md
# MinIO Monitoring Guide MinIO server exposes monitoring data over endpoints. Monitoring tools can pick the data from these endpoints. This document lists the monitoring endpoints and relevant documentation. ## Healthcheck Probe MinIO server has two healthcheck related un-authenticated endpoints, a liveness probe to indicate if server is responding, cluster probe to check if server can be taken down for maintenance.
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 29 18:35:20 GMT 2024 - 1.9K bytes - Viewed (0) -
internal/etag/reader.go
// // content := etag.NewReader(r.Body, nil) // // compressedContent := Compress(content) // encryptedContent := Encrypt(compressedContent) // // // Now, we need an io.Reader that can access // // the ETag computed over the content. // reader := etag.Wrap(encryptedContent, content) func Wrap(wrapped, content io.Reader) io.Reader { if t, ok := content.(Tagger); ok { return wrapReader{ Reader: wrapped, Tagger: t, } }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 4.8K bytes - Viewed (0) -
cmd/s3-zip-handlers.go
} var rc io.ReadCloser if file.UncompressedSize64 > 0 { // There may be number of header bytes before the content. // Reading 64K extra. This should more than cover name and any "extra" details. end := file.Offset + int64(file.CompressedSize64) + 64<<10 if end > zipObjInfo.Size { end = zipObjInfo.Size } rs := &HTTPRangeSpec{Start: file.Offset, End: end}
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Apr 09 10:41:25 GMT 2024 - 15.8K bytes - Viewed (0) -
cmd/erasure.go
newInfos = append(newInfos, infos[i]) } else { scanningDisks = append(scanningDisks, disks[i]) scanningInfos = append(scanningInfos, infos[i]) } } // Prefer non-scanning disks over disks which are currently being scanned. newDisks = append(newDisks, scanningDisks...) newInfos = append(newInfos, scanningInfos...) /// Then add healing disks. newDisks = append(newDisks, healingDisks...)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 16K bytes - Viewed (1)