Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 26 for __construct (0.21 sec)

  1. cmd/bucket-lifecycle-handlers_test.go

    		shouldPass         bool
    	},
    ) {
    	for i, testCase := range testCases {
    		// initialize httptest Recorder, this records any mutations to response writer inside the handler.
    		rec := httptest.NewRecorder()
    		// construct HTTP request
    		req, err := newTestSignedRequestV4(testCase.method, getBucketLifecycleURL("", testCase.bucketName),
    			int64(len(testCase.body)), bytes.NewReader(testCase.body), testCase.accessKey, testCase.secretKey, nil)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Jun 13 20:52:33 GMT 2023
    - 11.2K bytes
    - Viewed (0)
  2. cmd/iam-etcd-store.go

    	//  a large number of policies
    	r, err := ies.client.Get(ctx, iamConfigPoliciesPrefix, etcd.WithPrefix())
    	if err != nil {
    		return err
    	}
    
    	// Parse all values to construct the policies data model.
    	for _, kvs := range r.Kvs {
    		if err = ies.getPolicyDocKV(ctx, kvs, m); err != nil && !errors.Is(err, errNoSuchPolicy) {
    			return err
    		}
    	}
    	return nil
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 13.6K bytes
    - Viewed (0)
  3. cmd/test-utils_test.go

    	}
    }
    
    // Uploads an object using DummyDataGen directly via the http
    // handler. Each part in a multipart object is a new DummyDataGen
    // instance (so the part sizes are needed to reconstruct the whole
    // object). When `len(partSizes) == 1`, asMultipart is used to upload
    // the object as multipart with 1 part or as a regular single object.
    //
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:06:57 GMT 2024
    - 75.7K bytes
    - Viewed (0)
  4. cmd/peer-rest-client.go

    	// Use a separate client to avoid recursive calls.
    	healthClient := rest.NewClient(serverURL, globalInternodeTransport, newCachedAuthToken())
    	healthClient.NoMetrics = true
    
    	// Construct a new health function.
    	restClient.HealthCheckFn = func() bool {
    		ctx, cancel := context.WithTimeout(context.Background(), restClient.HealthCheckTimeout)
    		defer cancel()
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.8K bytes
    - Viewed (0)
  5. cmd/object-api-utils.go

    	}
    	p.Reader = encReader
    	p.sealMD5Fn = sealETagFn(*objEncKey)
    	return p, nil
    }
    
    // NewPutObjReader returns a new PutObjReader. It uses given hash.Reader's
    // MD5Current method to construct md5sum when requested downstream.
    func NewPutObjReader(rawReader *hash.Reader) *PutObjReader {
    	return &PutObjReader{Reader: rawReader, rawReader: rawReader}
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Mar 11 11:55:34 GMT 2024
    - 35.6K bytes
    - Viewed (1)
  6. 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 39.5K bytes
    - Viewed (2)
  7. 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Oct 18 18:05:24 GMT 2023
    - 5.4K bytes
    - Viewed (0)
  8. 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 23.4K bytes
    - Viewed (0)
  9. cmd/bucket-policy-handlers_test.go

    	for i, testCase := range testCases {
    		// obtain the put bucket policy request body.
    		// initialize HTTP NewRecorder, this records any mutations to response writer inside the handler.
    		recV4 := httptest.NewRecorder()
    		// construct HTTP request for PUT bucket policy endpoint.
    		reqV4, err := newTestSignedRequestV4(http.MethodPut, getPutPolicyURL("", testCase.bucketName),
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 32.7K 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 11 17:45:28 GMT 2024
    - 66.7K bytes
    - Viewed (0)
Back to top