Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 24 for HandlerFunc (0.3 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/api-router.go

    // high memory usage!
    func s3APIMiddleware(f http.HandlerFunc, flags ...s3HFlag) http.HandlerFunc {
    	// Collect all flags with bitwise-OR and assign operator
    	var handlerFlags s3HFlag
    	for _, flag := range flags {
    		handlerFlags |= flag
    	}
    
    	// Get name of the handler using reflection.
    	handlerName := getHandlerName(f, "objectAPIHandlers")
    
    	var handler http.HandlerFunc = func(w http.ResponseWriter, r *http.Request) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Oct 24 04:05:19 GMT 2025
    - 23.3K bytes
    - Click Count (0)
  2. cmd/kms-router.go

    		kmsRouter.Methods(http.MethodGet).Path(version + "/status").HandlerFunc(gz(httpTraceAll(kmsAPI.KMSStatusHandler)))
    		kmsRouter.Methods(http.MethodGet).Path(version + "/metrics").HandlerFunc(gz(httpTraceAll(kmsAPI.KMSMetricsHandler)))
    		kmsRouter.Methods(http.MethodGet).Path(version + "/apis").HandlerFunc(gz(httpTraceAll(kmsAPI.KMSAPIsHandler)))
    		kmsRouter.Methods(http.MethodGet).Path(version + "/version").HandlerFunc(gz(httpTraceAll(kmsAPI.KMSVersionHandler)))
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 07 23:55:37 GMT 2024
    - 2.7K bytes
    - Click Count (0)
  3. internal/dsync/dsync-server_test.go

    		subrouter.Methods(http.MethodPost).Path("/v1/health").HandlerFunc(lockServer.HealthHandler)
    		subrouter.Methods(http.MethodPost).Path("/v1/refresh").HandlerFunc(lockServer.RefreshHandler)
    		subrouter.Methods(http.MethodPost).Path("/v1/lock").HandlerFunc(lockServer.LockHandler)
    		subrouter.Methods(http.MethodPost).Path("/v1/rlock").HandlerFunc(lockServer.RLockHandler)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.3K bytes
    - Click Count (0)
  4. cmd/test-utils_test.go

    		case "HeadObject":
    			// Register HeadObject handler.
    			bucket.Methods("Head").Path("/{object:.+}").HandlerFunc(api.HeadObjectHandler)
    		case "GetObject":
    			// Register GetObject handler.
    			bucket.Methods(http.MethodGet).Path("/{object:.+}").HandlerFunc(api.GetObjectHandler)
    		case "PutObject":
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 77K bytes
    - Click Count (0)
  5. cmd/storage-rest-server.go

    			subrouter.Methods(http.MethodPost).Path(storageRESTVersionPrefix + storageRESTMethodVerifyFile).HandlerFunc(h(server.VerifyFileHandler))
    			subrouter.Methods(http.MethodPost).Path(storageRESTVersionPrefix + storageRESTMethodStatInfoFile).HandlerFunc(h(server.StatInfoFile))
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 45.7K bytes
    - Click Count (0)
  6. cmd/sts-handlers.go

    		noQueries := len(r.URL.RawQuery) == 0
    		return ctypeOk && noQueries
    	}).HandlerFunc(httpTraceAll(sts.AssumeRoleWithSSO))
    
    	// AssumeRoleWithClientGrants
    	stsRouter.Methods(http.MethodPost).HandlerFunc(httpTraceAll(sts.AssumeRoleWithClientGrants)).
    		Queries(stsAction, clientGrants).
    		Queries(stsVersion, stsAPIVersion).
    		Queries(stsToken, "{Token:.*}")
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 36.6K bytes
    - Click Count (0)
  7. cmd/http-tracer.go

    		tc.ResponseRecorder.LogAllBody = logBody
    		tc.ResponseRecorder.LogErrBody = true
    
    		f.ServeHTTP(w, r)
    	}
    }
    
    func httpTraceAll(f http.HandlerFunc) http.HandlerFunc {
    	return httpTrace(f, true)
    }
    
    func httpTraceHdrs(f http.HandlerFunc) http.HandlerFunc {
    	return httpTrace(f, false)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Sep 24 17:13:00 GMT 2024
    - 6K bytes
    - Click Count (0)
  8. cmd/generic-handlers.go

    		}
    	}
    	return false
    }
    
    // Limits body and header to specific allowed maximum limits as per S3/MinIO API requirements.
    func setRequestLimitMiddleware(h http.Handler) http.Handler {
    	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    		tc, ok := r.Context().Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt)
    
    		// Reject unsupported reserved metadata first before validation.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 20.7K bytes
    - Click Count (1)
  9. cmd/update_test.go

    	httpServer1 := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {}))
    	defer httpServer1.Close()
    	httpServer2 := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    		fmt.Fprintln(w, "fbe246edbd382902db9a4035df7dce8cb441357d minio.RELEASE.2016-10-07T01-16-39Z")
    	}))
    	defer httpServer2.Close()
    	httpServer3 := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 10.4K bytes
    - Click Count (0)
  10. cmd/metrics-v3-handler.go

    					Name:   mg.MetricFQN(d.Name),
    					Help:   d.Help,
    					Type:   d.Type.String(),
    					Labels: labels,
    				}
    				metrics = append(metrics, metric)
    			}
    		}
    	}
    
    	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    		contentType := r.Header.Get("Content-Type")
    		if contentType == "application/json" {
    			w.Header().Set("Content-Type", "application/json")
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Oct 10 18:57:03 GMT 2025
    - 7.7K bytes
    - Click Count (0)
Back to Top