Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for HandlerFunc (0.15 sec)

  1. cmd/admin-router.go

    		adminRouter.Methods(http.MethodDelete).Path(adminVersion + "/tier/{tier}").HandlerFunc(adminMiddleware(adminAPI.RemoveTierHandler))
    		adminRouter.Methods(http.MethodGet).Path(adminVersion + "/tier/{tier}").HandlerFunc(adminMiddleware(adminAPI.VerifyTierHandler))
    		// Tier stats
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 16 07:34:24 UTC 2025
    - 26.7K bytes
    - Viewed (0)
  2. 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) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed May 07 15:37:12 UTC 2025
    - 23.3K bytes
    - Viewed (0)
  3. 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))
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 45.7K bytes
    - Viewed (0)
  4. 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.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 20.7K bytes
    - Viewed (1)
  5. cmd/handler-utils.go

    		if enc != streamingContentEncoding {
    			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
    		}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.3K bytes
    - Viewed (1)
  6. 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) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 10.4K bytes
    - Viewed (0)
  7. 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:.*}")
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 36.6K bytes
    - Viewed (0)
  8. cmd/handler-api.go

    	t.mu.RLock()
    	defer t.mu.RUnlock()
    
    	if t.requestsPool == nil {
    		return nil
    	}
    
    	return t.requestsPool
    }
    
    // maxClients throttles the S3 API calls
    func maxClients(f http.HandlerFunc) http.HandlerFunc {
    	return func(w http.ResponseWriter, r *http.Request) {
    		globalHTTPStats.incS3RequestsIncoming()
    
    		if r.Header.Get(globalObjectPerfUserMetadata) == "" {
    			if val := globalServiceFreeze.Load(); val != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 10.4K bytes
    - Viewed (0)
  9. cmd/metrics.go

    	logger.CriticalIf(GlobalContext, registry.Register(newMinioCollector()))
    
    	gatherers := prometheus.Gatherers{
    		prometheus.DefaultGatherer,
    		registry,
    	}
    
    	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    		tc, ok := r.Context().Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt)
    		if ok {
    			tc.FuncName = "handler.MetricsLegacy"
    			tc.ResponseRecorder.LogErrBody = true
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  10. cmd/auth-handler.go

    }
    
    // setAuthMiddleware to validate authorization header for the incoming request.
    func setAuthMiddleware(h http.Handler) http.Handler {
    	// handler for validating incoming authorization headers.
    	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    		tc, ok := r.Context().Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt)
    
    		aType := getRequestAuthType(r)
    		switch aType {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 25.4K bytes
    - Viewed (0)
Back to top