s3

Documentation

Index

• func NewRepository(storeConfig map[string]string) (storage.Store, error)
• type Repository
  • func (repository *Repository) Close() error
  • func (repository *Repository) Create(config []byte) error
  • func (repository *Repository) DeleteLock(lockID objects.MAC) error
  • func (repository *Repository) DeletePackfile(mac objects.MAC) error
  • func (repository *Repository) DeleteState(mac objects.MAC) error
  • func (repository *Repository) GetLock(lockID objects.MAC) (io.Reader, error)
  • func (repository *Repository) GetLocks() ([]objects.MAC, error)
  • func (repository *Repository) GetPackfile(mac objects.MAC) (io.Reader, error)
  • func (repository *Repository) GetPackfileBlob(mac objects.MAC, offset uint64, length uint32) (io.Reader, error)
  • func (repository *Repository) GetPackfiles() ([]objects.MAC, error)
  • func (repository *Repository) GetState(mac objects.MAC) (io.Reader, error)
  • func (repository *Repository) GetStates() ([]objects.MAC, error)
  • func (repo *Repository) Location() string
  • func (repository *Repository) Open() ([]byte, error)
  • func (repository *Repository) PutLock(lockID objects.MAC, rd io.Reader) error
  • func (repository *Repository) PutPackfile(mac objects.MAC, rd io.Reader) error
  • func (repository *Repository) PutState(mac objects.MAC, rd io.Reader) error

Functions

func NewRepository

func NewRepository(storeConfig map[string]string) (storage.Store, error)

Types

type Repository

type Repository struct {
	Repository string
	// contains filtered or unexported fields
}

func (*Repository) Close

func (repository *Repository) Close() error

func (*Repository) Create

func (repository *Repository) Create(config []byte) error

func (*Repository) DeleteLock

func (repository *Repository) DeleteLock(lockID objects.MAC) error

func (*Repository) DeletePackfile

func (repository *Repository) DeletePackfile(mac objects.MAC) error

func (*Repository) DeleteState

func (repository *Repository) DeleteState(mac objects.MAC) error

func (*Repository) GetLock

func (repository *Repository) GetLock(lockID objects.MAC) (io.Reader, error)

func (*Repository) GetLocks

func (repository *Repository) GetLocks() ([]objects.MAC, error)

func (*Repository) GetPackfile

func (repository *Repository) GetPackfile(mac objects.MAC) (io.Reader, error)

func (*Repository) GetPackfileBlob

func (repository *Repository) GetPackfileBlob(mac objects.MAC, offset uint64, length uint32) (io.Reader, error)

func (*Repository) GetPackfiles

func (repository *Repository) GetPackfiles() ([]objects.MAC, error)

packfiles

func (*Repository) GetState

func (repository *Repository) GetState(mac objects.MAC) (io.Reader, error)

func (*Repository) GetStates

func (repository *Repository) GetStates() ([]objects.MAC, error)

states

func (*Repository) Location

func (repo *Repository) Location() string

func (*Repository) Open

func (repository *Repository) Open() ([]byte, error)

func (*Repository) PutLock

func (repository *Repository) PutLock(lockID objects.MAC, rd io.Reader) error

func (*Repository) PutPackfile

func (repository *Repository) PutPackfile(mac objects.MAC, rd io.Reader) error

func (*Repository) PutState

func (repository *Repository) PutState(mac objects.MAC, rd io.Reader) error