snapshot

package
v0.17.0 Latest Latest
Warning

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

 Go to latest Published: Apr 16, 2024 License: Apache-2.0 Imports: 14 Imported by: 9

Documentation

Overview

Package snapshot manages metadata about snapshots stored in repository.

Index

Constants

View Source 
const (
	UsernameLabel = "username"
	HostnameLabel = "hostname"
	PathLabel     = "path"
)

Manifest labels identifying snapshots.

View Source 
const ManifestType = "snapshot"

ManifestType is the value of the "type" label for snapshot manifests.

Variables

View Source 
var ErrSnapshotNotFound = errors.Errorf("snapshot not found")

ErrSnapshotNotFound is returned when a snapshot is not found.

Functions

func GroupBySource 

func GroupBySource(manifests []*Manifest) [][]*Manifest

GroupBySource returns a slice of slices, such that each result item contains manifests from a single source.

func ListSnapshotManifests 

func ListSnapshotManifests(ctx context.Context, rep repo.Repository, src *SourceInfo, tags map[string]string) ([]manifest.ID, error)

ListSnapshotManifests returns the list of snapshot manifests for a given source or all sources if nil.

func SaveSnapshot 

func SaveSnapshot(ctx context.Context, rep repo.RepositoryWriter, man *Manifest) (manifest.ID, error)

SaveSnapshot persists given snapshot manifest and returns manifest ID.

func UpdateSnapshot added in v0.9.6 

func UpdateSnapshot(ctx context.Context, rep repo.RepositoryWriter, m *Manifest) error

UpdateSnapshot updates the snapshot by saving the provided data and deleting old manifest ID.

Types

type DirEntry 

type DirEntry struct {
	Name        string               `json:"name,omitempty"`
	Type        EntryType            `json:"type,omitempty"`
	Permissions Permissions          `json:"mode,omitempty"`
	FileSize    int64                `json:"size,omitempty"`
	ModTime     fs.UTCTimestamp      `json:"mtime,omitempty"`
	UserID      uint32               `json:"uid,omitempty"`
	GroupID     uint32               `json:"gid,omitempty"`
	ObjectID    object.ID            `json:"obj,omitempty"`
	DirSummary  *fs.DirectorySummary `json:"summ,omitempty"`
}

DirEntry represents a directory entry as stored in JSON stream.

func (*DirEntry) Clone added in v0.11.0 

func (e *DirEntry) Clone() *DirEntry

Clone returns a clone of the entry.

type DirManifest 

type DirManifest struct {
	StreamType string               `json:"stream"` // legacy
	Entries    []*DirEntry          `json:"entries"`
	Summary    *fs.DirectorySummary `json:"summary"`
}

DirManifest represents serialized contents of a directory. The entries are sorted lexicographically and summary only refers to properties of entries, so directory with the same contents always serializes to exactly the same JSON.

type EntryType 

type EntryType string

EntryType is a type of a filesystem entry. 

const (
	EntryTypeUnknown   EntryType = ""  // unknown type
	EntryTypeFile      EntryType = "f" // file
	EntryTypeDirectory EntryType = "d" // directory
	EntryTypeSymlink   EntryType = "s" // symbolic link
)

Supported entry types.

type HasDirEntry added in v0.4.0 

type HasDirEntry interface {
	DirEntry() *DirEntry
}

HasDirEntry is implemented by objects that have a DirEntry associated with them.

type HasDirEntryOrNil added in v0.9.0 

type HasDirEntryOrNil interface {
	DirEntryOrNil(ctx context.Context) (*DirEntry, error)
}

HasDirEntryOrNil is implemented by objects that may have a DirEntry stored in the object's corresponding shallow placeholder file.

type Manifest 

type Manifest struct {
	ID     manifest.ID `json:"id"`
	Source SourceInfo  `json:"source"`

	Description string          `json:"description"`
	StartTime   fs.UTCTimestamp `json:"startTime"`
	EndTime     fs.UTCTimestamp `json:"endTime"`

	Stats            Stats  `json:"stats,omitempty"`
	IncompleteReason string `json:"incomplete,omitempty"`

	RootEntry *DirEntry `json:"rootEntry"`

	RetentionReasons []string `json:"-"`

	Tags map[string]string `json:"tags,omitempty"`

	// usage, not persisted, values depend on walking snapshot list in a particular order
	StorageStats *StorageStats `json:"storageStats,omitempty"`

	// list of manually-defined pins which prevent the snapshot from being deleted.
	Pins []string `json:"pins,omitempty"`
}

Manifest represents information about a single point-in-time filesystem snapshot.

func FindSnapshotsByRootObjectID added in v0.7.2 

func FindSnapshotsByRootObjectID(ctx context.Context, rep repo.Repository, rootID object.ID) ([]*Manifest, error)

FindSnapshotsByRootObjectID returns the list of matching snapshots for a given rootID.

func ListSnapshots 

func ListSnapshots(ctx context.Context, rep repo.Repository, si SourceInfo) ([]*Manifest, error)

ListSnapshots lists all snapshots for a given source.

func LoadSnapshot added in v0.4.0 

func LoadSnapshot(ctx context.Context, rep repo.Repository, manifestID manifest.ID) (*Manifest, error)

LoadSnapshot loads and parses a snapshot with a given ID.

