repository

Documentation

Index

• Variables
• type Repository
  • func Inexistant(ctx *appcontext.AppContext, repositoryPath string) (*Repository, error)
  • func New(ctx *appcontext.AppContext, store storage.Store, config []byte) (*Repository, error)
  • func NewNoRebuild(ctx *appcontext.AppContext, store storage.Store, config []byte) (*Repository, error)
  • func (r *Repository) AppContext() *appcontext.AppContext
  • func (r *Repository) BlobExists(Type resources.Type, mac objects.MAC) bool
  • func (r *Repository) Chunker(rd io.ReadCloser) (*chunkers.Chunker, error)
  • func (r *Repository) Close() error
  • func (r *Repository) ComputeMAC(data []byte) objects.MAC
  • func (r *Repository) Configuration() storage.Configuration
  • func (r *Repository) Decode(input io.Reader) (io.Reader, error)
  • func (r *Repository) DecodeBuffer(buffer []byte) ([]byte, error)
  • func (r *Repository) DeletePackfile(mac objects.MAC) error
  • func (r *Repository) DeleteSnapshot(snapshotID objects.MAC) error
  • func (r *Repository) DeleteState(mac objects.MAC) error
  • func (r *Repository) Encode(input io.Reader) (io.Reader, error)
  • func (r *Repository) EncodeBuffer(buffer []byte) ([]byte, error)
  • func (r *Repository) GetBlob(Type resources.Type, mac objects.MAC) (io.ReadSeeker, error)
  • func (r *Repository) GetMACHasher() hash.Hash
  • func (r *Repository) GetPackfile(mac objects.MAC) (*packfile.PackFile, error)
  • func (r *Repository) GetPackfileBlob(mac objects.MAC, offset uint64, length uint32) (io.ReadSeeker, error)
  • func (r *Repository) GetPackfiles() ([]objects.MAC, error)
  • func (r *Repository) GetSnapshots() ([]objects.MAC, error)
  • func (r *Repository) GetState(mac objects.MAC) (versioning.Version, io.Reader, error)
  • func (r *Repository) GetStates() ([]objects.MAC, error)
  • func (r *Repository) ListSnapshots() iter.Seq[objects.MAC]
  • func (r *Repository) Location() string
  • func (r *Repository) Logger() *logging.Logger
  • func (r *Repository) NewStateDelta(cache *caching.ScanCache) *state.LocalState
  • func (r *Repository) PutPackfile(mac objects.MAC, rd io.Reader) error
  • func (r *Repository) PutState(mac objects.MAC, rd io.Reader) error
  • func (r *Repository) RebuildState() error
  • func (r *Repository) Store() storage.Store
• type RepositoryStore
  • func NewRepositoryStore[K, V any](repo *Repository, blobtype resources.Type) *RepositoryStore[K, V]
  • func (rs *RepositoryStore[K, V]) Get(sum objects.MAC) (*btree.Node[K, objects.MAC, V], error)
  • func (rs *RepositoryStore[K, V]) Put(node *btree.Node[K, objects.MAC, V]) (csum objects.MAC, err error)
  • func (rs *RepositoryStore[K, V]) Update(sum objects.MAC, node *btree.Node[K, objects.MAC, V]) error

Variables

var (
	ErrPackfileNotFound = errors.New("packfile not found")
	ErrBlobNotFound     = errors.New("blob not found")
)

var ErrStoreReadOnly = errors.New("read only store")

Types

type Repository

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

func Inexistant

func Inexistant(ctx *appcontext.AppContext, repositoryPath string) (*Repository, error)

func New

func New(ctx *appcontext.AppContext, store storage.Store, config []byte) (*Repository, error)

func NewNoRebuild

func NewNoRebuild(ctx *appcontext.AppContext, store storage.Store, config []byte) (*Repository, error)

func (*Repository) AppContext

func (r *Repository) AppContext() *appcontext.AppContext

func (*Repository) BlobExists

func (r *Repository) BlobExists(Type resources.Type, mac objects.MAC) bool

func (*Repository) Chunker

func (r *Repository) Chunker(rd io.ReadCloser) (*chunkers.Chunker, error)

func (*Repository) Close

func (r *Repository) Close() error

func (*Repository) ComputeMAC

func (r *Repository) ComputeMAC(data []byte) objects.MAC

func (*Repository) Configuration

func (r *Repository) Configuration() storage.Configuration

func (*Repository) Decode

func (r *Repository) Decode(input io.Reader) (io.Reader, error)

func (*Repository) DecodeBuffer

func (r *Repository) DecodeBuffer(buffer []byte) ([]byte, error)

func (*Repository) DeletePackfile

func (r *Repository) DeletePackfile(mac objects.MAC) error

func (*Repository) DeleteSnapshot

func (r *Repository) DeleteSnapshot(snapshotID objects.MAC) error

func (*Repository) DeleteState

func (r *Repository) DeleteState(mac objects.MAC) error

func (*Repository) Encode

func (r *Repository) Encode(input io.Reader) (io.Reader, error)

func (*Repository) EncodeBuffer

func (r *Repository) EncodeBuffer(buffer []byte) ([]byte, error)

func (*Repository) GetBlob

func (r *Repository) GetBlob(Type resources.Type, mac objects.MAC) (io.ReadSeeker, error)

func (*Repository) GetMACHasher

func (r *Repository) GetMACHasher() hash.Hash

func (*Repository) GetPackfile

func (r *Repository) GetPackfile(mac objects.MAC) (*packfile.PackFile, error)

func (*Repository) GetPackfileBlob

func (r *Repository) GetPackfileBlob(mac objects.MAC, offset uint64, length uint32) (io.ReadSeeker, error)

func (*Repository) GetPackfiles

func (r *Repository) GetPackfiles() ([]objects.MAC, error)

func (*Repository) GetSnapshots

func (r *Repository) GetSnapshots() ([]objects.MAC, error)

func (*Repository) GetState

func (r *Repository) GetState(mac objects.MAC) (versioning.Version, io.Reader, error)

func (*Repository) GetStates

func (r *Repository) GetStates() ([]objects.MAC, error)

func (*Repository) ListSnapshots

func (r *Repository) ListSnapshots() iter.Seq[objects.MAC]

func (*Repository) Location

func (r *Repository) Location() string

func (*Repository) Logger

func (r *Repository) Logger() *logging.Logger

func (*Repository) NewStateDelta

func (r *Repository) NewStateDelta(cache *caching.ScanCache) *state.LocalState

func (*Repository) PutPackfile

func (r *Repository) PutPackfile(mac objects.MAC, rd io.Reader) error

func (*Repository) PutState

func (r *Repository) PutState(mac objects.MAC, rd io.Reader) error

func (*Repository) RebuildState

func (r *Repository) RebuildState() error

func (*Repository) Store

func (r *Repository) Store() storage.Store

type RepositoryStore

type RepositoryStore[K, V any] struct {
	// contains filtered or unexported fields
}

func NewRepositoryStore

func NewRepositoryStore[K, V any](repo *Repository, blobtype resources.Type) *RepositoryStore[K, V]

func (*RepositoryStore[K, V]) Get

func (rs *RepositoryStore[K, V]) Get(sum objects.MAC) (*btree.Node[K, objects.MAC, V], error)

func (*RepositoryStore[K, V]) Put

func (rs *RepositoryStore[K, V]) Put(node *btree.Node[K, objects.MAC, V]) (csum objects.MAC, err error)

func (*RepositoryStore[K, V]) Update

func (rs *RepositoryStore[K, V]) Update(sum objects.MAC, node *btree.Node[K, objects.MAC, V]) error