Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 64 for setObject (0.06 seconds)

  1. cmd/global-heal.go

    		// If we resume to the same bucket, forward to last known item.
    		b := tracker.getBucket()
    		if b == bucket {
    			forwardTo = tracker.getObject()
    		}
    		if b != "" {
    			// Reset to where last bucket ended if resuming.
    			tracker.resume()
    		}
    		tracker.setObject("")
    		tracker.setBucket(bucket)
    		// Heal current bucket again in case if it is failed
    		// in the beginning of erasure set healing
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Apr 04 13:49:12 GMT 2025
    - 16.2K bytes
    - Click Count (0)
  2. cmd/background-newdisks-heal-ops.go

    func (h *healingTracker) setBucket(bucket string) {
    	h.mu.Lock()
    	defer h.mu.Unlock()
    
    	h.Bucket = bucket
    }
    
    func (h *healingTracker) getObject() string {
    	h.mu.RLock()
    	defer h.mu.RUnlock()
    
    	return h.Object
    }
    
    func (h *healingTracker) setObject(object string) {
    	h.mu.Lock()
    	defer h.mu.Unlock()
    
    	h.Object = object
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 16.5K bytes
    - Click Count (0)
  3. cmd/object-api-interface.go

    }
    
    // GetObject - TODO(aead): This function just acts as an adapter for GetObject tests and benchmarks
    // since the GetObject method of the ObjectLayer interface has been removed. Once, the
    // tests are adjusted to use GetObjectNInfo this function can be removed.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 17.5K bytes
    - Click Count (0)
  4. cmd/object_api_suite_test.go

    		}
    	}
    
    	for key, value := range objects {
    		var byteBuffer bytes.Buffer
    		err = GetObject(context.Background(), obj, "bucket", key, 0, int64(len(value)), &byteBuffer, "", opts)
    		if err != nil {
    			t.Fatalf("%s: <ERROR> %s", instanceType, err)
    		}
    		if !bytes.Equal(byteBuffer.Bytes(), value) {
    			t.Errorf("%s: Mismatch of GetObject data with the expected one.", instanceType)
    		}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 34.5K bytes
    - Click Count (0)
  5. cmd/erasure-object_test.go

    		if err != toObjectErr(errErasureReadQuorum, bucket, object) {
    			t.Errorf("Expected GetObject to fail with %v, but failed with %v", toObjectErr(errErasureReadQuorum, bucket, object), err)
    		}
    	}
    	if gr != nil {
    		_, err = io.Copy(io.Discard, gr)
    		if err != toObjectErr(errErasureReadQuorum, bucket, object) {
    			t.Errorf("Expected GetObject to fail with %v, but failed with %v", toObjectErr(errErasureReadQuorum, bucket, object), err)
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 38.3K bytes
    - Click Count (0)
  6. helm/minio/values.yaml

    #   statements:
    #     - effect: Allow  # this is the default
    #       resources:
    #         - 'arn:aws:s3:::example*/*'
    #       actions:
    #         - "s3:AbortMultipartUpload"
    #         - "s3:GetObject"
    #         - "s3:DeleteObject"
    #         - "s3:PutObject"
    #         - "s3:ListMultipartUploadParts"
    #     - resources:
    #         - 'arn:aws:s3:::example*'
    #       actions:
    #         - "s3:CreateBucket"
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 19.7K bytes
    - Click Count (1)
  7. cmd/bucket-policy-handlers_test.go

    	bucketPolicyTemplateWithoutVersion := `{"Version":"","Statement":[{"Sid":"","Effect":"Allow","Principal":{"AWS":["*"]},"Action":["s3:GetBucketLocation","s3:ListBucket"],"Resource":["arn:aws:s3:::%s"]},{"Sid":"","Effect":"Allow","Principal":{"AWS":["*"]},"Action":["s3:GetObject"],"Resource":["arn:aws:s3:::%s/this*"]}]}`
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 32.9K bytes
    - Click Count (0)
  8. cmd/api-router.go

    			HandlerFunc(s3APIMiddleware(api.GetObjectLegalHoldHandler)).
    			Queries("legal-hold", "")
    		// GetObject with lambda ARNs
    		router.Methods(http.MethodGet).Path("/{object:.+}").
    			HandlerFunc(s3APIMiddleware(api.GetObjectLambdaHandler, traceHdrsS3HFlag)).
    			Queries("lambdaArn", "{lambdaArn:.*}")
    		// GetObject
    		router.Methods(http.MethodGet).Path("/{object:.+}").
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:19 GMT 2025
    - 23.3K bytes
    - Click Count (0)
  9. helm/minio/README.md

    ```bash
    helm install --set policies[0].name=mypolicy,policies[0].statements[0].resources[0]='arn:aws:s3:::bucket1',policies[0].statements[0].actions[0]='s3:ListBucket',policies[0].statements[0].actions[1]='s3:GetObject' minio/minio
    ```
    
    Description of the configuration parameters used above -
    
    - `policies[].name` - name of the policy to create, must be a string with length > 0
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 10.9K bytes
    - Click Count (0)
  10. cmd/ftp-server-driver.go

    		return 0, nil, errors.New("bucket name cannot be empty")
    	}
    
    	clnt, err := driver.getMinIOClient(ctx)
    	if err != nil {
    		return 0, nil, err
    	}
    
    	opts := minio.GetObjectOptions{}
    	obj, err := clnt.GetObject(context.Background(), bucket, object, opts)
    	if err != nil {
    		return 0, nil, err
    	}
    	defer func() {
    		if err != nil && obj != nil {
    			obj.Close()
    		}
    	}()
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 14.3K bytes
    - Click Count (0)
Back to Top