diff options
| author | 2026-03-04 14:36:33 +0800 | |
|---|---|---|
| committer | 2026-03-04 14:37:15 +0800 | |
| commit | 4e3357b476690e02945316519c7804e7f07ccb1b (patch) | |
| tree | 009b977bd973761c8b80f448a8242748acf863e1 /objectstore/chain/header.go | |
| parent | *: Add package-level docs (diff) | |
| signature | No signature | |
objectstore/chain: Add an actual chain object store v0.1.45
Diffstat (limited to 'objectstore/chain/header.go')
| -rw-r--r-- | objectstore/chain/header.go | 32 |
1 files changed, 32 insertions, 0 deletions
diff --git a/objectstore/chain/header.go b/objectstore/chain/header.go new file mode 100644 index 00000000..c1d4692c --- /dev/null +++ b/objectstore/chain/header.go @@ -0,0 +1,32 @@ +package chain + +import ( + "errors" + "fmt" + + "codeberg.org/lindenii/furgit/objectid" + "codeberg.org/lindenii/furgit/objectstore" + "codeberg.org/lindenii/furgit/objecttype" +) + +// ReadHeader reads object header data from the first backend that has it. +func (chain *Chain) ReadHeader(id objectid.ObjectID) (objecttype.Type, int64, error) { + for i, backend := range chain.backends { + if backend == nil { + continue + } + + ty, size, err := backend.ReadHeader(id) + if err == nil { + 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 +} |
