storage

package

v0.0.0-...-094e3b7 Latest Latest Go to latest Published: Aug 14, 2023 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation ¶

Package storage defines the persistent storage of snapshots.

This section is empty.

This section is empty.

This section is empty.

type LocalFiles struct {
	ArchiveDir string
}

LocalFiles implementes the `snapshot.Storage` interface using the local file system.

It is used to write and read snapshots to persistent storage.

func (s *LocalFiles) CachePathInfo(ctx context.Context, p snapshot.Path, info os.FileInfo) error

func (s *LocalFiles) Exclude(p snapshot.Path) bool

Exclude reports whether or not the given path should be excluded from snapshotting.

This should return true for any paths that are part of the underlying persistent storage.

func (s *LocalFiles) FindSnapshot(ctx context.Context, p snapshot.Path) (*snapshot.Hash, *snapshot.File, error)

func (s *LocalFiles) LatestSignatureForIdentity(ctx context.Context, id *snapshot.Identity) (*snapshot.Hash, error)

func (s *LocalFiles) ListDirectorySnapshotContents(ctx context.Context, h *snapshot.Hash, f *snapshot.File) (snapshot.Tree, error)

ListDirectorySnapshotContents returns the parsed `*snapshot.Tree` object listing the contents of `f`.

The supplied `*snapshot.File` object must correspond to a directory.

func (s *LocalFiles) PathInfoMatchesCache(ctx context.Context, p snapshot.Path, info os.FileInfo) bool

func (s *LocalFiles) ReadObject(ctx context.Context, h *snapshot.Hash) (io.ReadCloser, error)

func (s *LocalFiles) ReadSnapshot(ctx context.Context, h *snapshot.Hash) (*snapshot.File, error)

func (s *LocalFiles) RemoveMappingForPath(ctx context.Context, p snapshot.Path) error

func (s *LocalFiles) StoreObject(ctx context.Context, size int64, reader io.Reader) (h *snapshot.Hash, err error)

func (s *LocalFiles) StoreSnapshot(ctx context.Context, p snapshot.Path, f *snapshot.File) (*snapshot.Hash, error)

func (s *LocalFiles) UpdateSignatureForIdentity(ctx context.Context, id *snapshot.Identity, h *snapshot.Hash) error