Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 26 for ServeHTTP (0.49 sec)

  1. cmd/bucket-policy-handlers_test.go

    		}
    		// Since `apiRouter` satisfies `http.Handler` it has a ServeHTTP to execute the logic of the handler.
    		// Call the ServeHTTP to execute the handler.
    		apiRouter.ServeHTTP(recV4, reqV4)
    		if recV4.Code != testCase.expectedRespStatus {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 32.9K bytes
    - Viewed (0)
  2. cmd/bucket-handlers_test.go

    		t.Fatalf("Test %s: Failed to create HTTP request for RemoveBucketHandler: <ERROR> %v", instanceType, err)
    	}
    	// Since `apiRouter` satisfies `http.Handler` it has a ServeHTTP to execute the logic of the handler.
    	// Call the ServeHTTP to execute the handler.
    	apiRouter.ServeHTTP(rec, req)
    	switch rec.Code {
    	case http.StatusOK, http.StatusCreated, http.StatusAccepted, http.StatusNoContent:
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 39.8K bytes
    - Viewed (0)
  3. cmd/generic-handlers.go

    		// in a federated setup cannot be proxied, so serve them at
    		// current server.
    		if bucket == "" {
    			h.ServeHTTP(w, r)
    			return
    		}
    
    		// MakeBucket requests should be handled at current endpoint
    		if r.Method == http.MethodPut && bucket != "" && object == "" && r.URL.RawQuery == "" {
    			h.ServeHTTP(w, r)
    			return
    		}
    
    		// CopyObject requests should be handled at current endpoint as path style
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 20.7K bytes
    - Viewed (1)
  4. cmd/post-policy_test.go

    	req.Header.Set("Content-Type", contentTypeHdr)
    	req.Header.Set("User-Agent", "Mozilla")
    
    	// Since `apiRouter` satisfies `http.Handler` it has a ServeHTTP to execute the logic of the handler.
    	// Call the ServeHTTP to execute the handler.
    	apiRouter.ServeHTTP(rec, req)
    
    	ctx, cancel := context.WithCancel(GlobalContext)
    	defer cancel()
    
    	// Now check if we actually wrote to backend (regardless of the response
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 30.6K bytes
    - Viewed (0)
  5. cmd/object-handlers_test.go

    		}
    		// Since `apiRouter` satisfies `http.Handler` it has a ServeHTTP to execute the logic of the handler.
    		// Call the ServeHTTP to execute the handler,`func (api objectAPIHandlers) GetObjectHandler`  handles the request.
    		apiRouter.ServeHTTP(rec, req)
    
    		// Assert the response code with the expected status.
    		if rec.Code != testCase.expectedRespStatus {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 163.1K bytes
    - Viewed (0)
  6. cmd/bucket-lifecycle-handlers_test.go

    		}
    		// Since `apiRouter` satisfies `http.Handler` it has a ServeHTTP to execute the logic of the handler.
    		// Call the ServeHTTP to execute the handler.
    		apiRouter.ServeHTTP(rec, req)
    		if rec.Code != testCase.expectedRespStatus {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 11.3K bytes
    - Viewed (0)
  7. internal/handlers/forwarder.go

    	return &bufPool{sz: sz, pool: bpool.Pool[*[]byte]{
    		New: func() *[]byte {
    			buf := make([]byte, sz)
    			return &buf
    		},
    	}}
    }
    
    // ServeHTTP forwards HTTP traffic using the configured transport
    func (f *Forwarder) ServeHTTP(w http.ResponseWriter, inReq *http.Request) {
    	outReq := new(http.Request)
    	*outReq = *inReq // includes shallow copies of maps, but we handle this in Director
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 5.7K bytes
    - Viewed (0)
  8. cmd/metrics-v3-handler.go

    		if ok {
    			tc.FuncName = "handler.MetricsV3"
    			tc.ResponseRecorder.LogErrBody = true
    		}
    
    		innerHandler.ServeHTTP(w, r)
    	})
    
    	// Add authentication
    	h.auth(tracedHandler).ServeHTTP(w, r)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 10 18:57:03 UTC 2025
    - 7.7K bytes
    - Viewed (0)
  9. cmd/http-tracer.go

    		if !ok {
    			// Tracing is not enabled for this request
    			f.ServeHTTP(w, r)
    			return
    		}
    
    		tc.FuncName = getOpName(runtime.FuncForPC(reflect.ValueOf(f).Pointer()).Name())
    		tc.RequestRecorder.LogBody = logBody
    		tc.ResponseRecorder.LogAllBody = logBody
    		tc.ResponseRecorder.LogErrBody = true
    
    		f.ServeHTTP(w, r)
    	}
    }
    
    func httpTraceAll(f http.HandlerFunc) http.HandlerFunc {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 6K bytes
    - Viewed (0)
  10. cmd/handler-utils.go

    			newEncs = append(newEncs, enc)
    		}
    	}
    	return strings.Join(newEncs, ",")
    }
    
    func collectInternodeStats(f http.HandlerFunc) http.HandlerFunc {
    	return func(w http.ResponseWriter, r *http.Request) {
    		f.ServeHTTP(w, r)
    
    		tc, ok := r.Context().Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt)
    		if !ok || tc == nil {
    			return
    		}
    
    		globalConnStats.incInternodeInputBytes(int64(tc.RequestRecorder.Size()))
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 16.4K bytes
    - Viewed (1)
Back to top