- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for 200 (0.16 sec)
-
cmd/server_test.go
0, nil, s.accessKey, s.secretKey, s.signer) c.Assert(err, nil) // execute the HTTP request. response, err = s.client.Do(request) c.Assert(err, nil) // assert whether 200 OK response status is obtained. c.Assert(response.StatusCode, http.StatusOK) // extract the response body. responseBody, err := io.ReadAll(response.Body) c.Assert(err, nil)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 108K bytes - Viewed (0) -
cmd/data-usage_test.go
size: 20000, }, { name: "dir1/dirc/fileindirc", size: 20000, }, { name: "rootfile3", size: 1000, }, { name: "dir1/dira/dirasub/fileindira2", size: 200, }, } createUsageTestFiles(t, base, bucket, files) err = os.RemoveAll(filepath.Join(base, bucket, "dir1/dira/dirasub/dcfile")) if err != nil { t.Fatal(err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Mar 27 15:10:40 GMT 2024 - 14.1K bytes - Viewed (0) -
cmd/generic-handlers_test.go
t.Errorf("Test %d: should fail but status code is HTTP %d", i, w.Code) case !test.ShouldFail && w.Code != http.StatusOK: t.Errorf("Test %d: should not fail but status code is HTTP %d and not 200 OK", i, w.Code) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 5.4K bytes - Viewed (0) -
internal/event/target/webhook.go
} req.Header.Set("Content-Type", "application/json") resp, err := target.httpClient.Do(req) if err != nil { return err } defer xhttp.DrainBody(resp.Body) if resp.StatusCode < 200 || resp.StatusCode > 299 { return fmt.Errorf("sending event failed with %v", resp.Status) } return nil } // SendFromStore - reads an event from store and sends it to webhook.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 20 22:40:07 GMT 2023 - 8.5K bytes - Viewed (0) -
cmd/format-erasure_test.go
return nil, errErasureReadQuorum } func BenchmarkGetFormatErasureInQuorumOld(b *testing.B) { setCount := 200 setDriveCount := 15 format := newFormatErasureV3(setCount, setDriveCount) format.Erasure.DistributionAlgo = formatErasureVersionV2DistributionAlgoV1 formats := make([]*formatErasureV3, 15*200) for i := 0; i < setCount; i++ { for j := 0; j < setDriveCount; j++ { newFormat := format.Clone()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 12.9K bytes - Viewed (0) -
cmd/erasure-sets_test.go
{"/a/b/c", 96}, {string([]byte{0xff, 0xfe, 0xfd}), 147}, } // Tests hashing order to be consistent. for i, testCase := range testCases { if sipHashElement := hashKey("SIPMOD", testCase.objectName, 200, testUUID); sipHashElement != testCase.sipHash { t.Errorf("Test case %d: Expected \"%v\" but failed \"%v\"", i+1, testCase.sipHash, sipHashElement) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 12 07:21:56 GMT 2024 - 6.9K bytes - Viewed (0) -
internal/rest/client.go
// Should only be modified before any calls are made. MaxErrResponseSize int64 // Avoid metrics update if set to true NoMetrics bool // TraceOutput will print debug information on non-200 calls if set. TraceOutput io.Writer // Debug trace output httpClient *http.Client url *url.URL newAuthToken func(audience string) string sync.RWMutex // mutex for lastErr lastErr error
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 14.4K bytes - Viewed (0) -
cmd/object-handlers.go
if err != nil { // if object is not found locally, but exists on peer site - proxy // the tagging request to peer site. The response to client will // be 200 with extra header indicating that the request was proxied. if isErrObjectNotFound(err) || isErrVersionNotFound(err) { proxytgts := getProxyTargets(ctx, bucket, object, opts) if !proxytgts.Empty() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0) -
internal/dsync/dsync_test.go
for i := 0; i < loops; i++ { m.Lock(id, source) m.Unlock(context.Background()) } cdone <- true } // Borrowed from mutex_test.go func TestMutex(t *testing.T) { loops := 200 if testing.Short() { loops = 5 } c := make(chan bool) m := NewDRWMutex(ds, "test") for i := 0; i < 10; i++ { go HammerMutex(m, loops, c) } for i := 0; i < 10; i++ { <-c } }
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/api-response.go
} deleteResp.Errors = errs return deleteResp } func writeResponse(w http.ResponseWriter, statusCode int, response []byte, mType mimeType) { if statusCode == 0 { statusCode = 200 } // Similar check to http.checkWriteHeaderCode if statusCode < 100 || statusCode > 999 { bugLogIf(context.Background(), fmt.Errorf("invalid WriteHeader code %v", statusCode))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 33.3K bytes - Viewed (2)