Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 24 for ServeHTTP (0.21 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 {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 32.7K 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:
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 39.5K bytes
    - Viewed (2)
  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
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 11 01:08:52 GMT 2024
    - 20.7K bytes
    - Viewed (0)
  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
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 16:45:54 GMT 2024
    - 29.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 {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun Mar 10 21:09:36 GMT 2024
    - 160K bytes
    - Viewed (0)
  6. internal/handlers/forwarder.go

    	return &bufPool{sz: sz, pool: sync.Pool{
    		New: func() interface{} {
    			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
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 07 05:42:10 GMT 2023
    - 5.6K bytes
    - Viewed (0)
  7. cmd/metrics-v3-handler.go

    		if ok {
    			tc.FuncName = "handler.MetricsV3"
    			tc.ResponseRecorder.LogErrBody = true
    		}
    
    		innerHandler.ServeHTTP(w, r)
    	})
    
    	// Add authentication
    	h.authFn(tracedHandler).ServeHTTP(w, r)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 7.4K bytes
    - Viewed (0)
  8. 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 {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 5.9K bytes
    - Viewed (0)
  9. 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()))
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 15.5K bytes
    - Viewed (3)
  10. 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 {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Jun 13 20:52:33 GMT 2023
    - 11.2K bytes
    - Viewed (0)
Back to top