- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 53 for newDecoder (0.31 sec)
-
cmd/generic-handlers_test.go
var okHandler http.HandlerFunc = func(w http.ResponseWriter, r *http.Request) { w.WriteHeader(http.StatusOK) } for i, test := range sseTLSHandlerTests { globalIsTLS = test.IsTLS w := httptest.NewRecorder() r := new(http.Request) r.Header = test.Header r.URL = test.URL h := setRequestValidityMiddleware(okHandler) h.ServeHTTP(w, r) switch {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 6.2K bytes - Viewed (0) -
cmd/bucket-replication-handlers.go
writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } w.Header().Set(xhttp.ContentType, string(mimeJSON)) enc := json.NewEncoder(w) stats := globalReplicationStats.Load().getLatestReplicationStats(bucket) bwRpt := globalNotificationSys.GetBandwidthReports(ctx, bucket) bwMap := bwRpt.BucketStats for arn, st := range stats.ReplicationStats.Stats {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 23.3K bytes - Viewed (0) -
cmd/bucket-lifecycle-handlers_test.go
shouldPass bool }, ) { for i, testCase := range testCases { // initialize httptest Recorder, this records any mutations to response writer inside the handler. rec := httptest.NewRecorder() // construct HTTP request req, err := newTestSignedRequestV4(testCase.method, getBucketLifecycleURL("", testCase.bucketName),
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 11.3K bytes - Viewed (0) -
cmd/metrics-v3-handler.go
contentType := r.Header.Get("Content-Type") if contentType == "application/json" { w.Header().Set("Content-Type", "application/json") jsonEncoder := json.NewEncoder(w) jsonEncoder.Encode(metrics) return } // If not JSON, return plain text. We format it as a markdown table for // readability. w.Header().Set("Content-Type", "text/plain")
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 7.7K bytes - Viewed (0) -
cmd/object-api-utils_test.go
t.Fatalf("Initializing config.json failed") } objectName := `\../.minio.sys/config/hello.txt` // initialize HTTP NewRecorder, this records any mutations to response writer inside the handler. rec := httptest.NewRecorder() // construct HTTP request for Get Object end point. req, err := newTestSignedRequestV4(http.MethodPut, getPutObjectURL("", bucketName, objectName),
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 24.1K bytes - Viewed (0) -
docs/debugging/inspect/export.go
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Jan 17 19:38:44 UTC 2025 - 9.1K bytes - Viewed (1) -
cmd/admin-bucket-handlers.go
defer keepAliveTicker.Stop() diffCh, err := getReplicationDiff(ctx, objectAPI, bucket, opts) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } enc := json.NewEncoder(w) for { select { case entry, ok := <-diffCh: if !ok { return } if err := enc.Encode(entry); err != nil { return } if len(diffCh) == 0 {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 33.3K bytes - Viewed (0) -
cmd/metrics.go
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 16.6K bytes - Viewed (0) -
cmd/admin-handlers-config-kv.go
key := vars["key"] _, envOnly := r.Form["env"] rd, err := GetHelp(subSys, key, envOnly) if err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } json.NewEncoder(w).Encode(rd) } // SetConfigHandler - PUT /minio/admin/v3/config func (a adminAPIHandlers) SetConfigHandler(w http.ResponseWriter, r *http.Request) { ctx := r.Context()
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 15.7K bytes - Viewed (1) -
cmd/metrics-v2.go
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 133.4K bytes - Viewed (0)