chain

package

v0.1.39 Latest Latest Go to latest Published: Mar 1, 2026 License: AGPL-3.0 Imports: 7 Imported by: 0

Details

Package chain provides an adaptive wrapper over multiple object storage backends.

This section is empty.

This section is empty.

This section is empty.

type Chain struct {
	// contains filtered or unexported fields
}

Chain queries multiple object databases with an MRU backend preference.

func New(backends ...objectstore.Store) *Chain

New creates a Chain from backends.

func (chain *Chain) Close() error

Close closes all backends and joins close errors.

func (chain *Chain) ReadBytesContent(id objectid.ObjectID) (objecttype.Type, []byte, error)

ReadBytesContent reads an object's type and content bytes from one backend that has it.

func (chain *Chain) ReadBytesFull(id objectid.ObjectID) ([]byte, error)

ReadBytesFull reads a full serialized object from one backend that has it.

func (chain *Chain) ReadHeader(id objectid.ObjectID) (objecttype.Type, int64, error)

ReadHeader reads object header data from one backend that has it.

func (chain *Chain) ReadReaderContent(id objectid.ObjectID) (objecttype.Type, int64, io.ReadCloser, error)

ReadReaderContent reads an object's type, declared content length, and content stream from one backend that has it.

func (chain *Chain) ReadReaderFull(id objectid.ObjectID) (io.ReadCloser, error)

ReadReaderFull reads a full serialized object stream from one backend that has it.

func (chain *Chain) ReadSize(id objectid.ObjectID) (int64, error)

ReadSize reads object content length from one backend that has it.