restore

package
v0.11.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 5, 2022 License: Apache-2.0 Imports: 24 Imported by: 2

Documentation

Overview

Package restore manages restoring filesystem snapshots.

Package restore manages restoring filesystem snapshots.

Index

Constants

View Source 
const MaxFilenameLength = syscall.NAME_MAX

MaxFilenameLength is the maximum length of a filename.

Variables

This section is empty.

Functions

func PathIfPlaceholder added in v0.9.0 

func PathIfPlaceholder(path string) string

PathIfPlaceholder returns the placeholder suffix trimmed from path or the empty string if path is not a placeholder file.

func SafeRemoveAll added in v0.9.0 

func SafeRemoveAll(path string) error

SafeRemoveAll removes the shallow placeholder file(s) for path if they exist without experiencing errors caused by long file names.

func SafelySuffixablePath added in v0.9.0 

func SafelySuffixablePath(path string) bool

SafelySuffixablePath returns true if path can be suffixed with the placeholder suffix and written to the filesystem.

Types

type FilesystemOutput 

type FilesystemOutput struct {
	// TargetPath for restore.
	TargetPath string `json:"targetPath"`

	// If a directory already exists, overwrite the directory.
	OverwriteDirectories bool `json:"overwriteDirectories"`

	// Indicate whether or not to overwrite existing files. When set to false,
	// the copier does not modify already existing files and returns an error
	// instead.
	OverwriteFiles bool `json:"overwriteFiles"`

	// If a symlink already exists, remove it and create a new one. When set to
	// false, the copier does not modify existing symlinks and will return an
	// error instead.
	OverwriteSymlinks bool `json:"overwriteSymlinks"`

	// IgnorePermissionErrors causes restore to ignore errors due to invalid permissions.
	IgnorePermissionErrors bool `json:"ignorePermissionErrors"`

	// When set to true, first write to a temp file and rename it, to ensure there are no partially written files in case of a crash.
	WriteFilesAtomically bool `json:"writeFilesAtomically"`

	// SkipOwners when set to true causes restore to skip restoring owner information.
	SkipOwners bool `json:"skipOwners"`

	// SkipPermissions when set to true causes restore to skip restoring permission information.
	SkipPermissions bool `json:"skipPermissions"`

	// SkipTimes when set to true causes restore to skip restoring modification times.
	SkipTimes bool `json:"skipTimes"`

	// WriteSparseFiles when set to true, write contents as sparse files, minimizing allocated disk space.
	WriteSparseFiles bool `json:"writeSparseFiles"`
	// contains filtered or unexported fields
}

FilesystemOutput contains the options for outputting a file system tree.

func (*FilesystemOutput) BeginDirectory 

func (o *FilesystemOutput) BeginDirectory(ctx context.Context, relativePath string, e fs.Directory) error

BeginDirectory implements restore.Output interface.

func (*FilesystemOutput) Close 

func (o *FilesystemOutput) Close(ctx context.Context) error

Close implements restore.Output interface. 

func (o *FilesystemOutput) CreateSymlink(ctx context.Context, relativePath string, e fs.Symlink) error

CreateSymlink implements restore.Output interface.

func (*FilesystemOutput) FileExists added in v0.8.0 

func (o *FilesystemOutput) FileExists(ctx context.Context, relativePath string, e fs.File) bool

FileExists implements restore.Output interface.

func (*FilesystemOutput) FinishDirectory 

func (o *FilesystemOutput) FinishDirectory(ctx context.Context, relativePath string, e fs.Directory) error

FinishDirectory implements restore.Output interface.

func (*FilesystemOutput) Init added in v0.11.0 

func (o *FilesystemOutput) Init() error

Init initializes the internal members of the filesystem writer output. This method must be called before FilesystemOutput can be used.

func (*FilesystemOutput) Parallelizable added in v0.7.3 

func (o *FilesystemOutput) Parallelizable() bool

