aboutsummaryrefslogtreecommitdiff
path: root/objectdb
diff options
context:
space:
mode:
authorGravatar Runxi Yu2026-02-21 01:47:11 +0800
committerGravatar Runxi Yu2026-02-21 01:47:11 +0800
commite936d246576e8bf714dbf8666e9349a5f22be87e (patch)
tree2e97a53b076627958f2babbb0bdd732dafcaa381 /objectdb
parentobjectdb/chain: Chain belongs separately from objectdb (diff)
signatureNo signature
objectstore: Rename from objectdb
Diffstat (limited to 'objectdb')
-rw-r--r--objectdb/chain/chain.go128
-rw-r--r--objectdb/objectdb.go33
2 files changed, 0 insertions, 161 deletions
diff --git a/objectdb/chain/chain.go b/objectdb/chain/chain.go
deleted file mode 100644
index 1b4678d4..00000000
--- a/objectdb/chain/chain.go
+++ /dev/null
@@ -1,128 +0,0 @@
-// Package chain provides an ordered object database chain implementation.
-package chain
-
-import (
- "errors"
- "fmt"
- "io"
-
- "codeberg.org/lindenii/furgit/objectdb"
- "codeberg.org/lindenii/furgit/objectid"
- "codeberg.org/lindenii/furgit/objecttype"
-)
-
-// Chain queries multiple object databases in order.
-type Chain struct {
- backends []objectdb.ObjectDB
-}
-
-// New creates an ordered object database chain.
-func New(backends ...objectdb.ObjectDB) *Chain {
- return &Chain{
- backends: append([]objectdb.ObjectDB(nil), backends...),
- }
-}
-
-// ReadBytesFull reads a full serialized object from the first backend that has it.
-func (chain *Chain) ReadBytesFull(id objectid.ObjectID) ([]byte, error) {
- for i, backend := range chain.backends {
- if backend == nil {
- continue
- }
- full, err := backend.ReadBytesFull(id)
- if err == nil {
- return full, nil
- }
- if errors.Is(err, objectdb.ErrObjectNotFound) {
- continue
- }
- return nil, fmt.Errorf("objectdb: backend %d read bytes full: %w", i, err)
- }
- return nil, objectdb.ErrObjectNotFound
-}
-
-// ReadBytesContent reads an object's type and content bytes from the first backend that has it.
-func (chain *Chain) ReadBytesContent(id objectid.ObjectID) (objecttype.Type, []byte, error) {
- for i, backend := range chain.backends {
- if backend == nil {
- continue
- }
- ty, content, err := backend.ReadBytesContent(id)
- if err == nil {
- return ty, content, nil
- }
- if errors.Is(err, objectdb.ErrObjectNotFound) {
- continue
- }
- return objecttype.TypeInvalid, nil, fmt.Errorf("objectdb: backend %d read bytes content: %w", i, err)
- }
- return objecttype.TypeInvalid, nil, objectdb.ErrObjectNotFound
-}
-
-// ReadReaderFull reads a full serialized object stream from the first backend that has it.
-func (chain *Chain) ReadReaderFull(id objectid.ObjectID) (io.ReadCloser, error) {
- for i, backend := range chain.backends {
- if backend == nil {
- continue
- }
- reader, err := backend.ReadReaderFull(id)
- if err == nil {
- return reader, nil
- }
- if errors.Is(err, objectdb.ErrObjectNotFound) {
- continue
- }
- return nil, fmt.Errorf("objectdb: backend %d read reader full: %w", i, err)
- }
- return nil, objectdb.ErrObjectNotFound
-}
-
-// ReadReaderContent reads an object's type and content stream from the first backend that has it.
-func (chain *Chain) ReadReaderContent(id objectid.ObjectID) (objecttype.Type, io.ReadCloser, error) {
- for i, backend := range chain.backends {
- if backend == nil {
- continue
- }
- ty, reader, err := backend.ReadReaderContent(id)
- if err == nil {
- return ty, reader, nil
- }
- if errors.Is(err, objectdb.ErrObjectNotFound) {
- continue
- }
- return objecttype.TypeInvalid, nil, fmt.Errorf("objectdb: backend %d read reader content: %w", i, err)
- }
- return objecttype.TypeInvalid, nil, objectdb.ErrObjectNotFound
-}
-
-// 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, objectdb.ErrObjectNotFound) {
- continue
- }
- return objecttype.TypeInvalid, 0, fmt.Errorf("objectdb: backend %d read header: %w", i, err)
- }
- return objecttype.TypeInvalid, 0, objectdb.ErrObjectNotFound
-}
-
-// Close closes all backends and joins close errors.
-func (chain *Chain) Close() error {
- var errs []error
- for _, backend := range chain.backends {
- if backend == nil {
- continue
- }
- if err := backend.Close(); err != nil {
- errs = append(errs, err)
- }
- }
- return errors.Join(errs...)
-}
diff --git a/objectdb/objectdb.go b/objectdb/objectdb.go
deleted file mode 100644
index 6e1fbded..00000000
--- a/objectdb/objectdb.go
+++ /dev/null
@@ -1,33 +0,0 @@
-// Package objectdb provides storage interfaces for Git objects.
-package objectdb
-
-import (
- "errors"
- "io"
-
- "codeberg.org/lindenii/furgit/objectid"
- "codeberg.org/lindenii/furgit/objecttype"
-)
-
-// ErrObjectNotFound indicates that an object does not exist in a backend.
-// TODO: This might need to be an interface or otherwise be able to encapsulate multiple concrete backends'
-var ErrObjectNotFound = errors.New("objectdb: object not found")
-
-// ObjectDB reads Git objects by object ID.
-type ObjectDB interface {
- // ReadBytesFull reads a full serialized object as "type size\\x00content".
- // If hashed with the same algorithm it MUST match the object ID.
- ReadBytesFull(id objectid.ObjectID) ([]byte, error)
- // ReadBytesContent reads an object's type and content bytes.
- ReadBytesContent(id objectid.ObjectID) (objecttype.Type, []byte, error)
- // ReadReaderFull reads a full serialized object stream as "type size\\x00content".
- // Caller must close the returned reader.
- ReadReaderFull(id objectid.ObjectID) (io.ReadCloser, error)
- // ReadReaderContent reads an object's type and content stream.
- // Caller must close the returned reader.
- ReadReaderContent(id objectid.ObjectID) (objecttype.Type, io.ReadCloser, error)
- // ReadHeader reads an object's type and declared content length.
- ReadHeader(id objectid.ObjectID) (objecttype.Type, int64, error)
- // Close releases resources associated with the backend.
- Close() error
-}