snapshot

Documentation

Index

• func GetBlob(repository *storage.Repository, checksum [32]byte) ([]byte, error)
• func GetFilesystem(repository *storage.Repository, checksum [32]byte) (*vfs.Filesystem, []byte, error)
• func GetIndex(repository *storage.Repository, checksum [32]byte) (*index.Index, []byte, error)
• func GetSnapshot(repository *storage.Repository, indexID uuid.UUID) (*metadata.Metadata, bool, error)
• func List(repository *storage.Repository) ([]uuid.UUID, error)
• type CachedObject
• type Reader
  • func NewReader(snapshot *Snapshot, pathname string) (*Reader, error)
  • func (reader *Reader) Close() error
  • func (reader *Reader) GetContentType() string
  • func (reader *Reader) Read(buf []byte) (int, error)
  • func (reader *Reader) Seek(offset int64, whence int) (int64, error)
• type Snapshot
  • func Fork(repository *storage.Repository, indexID uuid.UUID) (*Snapshot, error)
  • func Load(repository *storage.Repository, indexID uuid.UUID) (*Snapshot, error)
  • func New(repository *storage.Repository, indexID uuid.UUID) (*Snapshot, error)
  • func (snapshot *Snapshot) Check(resource string, fast bool, showProgress bool) (bool, error)
  • func (snapshot *Snapshot) CheckChunk(checksum [32]byte) (bool, error)
  • func (snapshot *Snapshot) CheckObject(checksum [32]byte) (bool, error)
  • func (snapshot *Snapshot) Commit() error
  • func (snapshot *Snapshot) GetCachedObject(pathname string) (*CachedObject, error)
  • func (snapshot *Snapshot) GetChunk(checksum [32]byte) ([]byte, error)
  • func (snapshot *Snapshot) NewReader(pathname string) (*Reader, error)
  • func (snapshot *Snapshot) Pull(root string, rebase bool, pattern string, showProgress bool)
  • func (snapshot *Snapshot) Push(scanDir string, showProgress bool) error
  • func (snapshot *Snapshot) PutBlob(checksum [32]byte, data []byte) (int, error)
  • func (snapshot *Snapshot) PutCachedObject(pathname string, object objects.Object, fi vfs.FileInfo) error
  • func (snapshot *Snapshot) PutChunk(checksum [32]byte, data []byte) (int, error)
  • func (snapshot *Snapshot) PutObject(object *objects.Object) error
  • func (snapshot *Snapshot) Repository() *storage.Repository

Functions

func GetBlob

func GetBlob(repository *storage.Repository, checksum [32]byte) ([]byte, error)

func GetFilesystem

func GetFilesystem(repository *storage.Repository, checksum [32]byte) (*vfs.Filesystem, []byte, error)

func GetIndex

func GetIndex(repository *storage.Repository, checksum [32]byte) (*index.Index, []byte, error)

func GetSnapshot

func GetSnapshot(repository *storage.Repository, indexID uuid.UUID) (*metadata.Metadata, bool, error)

func List

func List(repository *storage.Repository) ([]uuid.UUID, error)

Types

type CachedObject

type CachedObject struct {
	Checksum    [32]byte
	Chunks      []*objects.Chunk
	ContentType string
	Info        vfs.FileInfo
}

CachedObject needs to be killed

type Reader

type Reader struct {
	// contains filtered or unexported fields
}

func NewReader

func NewReader(snapshot *Snapshot, pathname string) (*Reader, error)

func (*Reader) Close

func (reader *Reader) Close() error

func (*Reader) GetContentType

func (reader *Reader) GetContentType() string

func (*Reader) Read

func (reader *Reader) Read(buf []byte) (int, error)

func (*Reader) Seek

func (reader *Reader) Seek(offset int64, whence int) (int64, error)

type Snapshot

type Snapshot struct {
	SkipDirs []string

	Metadata   *metadata.Metadata
	Index      *index.Index
	Filesystem *vfs.Filesystem
	// contains filtered or unexported fields
}

func Fork

func Fork(repository *storage.Repository, indexID uuid.UUID) (*Snapshot, error)

func Load

func Load(repository *storage.Repository, indexID uuid.UUID) (*Snapshot, error)

func New

func New(repository *storage.Repository, indexID uuid.UUID) (*Snapshot, error)

func (*Snapshot) Check

func (snapshot *Snapshot) Check(resource string, fast bool, showProgress bool) (bool, error)

func (*Snapshot) CheckChunk

func (snapshot *Snapshot) CheckChunk(checksum [32]byte) (bool, error)

func (*Snapshot) CheckObject

func (snapshot *Snapshot) CheckObject(checksum [32]byte) (bool, error)

func (*Snapshot) Commit

func (snapshot *Snapshot) Commit() error

func (*Snapshot) GetCachedObject

func (snapshot *Snapshot) GetCachedObject(pathname string) (*CachedObject, error)

func (*Snapshot) GetChunk

func (snapshot *Snapshot) GetChunk(checksum [32]byte) ([]byte, error)

func (*Snapshot) NewReader

func (snapshot *Snapshot) NewReader(pathname string) (*Reader, error)

func (*Snapshot) Pull

func (snapshot *Snapshot) Pull(root string, rebase bool, pattern string, showProgress bool)

func (*Snapshot) Push

func (snapshot *Snapshot) Push(scanDir string, showProgress bool) error

func (*Snapshot) PutBlob

func (snapshot *Snapshot) PutBlob(checksum [32]byte, data []byte) (int, error)

func (*Snapshot) PutCachedObject

func (snapshot *Snapshot) PutCachedObject(pathname string, object objects.Object, fi vfs.FileInfo) error

func (*Snapshot) PutChunk

func (snapshot *Snapshot) PutChunk(checksum [32]byte, data []byte) (int, error)

func (*Snapshot) PutObject

func (snapshot *Snapshot) PutObject(object *objects.Object) error

func (*Snapshot) Repository

func (snapshot *Snapshot) Repository() *storage.Repository