Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for sekund (0.16 sec)

  1. cmd/batch-handlers.go

    	if endpoint == "" {
    		return nil
    	}
    
    	buf, err := json.Marshal(ri)
    	if err != nil {
    		return err
    	}
    
    	ctx, cancel := context.WithTimeout(ctx, 10*time.Second)
    	defer cancel()
    
    	req, err := http.NewRequestWithContext(ctx, http.MethodPost, endpoint, bytes.NewReader(buf))
    	if err != nil {
    		return err
    	}
    
    	if token != "" {
    		req.Header.Set("Authorization", token)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 55.2K bytes
    - Viewed (0)
  2. cmd/erasure-object.go

    		// the content implicitly for all versions, we can
    		// avoid triggering another MRF heal for offline drives.
    		if len(versions) == 0 {
    			// Whether a disk was initially or becomes offline
    			// during this upload, send it to the MRF list.
    			for i := 0; i < len(onlineDisks); i++ {
    				if onlineDisks[i] != nil && onlineDisks[i].IsOnline() {
    					continue
    				}
    
    				er.addPartial(bucket, object, fi.VersionID)
    				break
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  3. cmd/api-errors.go

    				}
    			}
    		case *googleapi.Error:
    			apiErr = APIError{
    				Code:           "XGCSInternalError",
    				Description:    e.Message,
    				HTTPStatusCode: e.Code,
    			}
    			// GCS may send multiple errors, just pick the first one
    			// since S3 only sends one Error XML response.
    			if len(e.Errors) >= 1 {
    				apiErr.Code = e.Errors[0].Reason
    			}
    		case azblob.StorageError:
    			apiErr = APIError{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 91.4K bytes
    - Viewed (6)
Back to top