Parallelizable implements restore.Output interface.

func (*FilesystemOutput) SymlinkExists added in v0.8.0 

func (o *FilesystemOutput) SymlinkExists(ctx context.Context, relativePath string, e fs.Symlink) bool

SymlinkExists implements restore.Output interface.

func (*FilesystemOutput) WriteDirEntry added in v0.9.0 

func (o *FilesystemOutput) WriteDirEntry(ctx context.Context, relativePath string, de *snapshot.DirEntry, e fs.Directory) error

WriteDirEntry implements restore.Output interface.

func (*FilesystemOutput) WriteFile 

func (o *FilesystemOutput) WriteFile(ctx context.Context, relativePath string, f fs.File) error

WriteFile implements restore.Output interface.

type Options added in v0.7.3 

type Options struct {
	// NOTE: this structure is passed as-is from the UI, make sure to add
	// required bindings in the UI.
	Parallel               int   `json:"parallel"`
	Incremental            bool  `json:"incremental"`
	IgnoreErrors           bool  `json:"ignoreErrors"`
	RestoreDirEntryAtDepth int32 `json:"restoreDirEntryAtDepth"`
	MinSizeForPlaceholder  int32 `json:"minSizeForPlaceholder"`

	ProgressCallback func(ctx context.Context, s Stats)
	Cancel           chan struct{} // channel that can be externally closed to signal cancelation
}

Options provides optional restore parameters.

type Output 

type Output interface {
	Parallelizable() bool
	BeginDirectory(ctx context.Context, relativePath string, e fs.Directory) error
	WriteDirEntry(ctx context.Context, relativePath string, de *snapshot.DirEntry, e fs.Directory) error
	FinishDirectory(ctx context.Context, relativePath string, e fs.Directory) error
	WriteFile(ctx context.Context, relativePath string, e fs.File) error
	FileExists(ctx context.Context, relativePath string, e fs.File) bool
	CreateSymlink(ctx context.Context, relativePath string, e fs.Symlink) error
	SymlinkExists(ctx context.Context, relativePath string, e fs.Symlink) bool
	Close(ctx context.Context) error
}

Output encapsulates output for restore operation.

type ShallowFilesystemOutput added in v0.9.0 

type ShallowFilesystemOutput struct {
	FilesystemOutput

	// Files smaller than this will be written directly as part of the restore.
	MinSizeForPlaceholder int32
}

ShallowFilesystemOutput overrides methods in FilesystemOutput with shallow versions.

func (*ShallowFilesystemOutput) WriteDirEntry added in v0.9.0 

func (o *ShallowFilesystemOutput) WriteDirEntry(ctx context.Context, relativePath string, de *snapshot.DirEntry, e fs.Directory) error

WriteDirEntry implements restore.Output interface.

func (*ShallowFilesystemOutput) WriteFile added in v0.9.0 

func (o *ShallowFilesystemOutput) WriteFile(ctx context.Context, relativePath string, f fs.File) error

WriteFile implements restore.Output interface.

type Stats 

type Stats struct {
	// +checkatomic
	RestoredTotalFileSize int64
	// +checkatomic
	EnqueuedTotalFileSize int64
	// +checkatomic
	SkippedTotalFileSize int64

	// +checkatomic
	RestoredFileCount int32
	// +checkatomic
	RestoredDirCount int32
	// +checkatomic
	RestoredSymlinkCount int32
	// +checkatomic
	EnqueuedFileCount int32
	// +checkatomic
	EnqueuedDirCount int32
	// +checkatomic
	EnqueuedSymlinkCount int32
	// +checkatomic
	SkippedCount int32
	// +checkatomic
	IgnoredErrorCount int32
}

Stats represents restore statistics.

func Entry added in v0.7.2 

func Entry(ctx context.Context, rep repo.Repository, output Output, rootEntry fs.Entry, options Options) (Stats, error)

Entry walks a snapshot root with given root entry and restores it to the provided output.

