Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 16 of 16 for toAdminAPIErr (0.09 sec)

  1. cmd/admin-bucket-handlers.go

    		return
    	}
    
    	config, _, err := globalBucketMetadataSys.GetQuotaConfig(ctx, bucket)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	configData, err := json.Marshal(config)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	// Write success response.
    	writeSuccessResponseJSON(w, configData)
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 33.3K bytes
    - Viewed (0)
  2. cmd/metrics.go

    			tc.FuncName = "handler.MetricsLegacy"
    			tc.ResponseRecorder.LogErrBody = true
    		}
    
    		mfs, err := gatherers.Gather()
    		if err != nil {
    			if len(mfs) == 0 {
    				writeErrorResponseJSON(r.Context(), w, toAdminAPIErr(r.Context(), err), r.URL)
    				return
    			}
    		}
    
    		contentType := expfmt.Negotiate(r.Header)
    		w.Header().Set("Content-Type", string(contentType))
    
    		enc := expfmt.NewEncoder(w, contentType)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  3. cmd/admin-handler-utils.go

    type AdminError struct {
    	Code       string
    	Message    string
    	StatusCode int
    }
    
    func (ae AdminError) Error() string {
    	return ae.Message
    }
    
    func toAdminAPIErr(ctx context.Context, err error) APIError {
    	if err == nil {
    		return noError
    	}
    
    	var apiErr APIError
    	switch e := err.(type) {
    	case policy.Error:
    		apiErr = APIError{
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Jul 03 07:17:20 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  4. cmd/admin-heal-ops.go

    	errHealIdleTimeout   = errors.New("healing results were not consumed for too long")
    	errHealStopSignalled = errors.New("heal stop signaled")
    
    	errFnHealFromAPIErr = func(ctx context.Context, err error) error {
    		apiErr := toAdminAPIErr(ctx, err)
    		return fmt.Errorf("Heal internal error: %s: %s",
    			apiErr.Code, apiErr.Description)
    	}
    )
    
    // healSequenceStatus - accumulated status of the heal sequence
    type healSequenceStatus struct {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 25.4K bytes
    - Viewed (0)
  5. cmd/bucket-replication-handlers.go

    			Bucket: bucket,
    			Err:    err,
    		}), r.URL)
    		return
    	}
    
    	data, err := json.Marshal(rinfo)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    	// Write success response.
    	writeSuccessResponseJSON(w, data)
    }
    
    // ResetBucketReplicationStatusHandler - returns the status of replication reset.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 23.3K bytes
    - Viewed (0)
  6. cmd/metrics-v2.go

    		if ok {
    			tc.FuncName = funcName
    			tc.ResponseRecorder.LogErrBody = true
    		}
    
    		mfs, err := gatherers.Gather()
    		if err != nil && len(mfs) == 0 {
    			writeErrorResponseJSON(r.Context(), w, toAdminAPIErr(r.Context(), err), r.URL)
    			return
    		}
    
    		contentType := expfmt.Negotiate(r.Header)
    		w.Header().Set("Content-Type", string(contentType))
    
    		enc := expfmt.NewEncoder(w, contentType)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 133.4K bytes
    - Viewed (0)
Back to top