s3

Documentation

Index

• func NewS3Repository() storage.RepositoryBackend
• type S3Repository
  • func (repository *S3Repository) CheckChunk(checksum [32]byte) (bool, error)
  • func (repository *S3Repository) CheckObject(checksum [32]byte) (bool, error)
  • func (repository *S3Repository) Close() error
  • func (repository *S3Repository) Configuration() storage.RepositoryConfig
  • func (repository *S3Repository) Create(location string, config storage.RepositoryConfig) error
  • func (repository *S3Repository) GetBlob(checksum [32]byte) ([]byte, error)
  • func (repository *S3Repository) GetChunk(checksum [32]byte) ([]byte, error)
  • func (repository *S3Repository) GetChunks() ([][32]byte, error)
  • func (repository *S3Repository) GetIndexes() ([]uuid.UUID, error)
  • func (repository *S3Repository) GetMetadata(indexID uuid.UUID) ([]byte, error)
  • func (repository *S3Repository) GetObject(checksum [32]byte) ([]byte, error)
  • func (repository *S3Repository) GetObjects() ([][32]byte, error)
  • func (repository *S3Repository) Open(location string) error
  • func (repository *S3Repository) Purge(indexID uuid.UUID) error
  • func (repository *S3Repository) PutBlob(checksum [32]byte, data []byte) error
  • func (repository *S3Repository) PutChunk(checksum [32]byte, data []byte) error
  • func (repository *S3Repository) PutMetadata(indexID uuid.UUID, data []byte) error
  • func (repository *S3Repository) PutObject(checksum [32]byte, data []byte) error
  • func (repository *S3Repository) Transaction(indexID uuid.UUID) (storage.TransactionBackend, error)
• type S3Transaction
  • func (transaction *S3Transaction) Commit() error
  • func (transaction *S3Transaction) GetUuid() uuid.UUID
  • func (transaction *S3Transaction) PutChunk(checksum [32]byte, data []byte) error
  • func (transaction *S3Transaction) PutFilesystem(data []byte) error
  • func (transaction *S3Transaction) PutIndex(data []byte) error
  • func (transaction *S3Transaction) PutMetadata(data []byte) error
  • func (transaction *S3Transaction) PutObject(checksum [32]byte, data []byte) error

Functions

func NewS3Repository

func NewS3Repository() storage.RepositoryBackend

Types

type S3Repository

type S3Repository struct {
	Cache *cache.Cache

	Repository string

	storage.RepositoryBackend
	// contains filtered or unexported fields
}

func (*S3Repository) CheckChunk

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

func (*S3Repository) CheckObject

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

func (*S3Repository) Close

func (repository *S3Repository) Close() error

func (*S3Repository) Configuration

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

func (*S3Repository) Create

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

func (*S3Repository) GetBlob

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

func (*S3Repository) GetChunk

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

func (*S3Repository) GetChunks

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

func (*S3Repository) GetIndexes

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

func (*S3Repository) GetMetadata

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

func (*S3Repository) GetObject

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

func (*S3Repository) GetObjects

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

func (*S3Repository) Open

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

func (*S3Repository) Purge

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

func (*S3Repository) PutBlob

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

func (*S3Repository) PutChunk

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

func (*S3Repository) PutMetadata

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

func (*S3Repository) PutObject

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

func (*S3Repository) Transaction

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

type S3Transaction

type S3Transaction struct {
	Uuid uuid.UUID

	storage.TransactionBackend
	// contains filtered or unexported fields
}

func (*S3Transaction) Commit

func (transaction *S3Transaction) Commit() error

func (*S3Transaction) GetUuid

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

func (*S3Transaction) PutChunk

func (transaction *S3Transaction) PutChunk(checksum [32]byte, data []byte) error

func (*S3Transaction) PutFilesystem

func (transaction *S3Transaction) PutFilesystem(data []byte) error

func (*S3Transaction) PutIndex

func (transaction *S3Transaction) PutIndex(data []byte) error

func (*S3Transaction) PutMetadata

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

func (*S3Transaction) PutObject

func (transaction *S3Transaction) PutObject(checksum [32]byte, data []byte) error