- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 41 for objInfos (0.1 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)