Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 36 of 36 for ToAPIErr (0.09 sec)

  1. cmd/handler-api.go

    		default:
    			globalHTTPStats.addRequestsInQueue(-1)
    			if contextCanceled(ctx) {
    				w.WriteHeader(499)
    				return
    			}
    			// Send a http timeout message
    			writeErrorResponse(ctx, w,
    				errorCodes.ToAPIErr(ErrTooManyRequests),
    				r.URL)
    
    		}
    	}
    }
    
    func (t *apiConfig) getReplicationOpts() replicationPoolOpts {
    	t.mu.RLock()
    	defer t.mu.RUnlock()
    
    	if t.replicationPriority == "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 26 17:07:10 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  2. cmd/handler-utils.go

    		resource, err := getResource(r.URL.Path, r.Host, globalDomainNames)
    		if err != nil {
    			defer logger.AuditLog(r.Context(), w, r, mustGetClaimsFromToken(r))
    
    			apiErr := errorCodes.ToAPIErr(ErrUnsupportedHostHeader)
    			apiErr.Description = fmt.Sprintf("%s: %v", apiErr.Description, err)
    
    			writeErrorResponse(r.Context(), w, apiErr, r.URL)
    			return
    		}
    
    		bucket, _ := path2BucketObject(resource)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  3. cmd/admin-heal-ops.go

    				"(use force-start option to stop and start afresh). " +
    				fmt.Sprintf("The heal was started by IP %s at %s, token is %s",
    					h.clientAddress, h.startTime.Format(http.TimeFormat), h.clientToken)
    			return nil, errorCodes.ToAPIErr(ErrHealAlreadyRunning), errMsg
    		}
    	}
    
    	ahs.Lock()
    	defer ahs.Unlock()
    
    	// Check if new heal sequence to be started overlaps with any
    	// existing, running sequence
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  4. cmd/api-router.go

    func getHost(r *http.Request) string {
    	if r.URL.IsAbs() {
    		return r.URL.Host
    	}
    	return r.Host
    }
    
    func notImplementedHandler(w http.ResponseWriter, r *http.Request) {
    	writeErrorResponse(r.Context(), w, errorCodes.ToAPIErr(ErrNotImplemented), r.URL)
    }
    
    type rejectedAPI struct {
    	api     string
    	methods []string
    	queries []string
    	path    string
    }
    
    var rejectedObjAPIs = []rejectedAPI{
    	{
    		api:     "torrent",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 15:25:16 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  5. cmd/admin-router.go

    		if !handlerFlags.Has(noObjLayerFlag) {
    			objectAPI := newObjectLayerFn()
    			if objectAPI == nil || globalNotificationSys == nil {
    				writeErrorResponseJSON(r.Context(), w, errorCodes.ToAPIErr(ErrServerNotInitialized), r.URL)
    				return
    			}
    		}
    
    		// Apply http tracing "middleware" based on presence of flag.
    		var f2 http.HandlerFunc
    		if handlerFlags.Has(traceAllFlag) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Sep 21 11:35:40 UTC 2024
    - 26.2K bytes
    - Viewed (0)
  6. cmd/api-errors.go

    			apiErr.Description = fmt.Sprintf("The authorization header is malformed; the region is wrong; expecting '%s'.", region)
    			return apiErr
    		}
    	}
    	return apiErr
    }
    
    func (e errorCodeMap) ToAPIErr(errCode APIErrorCode) APIError {
    	return e.ToAPIErrWithErr(errCode, nil)
    }
    
    // error code to APIError structure, these fields carry respective
    // descriptions for all the error responses.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 92.1K bytes
    - Viewed (0)
Back to top