Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 53 for newDecoder (0.31 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. docs/debugging/inspect/export.go

    				}
    				versions[idx] = version{
    					Idx:      idx,
    					Header:   b,
    					Metadata: buf.Bytes(),
    				}
    				return nil
    			})
    			if e != nil {
    				return nil, e
    			}
    			enc := json.NewEncoder(buf)
    			if e := enc.Encode(struct {
    				Versions []version
    			}{Versions: versions}); e != nil {
    				return nil, e
    			}
    			data = b
    		default:
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jan 17 19:38:44 UTC 2025
    - 9.1K bytes
    - Viewed (1)
  7. 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)
  8. cmd/metrics.go

    				return
    			}
    		}
    
    		contentType := expfmt.Negotiate(r.Header)
    		w.Header().Set("Content-Type", string(contentType))
    
    		enc := expfmt.NewEncoder(w, contentType)
    		for _, mf := range mfs {
    			if err := enc.Encode(mf); err != nil {
    				// client may disconnect for any reasons
    				// we do not have to log this.
    				return
    			}
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  9. 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)
  10. cmd/metrics-v2.go

    			return
    		}
    
    		contentType := expfmt.Negotiate(r.Header)
    		w.Header().Set("Content-Type", string(contentType))
    
    		enc := expfmt.NewEncoder(w, contentType)
    		for _, mf := range mfs {
    			if err := enc.Encode(mf); err != nil {
    				// client may disconnect for any reasons
    				// we do not have to log this.
    				return
    			}
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 133.4K bytes
    - Viewed (0)
Back to top