aboutsummaryrefslogtreecommitdiff
path: root/objectstore/mix/size.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/size.go
parentobjectstore/mix: Rename from objectstore/chain (diff)
signatureNo signature
objectstore/mix: Separate
Diffstat (limited to 'objectstore/mix/size.go')
-rw-r--r--objectstore/mix/size.go29
1 files changed, 29 insertions, 0 deletions
diff --git a/objectstore/mix/size.go b/objectstore/mix/size.go
new file mode 100644
index 00000000..7a45123c
--- /dev/null
+++ b/objectstore/mix/size.go
@@ -0,0 +1,29 @@
+package mix
+
+import (
+ "errors"
+ "fmt"
+
+ "codeberg.org/lindenii/furgit/objectid"
+ "codeberg.org/lindenii/furgit/objectstore"
+)
+
+// ReadSize reads object content length from one backend that has it.
+func (mix *Mix) ReadSize(id objectid.ObjectID) (int64, error) {
+ for i, backend := 0, mix.firstBackend(); backend != nil; i, backend = i+1, mix.nextBackend(backend) {
+ size, err := backend.ReadSize(id)
+ if err == nil {
+ mix.touchBackend(backend)
+
+ return size, nil
+ }
+
+ if errors.Is(err, objectstore.ErrObjectNotFound) {
+ continue
+ }
+
+ return 0, fmt.Errorf("objectstore: backend %d read size: %w", i, err)
+ }
+
+ return 0, objectstore.ErrObjectNotFound
+}