fs

package
v0.2.11-alpha Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 16, 2023 License: ISC Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewFSRepository

func NewFSRepository() storage.RepositoryBackend

Types

type FSRepository

type FSRepository struct {
	Cache *cache.Cache

	Repository string

	storage.RepositoryBackend
	// contains filtered or unexported fields
}

func (*FSRepository) CheckChunk

func (repository *FSRepository) CheckChunk(checksum [32]byte) (bool, error)

func (*FSRepository) CheckObject

func (repository *FSRepository) CheckObject(checksum [32]byte) (bool, error)

func (*FSRepository) Close

func (repository *FSRepository) Close() error

func (*FSRepository) Configuration

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

func (*FSRepository) Create

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

func (*FSRepository) DeleteChunk

func (repository *FSRepository) DeleteChunk(checksum [32]byte) error

func (*FSRepository) DeleteObject

func (repository *FSRepository) DeleteObject(checksum [32]byte) error

func (*FSRepository) GetBlob

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

func (*FSRepository) GetChunk

func (repository *FSRepository) GetChunk(checksum [32]byte) ([]byte, error)

func (*FSRepository) GetChunkRefCount

func (repository *FSRepository) GetChunkRefCount(checksum [32]byte) (uint64, error)

func (*FSRepository) GetChunkSize

func (repository *FSRepository) GetChunkSize(checksum [32]byte) (uint64, error)

func (*FSRepository) GetChunks

func (repository *FSRepository) GetChunks() ([][32]byte, error)

func (*FSRepository) GetIndexes

func (repository *FSRepository) GetIndexes() ([]uuid.UUID, error)

func (*FSRepository) GetMetadata

func (repository *FSRepository) GetMetadata(indexID uuid.UUID) ([]byte, error)

func (*FSRepository) GetObject

func (repository *FSRepository) GetObject(checksum [32]byte) ([]byte, error)

func (*FSRepository) GetObjectRefCount

func (repository *FSRepository) GetObjectRefCount(checksum [32]byte) (uint64, error)

func (*FSRepository) GetObjectSize

func (repository *FSRepository) GetObjectSize(checksum [32]byte) (uint64, error)

func (*FSRepository) GetObjects

func (repository *FSRepository) GetObjects() ([][32]byte, error)

func (*FSRepository) Open

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

func (*FSRepository) PathBlob

func (repository *FSRepository) PathBlob(checksum [32]byte) string

func (*FSRepository) PathBlobBucket

func (repository *FSRepository) PathBlobBucket(checksum [32]byte) string

func (*FSRepository) PathBlobs

func (repository *FSRepository) PathBlobs() string

func (*FSRepository) PathChunk

func (repository *FSRepository) PathChunk(checksum [32]byte) string

func (*FSRepository) PathChunkBucket

func (repository *FSRepository) PathChunkBucket(checksum [32]byte) string

func (*FSRepository) PathChunks

func (repository *FSRepository) PathChunks() string

func (*FSRepository) PathIndex

func (repository *FSRepository) PathIndex(indexID uuid.UUID) string

func (*FSRepository) PathIndexBucket

func (repository *FSRepository) PathIndexBucket(indexID uuid.UUID) string

func (*FSRepository) PathIndexes

func (repository *FSRepository) PathIndexes() string

func (*FSRepository) PathObject

func (repository *FSRepository) PathObject(checksum [32]byte) string

func (*FSRepository) PathObjectBucket

func (repository *FSRepository) PathObjectBucket(checksum [32]byte) string

func (*FSRepository) PathObjects

func (repository *FSRepository) PathObjects() string

func (*FSRepository) PathPurge

func (repository *FSRepository) PathPurge() string

func (*FSRepository) PathTransactions

func (repository *FSRepository) PathTransactions() string

func (*FSRepository) Purge

func (repository *FSRepository) Purge(indexID uuid.UUID) error

func (*FSRepository) PutBlob

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

func (*FSRepository) PutChunk

func (repository *FSRepository) PutChunk(checksum [32]byte, data []byte) error

func (*FSRepository) PutChunkSafe

func (repository *FSRepository) PutChunkSafe(checksum [32]byte, data []byte, link string) error

func (*FSRepository) PutMetadata

func (repository *FSRepository) PutMetadata(indexID uuid.UUID, data []byte) error

func (*FSRepository) PutObject

func (repository *FSRepository) PutObject(checksum [32]byte, data []byte) error

func (*FSRepository) PutObjectSafe

func (repository *FSRepository) PutObjectSafe(checksum [32]byte, data []byte, link string) error

func (*FSRepository) Transaction

func (repository *FSRepository) Transaction(indexID uuid.UUID) (storage.TransactionBackend, error)

type FSTransaction

type FSTransaction struct {
	Uuid uuid.UUID

	storage.TransactionBackend
	// contains filtered or unexported fields
}

func (*FSTransaction) Commit

func (transaction *FSTransaction) Commit() error

func (*FSTransaction) GetUuid

func (transaction *FSTransaction) GetUuid() uuid.UUID

func (*FSTransaction) Path

func (transaction *FSTransaction) Path() string

func (*FSTransaction) PutMetadata

func (transaction *FSTransaction) PutMetadata(data []byte) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL