Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 41 for objInfos (0.16 sec)

  1. cmd/config-common.go

    	}
    	defer r.Close()
    
    	buf, err := io.ReadAll(r)
    	if err != nil {
    		return nil, ObjectInfo{}, err
    	}
    	if len(buf) == 0 {
    		return nil, ObjectInfo{}, errConfigNotFound
    	}
    	return buf, r.ObjInfo, nil
    }
    
    func readConfig(ctx context.Context, store objectIO, configFile string) ([]byte, error) {
    	buf, _, err := readConfigWithMetadata(ctx, store, configFile, ObjectOptions{})
    	return buf, err
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 18 17:00:54 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  2. cmd/encryption-v1_test.go

    // offset of the object.
    func TestGetDecryptedRange_Issue50(t *testing.T) {
    	rs, err := parseRequestRangeSpec("bytes=594870256-594870263")
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	objInfo := ObjectInfo{
    		Bucket: "bucket",
    		Name:   "object",
    		Size:   595160760,
    		UserDefined: map[string]string{
    			crypto.MetaMultipart:                   "",
    			crypto.MetaIV:                          "HTexa=",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Sep 24 04:17:08 UTC 2022
    - 19.9K bytes
    - Viewed (0)
  3. cmd/erasure-sets.go

    	set := s.getHashedSet(object)
    	return set.PutObject(ctx, bucket, object, data, opts)
    }
    
    // GetObjectInfo - reads object metadata from the hashedSet based on the object name.
    func (s *erasureSets) GetObjectInfo(ctx context.Context, bucket, object string, opts ObjectOptions) (objInfo ObjectInfo, err error) {
    	set := s.getHashedSet(object)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
  4. cmd/erasure-server-pool-rebalance.go

    			if lc == nil {
    				return false
    			}
    			versioned := vc != nil && vc.Versioned(object)
    			objInfo := fi.ToObjectInfo(bucket, object, versioned)
    
    			evt := evalActionFromLifecycle(ctx, *lc, lr, rcfg, objInfo)
    			if evt.Action.Delete() {
    				globalExpiryState.enqueueByDays(objInfo, evt, lcEventSrc_Rebal)
    				return true
    			}
    
    			return false
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  5. cmd/veeam-sos-api.go

    func veeamSOSAPIHeadObject(ctx context.Context, bucket, object string, opts ObjectOptions) (ObjectInfo, error) {
    	gr, err := veeamSOSAPIGetObject(ctx, bucket, object, nil, opts)
    	if gr != nil {
    		gr.Close()
    		return gr.ObjInfo, nil
    	}
    	return ObjectInfo{}, err
    }
    
    func veeamSOSAPIGetObject(ctx context.Context, bucket, object string, rs *HTTPRangeSpec, opts ObjectOptions) (gr *GetObjectReader, err error) {
    	var buf []byte
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 00:34:56 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  6. cmd/object-api-utils.go

    }
    
    // GetObjectReader is a type that wraps a reader with a lock to
    // provide a ReadCloser interface that unlocks on Close()
    type GetObjectReader struct {
    	io.Reader
    	ObjInfo    ObjectInfo
    	cleanUpFns []func()
    	once       sync.Once
    }
    
    // WithCleanupFuncs sets additional cleanup functions to be called when closing
    // the GetObjectReader.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  7. cmd/post-policy_test.go

    		if rec.Code == http.StatusNoContent {
    			objInfo, err := obj.GetObjectInfo(context.Background(), bucketName, testCase.objectName+"/upload.txt", opts)
    			if err != nil {
    				t.Error("Unexpected error: ", err)
    			}
    			for k, v := range testCase.expectedHeaders {
    				if objInfo.UserDefined[k] != v {
    					t.Errorf("Expected to have header %s with value %s, but found value `%s` instead", k, v, objInfo.UserDefined[k])
    				}
    			}
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  8. cmd/erasure-healing_test.go

    		t.Fatal(err)
    	}
    
    	if fileInfoPostHeal.NumVersions != 2 {
    		t.Fatalf("Expected versions 2, got %d", fileInfoPreHeal.NumVersions)
    	}
    
    	if objInfo.DeleteMarker {
    		if _, err = objLayer.DeleteObject(ctx, bucket, object, ObjectOptions{
    			Versioned: true,
    			VersionID: objInfo.VersionID,
    		}); err != nil {
    			t.Fatal(err)
    		}
    	}
    
    	setDisks(nil, nil, nil, nil)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  9. cmd/erasure-object_test.go

    	for i, testCase := range testCases {
    		objInfo, err := obj.PutObject(ctx, testCase.bucket, testCase.object,
    			mustGetPutObjReader(t, bytes.NewReader([]byte("abcd")), int64(len("abcd")), "", ""), ObjectOptions{
    				Versioned: true,
    			})
    		if err != nil {
    			t.Fatalf("Erasure Object upload failed: <ERROR> %s", err)
    		}
    		names[i] = ObjectToDelete{
    			ObjectV: ObjectV{
    				ObjectName: objInfo.Name,
    				VersionID:  objInfo.VersionID,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 36.8K bytes
    - Viewed (0)
  10. cmd/object-handlers_test.go

    				continue
    			}
    			objInfo, err := obj.GetObjectInfo(context.Background(), testCase.bucketName, testCase.objectName, opts)
    			if err != nil {
    				t.Fatalf("Test %d: %s: Failed to fetch the copied object: <ERROR> %s", i+1, instanceType, err)
    			}
    			if objInfo.ContentEncoding == streamingContentEncoding {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:10:44 UTC 2024
    - 163.2K bytes
    - Viewed (0)
Back to top