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) DeleteBlob(checksum [32]byte) error
  • func (repository *ClientRepository) DeleteChunk(checksum [32]byte) error
  • func (repository *ClientRepository) DeleteObject(checksum [32]byte) error
  • func (repository *ClientRepository) DeleteSnapshot(indexID uuid.UUID) error
  • func (repository *ClientRepository) GetBlob(checksum [32]byte) ([]byte, error)
  • func (repository *ClientRepository) GetBlobs() ([][32]byte, error)
  • func (repository *ClientRepository) GetChunk(checksum [32]byte) ([]byte, error)
  • func (repository *ClientRepository) GetChunks() ([][32]byte, error)
  • func (repository *ClientRepository) GetObjects() ([][32]byte, error)
  • func (repository *ClientRepository) GetSnapshot(indexID uuid.UUID) ([]byte, error)
  • func (repository *ClientRepository) GetSnapshots() ([]uuid.UUID, error)
  • func (repository *ClientRepository) Open(location string) error
  • func (repository *ClientRepository) PutBlob(checksum [32]byte, data []byte) error
  • func (repository *ClientRepository) PutChunk(checksum [32]byte, data []byte) error
  • func (repository *ClientRepository) PutObject(checksum [32]byte) error
  • func (repository *ClientRepository) PutSnapshot(indexID uuid.UUID, data []byte) error
  • func (repository *ClientRepository) Transaction(indexID uuid.UUID) (storage.TransactionBackend, error)
• type ClientTransaction
  • func (transaction *ClientTransaction) Commit(data []byte) error
  • func (transaction *ClientTransaction) GetUuid() uuid.UUID
  • func (transaction *ClientTransaction) PutChunk(checksum [32]byte, data []byte) error
  • func (transaction *ClientTransaction) PutObject(checksum [32]byte) error

Functions

func NewClientRepository

func NewClientRepository() storage.RepositoryBackend

Types

type ClientRepository

type ClientRepository struct {
	Cache *cache.Cache

	Repository string
	// 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) DeleteBlob

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

func (*ClientRepository) DeleteChunk

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

func (*ClientRepository) DeleteObject

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

func (*ClientRepository) DeleteSnapshot

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

func (*ClientRepository) GetBlob

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

func (*ClientRepository) GetBlobs

func (repository *ClientRepository) GetBlobs() ([][32]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) GetObjects

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

func (*ClientRepository) GetSnapshot

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

func (*ClientRepository) GetSnapshots

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

func (*ClientRepository) Open

func (repository *ClientRepository) Open(location string) 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) PutObject

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

func (*ClientRepository) PutSnapshot

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

func (*ClientRepository) Transaction

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

type ClientTransaction

type ClientTransaction struct {
	Uuid uuid.UUID
	// contains filtered or unexported fields
}

func (*ClientTransaction) Commit

func (transaction *ClientTransaction) Commit(data []byte) 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) PutObject

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