type TarOutput 

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

TarOutput contains the options for outputting a file system tree to a tar or .tar.gz file.

func NewTarOutput 

func NewTarOutput(w io.WriteCloser) *TarOutput

NewTarOutput creates new tar writer output.

func (*TarOutput) BeginDirectory 

func (o *TarOutput) BeginDirectory(ctx context.Context, relativePath string, d fs.Directory) error

BeginDirectory implements restore.Output interface.

func (*TarOutput) Close 

func (o *TarOutput) Close(ctx context.Context) error

Close implements restore.Output interface. 

func (o *TarOutput) CreateSymlink(ctx context.Context, relativePath string, l fs.Symlink) error

CreateSymlink implements restore.Output interface.

func (*TarOutput) FileExists added in v0.8.0 

func (o *TarOutput) FileExists(ctx context.Context, relativePath string, f fs.File) bool

FileExists implements restore.Output interface.

func (*TarOutput) FinishDirectory 

func (o *TarOutput) FinishDirectory(ctx context.Context, relativePath string, e fs.Directory) error

FinishDirectory implements restore.Output interface.

func (*TarOutput) Parallelizable added in v0.7.3 

func (o *TarOutput) Parallelizable() bool

Parallelizable implements restore.Output interface.

func (*TarOutput) SymlinkExists added in v0.8.0 

func (o *TarOutput) SymlinkExists(ctx context.Context, relativePath string, l fs.Symlink) bool

SymlinkExists implements restore.Output interface.

func (*TarOutput) WriteDirEntry added in v0.9.0 

func (o *TarOutput) WriteDirEntry(ctx context.Context, relativePath string, de *snapshot.DirEntry, e fs.Directory) error

WriteDirEntry implements restore.Output interface.

func (*TarOutput) WriteFile 

func (o *TarOutput) WriteFile(ctx context.Context, relativePath string, f fs.File) error

WriteFile implements restore.Output interface.

type ZipOutput 

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

ZipOutput contains the options for outputting a file system tree to a zip file.

func NewZipOutput 

func NewZipOutput(w io.WriteCloser, method uint16) *ZipOutput

NewZipOutput creates new zip writer output.

func (*ZipOutput) BeginDirectory 

func (o *ZipOutput) BeginDirectory(ctx context.Context, relativePath string, e fs.Directory) error

BeginDirectory implements restore.Output interface.

func (*ZipOutput) Close 

func (o *ZipOutput) Close(ctx context.Context) error

Close implements restore.Output interface. 

func (o *ZipOutput) CreateSymlink(ctx context.Context, relativePath string, e fs.Symlink) error

CreateSymlink implements restore.Output interface.

func (*ZipOutput) FileExists added in v0.8.0 

func (o *ZipOutput) FileExists(ctx context.Context, relativePath string, l fs.File) bool

FileExists implements restore.Output interface.

func (*ZipOutput) FinishDirectory 

func (o *ZipOutput) FinishDirectory(ctx context.Context, relativePath string, e fs.Directory) error

FinishDirectory implements restore.Output interface.

func (*ZipOutput) Parallelizable added in v0.7.3 

func (o *ZipOutput) Parallelizable() bool

Parallelizable implements restore.Output interface.

func (*ZipOutput) SymlinkExists added in v0.8.0 

func (o *ZipOutput) SymlinkExists(ctx context.Context, relativePath string, l fs.Symlink) bool

SymlinkExists implements restore.Output interface.

func (*ZipOutput) WriteDirEntry added in v0.9.0 

func (o *ZipOutput) WriteDirEntry(ctx context.Context, relativePath string, de *snapshot.DirEntry, e fs.Directory) error

WriteDirEntry implements restore.Output interface.

func (*ZipOutput) WriteFile 

func (o *ZipOutput) WriteFile(ctx context.Context, relativePath string, f fs.File) error

WriteFile implements restore.Output interface.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.