func LoadSnapshots 

func LoadSnapshots(ctx context.Context, rep repo.Repository, manifestIDs []manifest.ID) ([]*Manifest, error)

LoadSnapshots efficiently loads and parses a given list of snapshot IDs.

func SortByTime 

func SortByTime(manifests []*Manifest, reverse bool) []*Manifest

SortByTime returns a slice of manifests sorted by start time.

func (*Manifest) Clone added in v0.11.0 

func (m *Manifest) Clone() *Manifest

Clone returns a clone of the manifest.

func (*Manifest) RootObjectID 

func (m *Manifest) RootObjectID() object.ID

RootObjectID returns the ID of a root object.

func (*Manifest) UpdatePins added in v0.9.6 

func (m *Manifest) UpdatePins(add, remove []string) bool

UpdatePins updates pins in the provided manifest.

type Permissions 

type Permissions int

Permissions encapsulates UNIX permissions for a filesystem entry.

func (Permissions) MarshalJSON 

func (p Permissions) MarshalJSON() ([]byte, error)

MarshalJSON emits permissions as octal string.

func (*Permissions) UnmarshalJSON 

func (p *Permissions) UnmarshalJSON(b []byte) error

UnmarshalJSON parses octal permissions string from JSON.

type SourceInfo 

type SourceInfo struct {
	Host     string `json:"host"`
	UserName string `json:"userName"`
	Path     string `json:"path"`
}

SourceInfo represents the information about snapshot source.

func ListSources 

func ListSources(ctx context.Context, rep repo.Repository) ([]SourceInfo, error)

ListSources lists all snapshot sources in a given repository.

func ParseSourceInfo 

func ParseSourceInfo(path, hostname, username string) (SourceInfo, error)

ParseSourceInfo parses a given path in the context of given hostname and username and returns SourceInfo. The path may be bare (in which case it's interpreted as local path and canonicalized) or may be 'username@host:path' where path, username and host are not processed.

func (SourceInfo) String 

func (ssi SourceInfo) String() string

type Stats 

type Stats struct {
	// keep all int64 aligned because they will be atomically updated
	// +checkatomic
	TotalFileSize int64 `json:"totalSize"`
	// +checkatomic
	ExcludedTotalFileSize int64 `json:"excludedTotalSize"`

	// keep all int32 aligned because they will be atomically updated
	// +checkatomic
	TotalFileCount int32 `json:"fileCount"`
	// +checkatomic
	CachedFiles int32 `json:"cachedFiles"`
	// +checkatomic
	NonCachedFiles int32 `json:"nonCachedFiles"`

	// +checkatomic
	TotalDirectoryCount int32 `json:"dirCount"`

	// +checkatomic
	ExcludedFileCount int32 `json:"excludedFileCount"`
	// +checkatomic
	ExcludedDirCount int32 `json:"excludedDirCount"`

	// +checkatomic
	IgnoredErrorCount int32 `json:"ignoredErrorCount"`
	// +checkatomic
	ErrorCount int32 `json:"errorCount"`
}

Stats keeps track of snapshot generation statistics.

func (*Stats) AddExcluded 

func (s *Stats) AddExcluded(md fs.Entry)

AddExcluded adds the information about excluded file to the statistics.

type StorageStats added in v0.10.6 

type StorageStats struct {
	// amount of new unique data in this snapshot that wasn't there before.
	// note that this depends on ordering of snapshots.
	NewData      StorageUsageDetails `json:"newData,omitempty"`
	RunningTotal StorageUsageDetails `json:"runningTotal,omitempty"`
}

StorageStats encapsulates snapshot storage usage information and running totals.

type StorageUsageDetails added in v0.10.6 

type StorageUsageDetails struct {
	// number of bytes in all objects (ignoring content-level deduplication).
	// +checkatomic
	ObjectBytes int64 `json:"objectBytes"`

	// number of bytes in all unique contents (original).
	// +checkatomic
	OriginalContentBytes int64 `json:"originalContentBytes"`

	// number of bytes in all unique contents as stored in the repository.
	// +checkatomic
	PackedContentBytes int64 `json:"packedContentBytes"`

	// number of unique file objects.
	// +checkatomic
	FileObjectCount int32 `json:"fileObjects"`

	// number of unique objects.
	// +checkatomic
	DirObjectCount int32 `json:"dirObjects"`

	// number of unique contents.
	// +checkatomic
	ContentCount int32 `json:"contents"`
}

StorageUsageDetails provides details about snapshot storage usage.

Source Files

View all Source files

Directories

Path Synopsis
Package policy implements management of snapshot policies.
 Package policy implements management of snapshot policies.
Package restore manages restoring filesystem snapshots.
 Package restore manages restoring filesystem snapshots.
Package snapshotfs implements virtual filesystem on top of snapshots in repo.Repository.
 Package snapshotfs implements virtual filesystem on top of snapshots in repo.Repository.
Package snapshotgc implements garbage collection of contents that are no longer referenced through snapshots.
 Package snapshotgc implements garbage collection of contents that are no longer referenced through snapshots.
Package snapshotmaintenance provides helpers to run snapshot GC and low-level repository snapshotmaintenance.
 Package snapshotmaintenance provides helpers to run snapshot GC and low-level repository snapshotmaintenance.

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.