database

Documentation

Index

• func NewRepository() storage.RepositoryBackend
• type Repository
  • func (repository *Repository) CheckBlob(checksum [32]byte) (bool, error)
  • func (repository *Repository) Close() error
  • func (repository *Repository) Commit(indexID uuid.UUID, data []byte) error
  • func (repository *Repository) Configuration() storage.RepositoryConfig
  • func (repository *Repository) Create(location string, config storage.RepositoryConfig) error
  • func (repository *Repository) DeleteBlob(checksum [32]byte) error
  • func (repository *Repository) DeleteIndex(checksum [32]byte) error
  • func (repository *Repository) DeleteLock(indexID uuid.UUID) error
  • func (repository *Repository) DeletePackfile(checksum [32]byte) error
  • func (repository *Repository) DeleteSnapshot(indexID uuid.UUID) error
  • func (repository *Repository) GetBlob(checksum [32]byte) ([]byte, error)
  • func (repository *Repository) GetBlobs() ([][32]byte, error)
  • func (repository *Repository) GetIndex(checksum [32]byte) ([]byte, error)
  • func (repository *Repository) GetIndexes() ([][32]byte, error)
  • func (repository *Repository) GetLock(indexID uuid.UUID) ([]byte, error)
  • func (repository *Repository) GetLocks() ([]uuid.UUID, error)
  • func (repository *Repository) GetPackfile(checksum [32]byte) ([]byte, error)
  • func (repository *Repository) GetPackfileSubpart(checksum [32]byte, offset uint32, length uint32) ([]byte, error)
  • func (repository *Repository) GetPackfiles() ([][32]byte, error)
  • func (repository *Repository) GetSnapshot(indexID uuid.UUID) ([]byte, error)
  • func (repository *Repository) GetSnapshots() ([]uuid.UUID, error)
  • func (repository *Repository) Open(location string) error
  • func (repository *Repository) PutBlob(checksum [32]byte, data []byte) error
  • func (repository *Repository) PutIndex(checksum [32]byte, data []byte) error
  • func (repository *Repository) PutLock(indexID uuid.UUID, data []byte) error
  • func (repository *Repository) PutPackfile(checksum [32]byte, data []byte) error
  • func (repository *Repository) PutSnapshot(indexID uuid.UUID, data []byte) error

Functions

func NewRepository

func NewRepository() storage.RepositoryBackend

Types

type Repository

type Repository struct {
	Cache *cache.Cache

	Repository string
	// contains filtered or unexported fields
}

func (*Repository) CheckBlob

func (repository *Repository) CheckBlob(checksum [32]byte) (bool, error)

func (*Repository) Close

func (repository *Repository) Close() error

func (*Repository) Commit

func (repository *Repository) Commit(indexID uuid.UUID, data []byte) error

func (*Repository) Configuration

func (repository *Repository) Configuration() storage.RepositoryConfig

func (*Repository) Create

func (repository *Repository) Create(location string, config storage.RepositoryConfig) error

func (*Repository) DeleteBlob

func (repository *Repository) DeleteBlob(checksum [32]byte) error

func (*Repository) DeleteIndex

func (repository *Repository) DeleteIndex(checksum [32]byte) error

func (*Repository) DeleteLock

func (repository *Repository) DeleteLock(indexID uuid.UUID) error

func (*Repository) DeletePackfile

func (repository *Repository) DeletePackfile(checksum [32]byte) error

func (*Repository) DeleteSnapshot

func (repository *Repository) DeleteSnapshot(indexID uuid.UUID) error

func (*Repository) GetBlob

func (repository *Repository) GetBlob(checksum [32]byte) ([]byte, error)

func (*Repository) GetBlobs

func (repository *Repository) GetBlobs() ([][32]byte, error)

blobs

func (*Repository) GetIndex

func (repository *Repository) GetIndex(checksum [32]byte) ([]byte, error)

func (*Repository) GetIndexes

func (repository *Repository) GetIndexes() ([][32]byte, error)

indexes

func (*Repository) GetLock

func (repository *Repository) GetLock(indexID uuid.UUID) ([]byte, error)

func (*Repository) GetLocks

func (repository *Repository) GetLocks() ([]uuid.UUID, error)

locks

func (*Repository) GetPackfile

func (repository *Repository) GetPackfile(checksum [32]byte) ([]byte, error)

func (*Repository) GetPackfileSubpart

func (repository *Repository) GetPackfileSubpart(checksum [32]byte, offset uint32, length uint32) ([]byte, error)

func (*Repository) GetPackfiles

func (repository *Repository) GetPackfiles() ([][32]byte, error)

packfiles

func (*Repository) GetSnapshot

func (repository *Repository) GetSnapshot(indexID uuid.UUID) ([]byte, error)

func (*Repository) GetSnapshots

func (repository *Repository) GetSnapshots() ([]uuid.UUID, error)

snapshots

func (*Repository) Open

func (repository *Repository) Open(location string) error

func (*Repository) PutBlob

func (repository *Repository) PutBlob(checksum [32]byte, data []byte) error

func (*Repository) PutIndex

func (repository *Repository) PutIndex(checksum [32]byte, data []byte) error

func (*Repository) PutLock

func (repository *Repository) PutLock(indexID uuid.UUID, data []byte) error

func (*Repository) PutPackfile

func (repository *Repository) PutPackfile(checksum [32]byte, data []byte) error

func (*Repository) PutSnapshot

func (repository *Repository) PutSnapshot(indexID uuid.UUID, data []byte) error