- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 203 for some (0.13 sec)
-
cmd/object_api_suite_test.go
func testListBucketsOrder(obj ObjectLayer, instanceType string, t TestErrHandler) { // if implementation contains a map, order of map keys will vary. // this ensures they return in the same order each time. // add one and test exists. err := obj.MakeBucket(context.Background(), "bucket1", MakeBucketOptions{}) if err != nil { t.Fatalf("%s: <ERROR> %s", instanceType, err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 32.3K bytes - Viewed (0) -
cmd/signature-v4-utils_test.go
t.Fatalf("Expected the APIErrorCode to be %d, but got %d", ErrNone, errCode) } inputQuery := r.URL.Query() // case where some headers need to get from request query signedHeaders = append(signedHeaders, "x-amz-server-side-encryption") // expect to fail with `ErrUnsignedHeaders` because couldn't find some header _, errCode = extractSignedHeaders(signedHeaders, r) if errCode != ErrUnsignedHeaders {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 05 21:26:41 GMT 2024 - 14.3K bytes - Viewed (0) -
internal/event/target/postgresql.go
} } if p.ConnectionString != "" { // No pq API doesn't help to validate connection string // prior connection, so no validation for now. } else { // Some fields need to be specified when ConnectionString is unspecified if p.Port == "" { return fmt.Errorf("unspecified port") } if _, err := strconv.Atoi(p.Port); err != nil { return fmt.Errorf("invalid port")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 17:51:07 GMT 2024 - 13.3K bytes - Viewed (0) -
internal/dsync/dsync_test.go
// These goroutines yield during local work, so that switching from // a blocked goroutine to other goroutines is profitable. // As a matter of fact, this benchmark still triggers some spinning in the mutex. m := NewDRWMutex(ds, "") var acc0, acc1 uint64 b.SetParallelism(4) b.RunParallel(func(pb *testing.PB) { c := make(chan bool) var data [4 << 10]uint64 for i := 0; pb.Next(); i++ {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 11K bytes - Viewed (0) -
cmd/bucket-object-lock.go
// version or alter its lock settings unless they have special // permissions. With governance mode, you protect objects against // being deleted by most users, but you can still grant some users // permission to alter the retention settings or delete the object // if necessary. You can also use governance mode to test retention-period // settings before creating a compliance-mode retention period.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 13.2K bytes - Viewed (0) -
cmd/peer-s3-client.go
continue } bucketsMap[bi.Name]++ if bucketsMap[bi.Name] >= quorum { resultMap[bi.Name] = bi } } } // loop through buckets and see if some with lost quorum // these could be stale buckets lying around, queue a heal // of such a bucket. This is needed here as we identify such // buckets here while listing buckets. As part of regular
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.8K bytes - Viewed (0) -
cmd/auth-handler_test.go
{ authT: authTypeJWT, pass: false, }, // Test 9 - unknown auth header is not supported s3 type. { authT: authTypeUnknown, pass: false, }, // Test 10 - some new auth type is not supported s3 type. { authT: authType(9), pass: false, }, } // Validate all the test cases. for i, tt := range testCases { ok := isSupportedS3AuthType(tt.authT)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 15.4K bytes - Viewed (0) -
cmd/storage-datatypes.go
// - on rewrite dataDir on disk that must be additionally purged // only after as a 2-phase call, allowing the older dataDir to // hang-around in-case we need some form of recovery. type RenameDataResp struct { Sign []byte OldDataDir string // contains '<uuid>', it is designed to be passed as value to Delete(bucket, pathJoin(object, dataDir)) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 15.3K bytes - Viewed (0) -
cmd/storage-rest-client.go
// return 503 server closed error, consider it as an offline node case strings.Contains(err.Error(), http.ErrServerClosed.Error()): return true // Corner case, the server closed the connection with a keep-alive timeout // some requests are not retried internally, such as POST request with written body case strings.Contains(err.Error(), "server closed idle connection"): return true } return false }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
cmd/api-router.go
noThrottleS3HFlag ) func (h s3HFlag) has(flag s3HFlag) bool { // Use bitwise-AND and check if the result is non-zero. return h&flag != 0 } // s3APIMiddleware - performs some common handler functionality for S3 API // handlers. // // It is set per-"handler function registration" in the router to allow for // behavior modification via flags. //
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 04 18:05:56 GMT 2024 - 22.8K bytes - Viewed (0)