aboutsummaryrefslogtreecommitdiff
path: root/objectstore/mix/header.go
diff options
context:
space:
mode:
authorGravatar Runxi Yu2026-03-04 12:45:42 +0800
committerGravatar Runxi Yu2026-03-04 12:45:42 +0800
commit787791683d40a4bfff5f19d10686cb181bb69bf6 (patch)
treecd3a13cc1af3883acfb2f735133d0df5a831ba65 /objectstore/mix/header.go
parentobjectstore/mix: Rename from objectstore/chain (diff)
signatureNo signature
objectstore/mix: Separate
Diffstat (limited to 'objectstore/mix/header.go')
-rw-r--r--objectstore/mix/header.go30
1 files changed, 30 insertions, 0 deletions
diff --git a/objectstore/mix/header.go b/objectstore/mix/header.go
new file mode 100644
index 00000000..00b3ead7
--- /dev/null
+++ b/objectstore/mix/header.go
@@ -0,0 +1,30 @@
+package mix
+
+import (
+ "errors"
+ "fmt"
+
+ "codeberg.org/lindenii/furgit/objectid"
+ "codeberg.org/lindenii/furgit/objectstore"
+ "codeberg.org/lindenii/furgit/objecttype"
+)
+
+// ReadHeader reads object header data from one backend that has it.
+func (mix *Mix) ReadHeader(id objectid.ObjectID) (objecttype.Type, int64, error) {
+ for i, backend := 0, mix.firstBackend(); backend != nil; i, backend = i+1, mix.nextBackend(backend) {
+ ty, size, err := backend.ReadHeader(id)
+ if err == nil {
+ mix.touchBackend(backend)
+
+ return ty, size, nil
+ }
+
+ if errors.Is(err, objectstore.ErrObjectNotFound) {
+ continue
+ }
+
+ return objecttype.TypeInvalid, 0, fmt.Errorf("objectstore: backend %d read header: %w", i, err)
+ }
+
+ return objecttype.TypeInvalid, 0, objectstore.ErrObjectNotFound
+}