Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 30 for __construct (0.17 sec)

  1. cmd/signature-v4.go

    		return ErrExpiredPresignRequest
    	}
    
    	// Save the date and expires.
    	t := pSignValues.Date
    	expireSeconds := int(pSignValues.Expires / time.Second)
    
    	// Construct new query.
    	query := make(url.Values)
    	clntHashedPayload := req.Form.Get(xhttp.AmzContentSha256)
    	if clntHashedPayload != "" {
    		query.Set(xhttp.AmzContentSha256, hashedPayload)
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:45:54 GMT 2024
    - 12.3K bytes
    - Viewed (0)
  2. cmd/erasure-decode.go

    			return -1, err
    		}
    
    		bytesWritten += n
    	}
    
    	if bytesWritten != length {
    		return bytesWritten, errLessData
    	}
    
    	return bytesWritten, derr
    }
    
    // Heal reads from readers, reconstruct shards and writes the data to the writers.
    func (e Erasure) Heal(ctx context.Context, writers []io.Writer, readers []io.ReaderAt, totalLength int64, prefer []bool) (derr error) {
    	if len(writers) != e.parityBlocks+e.dataBlocks {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 9.4K bytes
    - Viewed (0)
  3. cmd/admin-handlers_test.go

    	queryVal := url.Values{}
    	queryVal.Set("info", "")
    
    	req, err := buildAdminRequest(queryVal, http.MethodGet, "/info", 0, nil)
    	if err != nil {
    		t.Fatalf("Failed to construct get-config object request - %v", err)
    	}
    
    	rec := httptest.NewRecorder()
    	adminTestBed.router.ServeHTTP(rec, req)
    	if rec.Code != http.StatusOK {
    		t.Errorf("Expected to succeed but failed with %d", rec.Code)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 13.8K bytes
    - Viewed (0)
  4. internal/bucket/object/lock/lock.go

    		return ObjectLegalHold{XMLNS: "http://s3.amazonaws.com/doc/2006-03-01/", Status: parseLegalHoldStatus(holdStr)}
    	}
    	return ObjectLegalHold{}
    }
    
    // ParseObjectLockLegalHoldHeaders parses request headers to construct ObjectLegalHold
    func ParseObjectLockLegalHoldHeaders(h http.Header) (lhold ObjectLegalHold, err error) {
    	holdStatus, ok := h[AmzObjectLockLegalHold]
    	if ok {
    		lh := parseLegalHoldStatus(holdStatus[0])
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 17.1K bytes
    - Viewed (0)
  5. cmd/data-scanner.go

    				}
    				return nil
    			}
    
    			// successfully read means we have a valid object.
    			foundObjects = true
    			// Remove filename i.e is the meta file to construct object name
    			item.transformMetaDir()
    
    			// Object already accounted for, remove from heal map,
    			// simply because getSize() function already heals the
    			// object.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 11:18:58 GMT 2024
    - 47.6K bytes
    - Viewed (0)
  6. cmd/notification.go

    			return err
    		}, index)
    	}
    
    	for index, err := range g.Wait() {
    		if err != nil {
    			sys.addNodeErr(&reply[index], sys.peerClients[index], err)
    		}
    	}
    	return reply
    }
    
    // Construct a list of offline disks information for a given node.
    // If offlineHost is empty, do it for the local disks.
    func getOfflineDisks(offlineHost string, endpoints EndpointServerPools) []madmin.Disk {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 12 18:13:36 GMT 2024
    - 44.5K bytes
    - Viewed (0)
  7. cmd/bucket-handlers_test.go

    	if err != nil {
    		t.Fatalf("Error uploading object: <ERROR> %v", err)
    	}
    
    	// initialize httptest Recorder, this records any mutations to response writer inside the handler.
    	rec := httptest.NewRecorder()
    	// construct HTTP request for DELETE bucket.
    	req, err := newTestSignedRequestV4(http.MethodDelete, getBucketLocationURL("", bucketName), 0, nil, credentials.AccessKey, credentials.SecretKey, nil)
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 39.5K bytes
    - Viewed (2)
  8. cmd/config-migrate.go

    	return quick.LoadConfig(configFile, globalEtcdClient, data)
    }
    
    func readConfigWithoutMigrate(ctx context.Context, objAPI ObjectLayer) (config.Config, error) {
    	// Construct path to config.json for the given bucket.
    	configFile := path.Join(minioConfigPrefix, minioConfigFile)
    
    	configFiles := []string{
    		getConfigFile(),
    		getConfigFile() + ".deprecated",
    		configFile,
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Oct 18 18:05:24 GMT 2023
    - 5.4K bytes
    - Viewed (0)
  9. cmd/object-api-utils_test.go

    	}
    
    	objectName := `\../.minio.sys/config/hello.txt`
    
    	// initialize HTTP NewRecorder, this records any mutations to response writer inside the handler.
    	rec := httptest.NewRecorder()
    	// construct HTTP request for Get Object end point.
    	req, err := newTestSignedRequestV4(http.MethodPut, getPutObjectURL("", bucketName, objectName),
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 23.4K bytes
    - Viewed (0)
  10. cmd/xl-storage_test.go

    		Recursive: false,
    		Immediate: false,
    	})
    	if err != errDiskNotFound {
    		t.Errorf("Expected: \"Drive not found\", got \"%s\"", err)
    	}
    }
    
    // TestXLStorageDeleteFile - Series of test cases construct valid and invalid input data and validates the result and the error response.
    func TestXLStorageDeleteFile(t *testing.T) {
    	if runtime.GOOS == globalWindowsOSName {
    		t.Skip()
    	}
    
    	// create xlStorage test setup
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 11 17:45:28 GMT 2024
    - 66.7K bytes
    - Viewed (0)
Back to top