client

Documentation

Index

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

Functions

func NewClientRepository

func NewClientRepository() storage.RepositoryBackend

Types

type ClientRepository

type ClientRepository struct {
	Cache *cache.Cache

	Repository string

	storage.RepositoryBackend
	// contains filtered or unexported fields
}

func (*ClientRepository) CheckChunk

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

func (*ClientRepository) CheckObject

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

func (*ClientRepository) Close

func (repository *ClientRepository) Close() error

func (*ClientRepository) Configuration

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

func (*ClientRepository) Create

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

func (*ClientRepository) GetBlob

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

func (*ClientRepository) GetChunk

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

func (*ClientRepository) GetChunks

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

func (*ClientRepository) GetIndexes

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

func (*ClientRepository) GetMetadata

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

func (*ClientRepository) GetObject

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

func (*ClientRepository) GetObjects

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

func (*ClientRepository) Open

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

func (*ClientRepository) Purge

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

func (*ClientRepository) PutBlob

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

func (*ClientRepository) PutChunk

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

func (*ClientRepository) PutMetadata

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

func (*ClientRepository) PutObject

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

func (*ClientRepository) Transaction

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

type ClientTransaction

type ClientTransaction struct {
	Uuid uuid.UUID

	storage.TransactionBackend
	// contains filtered or unexported fields
}

func (*ClientTransaction) Commit

func (transaction *ClientTransaction) Commit() error

func (*ClientTransaction) GetUuid

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

func (*ClientTransaction) PutChunk

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

func (*ClientTransaction) PutMetadata

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

func (*ClientTransaction) PutObject

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