retention

Documentation

Index

• type GCStartingPoint
• type GCStartingPointIterator
  • func NewGCStartingPointIterator(commitIterator graveler.CommitIterator, branchIterator graveler.BranchIterator) *GCStartingPointIterator
  • func (sp *GCStartingPointIterator) Close()
  • func (sp *GCStartingPointIterator) Err() error
  • func (sp *GCStartingPointIterator) Next() bool
  • func (sp *GCStartingPointIterator) Value() *GCStartingPoint
• type GarbageCollectionCommits
  • func GetGarbageCollectionCommits(ctx context.Context, startingPointIterator *GCStartingPointIterator, ...) (*GarbageCollectionCommits, error)
• type GarbageCollectionManager
  • func NewGarbageCollectionManager(db db.Database, blockAdapter block.Adapter, refManager graveler.RefManager, ...) *GarbageCollectionManager
  • func (m *GarbageCollectionManager) GetAddressesLocation(sn graveler.StorageNamespace) (string, error)
  • func (m *GarbageCollectionManager) GetCommitsCSVLocation(runID string, sn graveler.StorageNamespace) (string, error)
  • func (m *GarbageCollectionManager) GetRules(ctx context.Context, storageNamespace graveler.StorageNamespace) (*graveler.GarbageCollectionRules, error)
  • func (m *GarbageCollectionManager) GetRunExpiredCommits(ctx context.Context, storageNamespace graveler.StorageNamespace, runID string) ([]graveler.CommitID, error)
  • func (m *GarbageCollectionManager) SaveGarbageCollectionCommits(ctx context.Context, storageNamespace graveler.StorageNamespace, ...) (string, error)
  • func (m *GarbageCollectionManager) SaveRules(ctx context.Context, storageNamespace graveler.StorageNamespace, ...) error
• type RepositoryCommitGetter
  • func (r *RepositoryCommitGetter) GetCommit(ctx context.Context, commitID graveler.CommitID) (*graveler.Commit, error)

Types

type GCStartingPoint

type GCStartingPoint struct {
	BranchID graveler.BranchID
	CommitID graveler.CommitID
}

A GCStartingPoint represents a commit from which the GC algorithm should start scanning. It could be either a branch HEAD, or a dangling commit. The CommitID field is always set, while BranchID is set only if the commit is a branch HEAD.

type GCStartingPointIterator

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

GCStartingPointIterator combines a branch iterator and a commit iterator. Both are assumed to be sorted and to contain no duplicates. Each returned GCStartingPoint object contains the commit id. If the entry came from the branch iterator, it also contains the branch id. Commits appearing in both iterators appear only once and include the branch id. Closing this iterator will close the two internal iterators.

func NewGCStartingPointIterator

func NewGCStartingPointIterator(commitIterator graveler.CommitIterator, branchIterator graveler.BranchIterator) *GCStartingPointIterator

func (*GCStartingPointIterator) Close

func (sp *GCStartingPointIterator) Close()

func (*GCStartingPointIterator) Err

func (sp *GCStartingPointIterator) Err() error

func (*GCStartingPointIterator) Next

func (sp *GCStartingPointIterator) Next() bool

func (*GCStartingPointIterator) Value

func (sp *GCStartingPointIterator) Value() *GCStartingPoint

type GarbageCollectionCommits

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

func GetGarbageCollectionCommits

func GetGarbageCollectionCommits(ctx context.Context, startingPointIterator *GCStartingPointIterator, commitGetter *RepositoryCommitGetter, rules *graveler.GarbageCollectionRules, previouslyExpired []graveler.CommitID) (*GarbageCollectionCommits, error)

GetGarbageCollectionCommits returns the sets of expired and active commits, according to the repository's garbage collection rules. See https://github.com/treeverse/lakeFS/issues/1932 for more details. Upon completion, the given startingPointIterator is closed.

type GarbageCollectionManager

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

func NewGarbageCollectionManager

func NewGarbageCollectionManager(db db.Database, blockAdapter block.Adapter, refManager graveler.RefManager, committedBlockStoragePrefix string) *GarbageCollectionManager

func (*GarbageCollectionManager) GetAddressesLocation

func (m *GarbageCollectionManager) GetAddressesLocation(sn graveler.StorageNamespace) (string, error)

func (*GarbageCollectionManager) GetCommitsCSVLocation

func (m *GarbageCollectionManager) GetCommitsCSVLocation(runID string, sn graveler.StorageNamespace) (string, error)

func (*GarbageCollectionManager) GetRules

func (m *GarbageCollectionManager) GetRules(ctx context.Context, storageNamespace graveler.StorageNamespace) (*graveler.GarbageCollectionRules, error)

func (*GarbageCollectionManager) GetRunExpiredCommits

func (m *GarbageCollectionManager) GetRunExpiredCommits(ctx context.Context, storageNamespace graveler.StorageNamespace, runID string) ([]graveler.CommitID, error)

func (*GarbageCollectionManager) SaveGarbageCollectionCommits

func (m *GarbageCollectionManager) SaveGarbageCollectionCommits(ctx context.Context, storageNamespace graveler.StorageNamespace, repositoryID graveler.RepositoryID, rules *graveler.GarbageCollectionRules, previouslyExpiredCommits []graveler.CommitID) (string, error)

func (*GarbageCollectionManager) SaveRules

func (m *GarbageCollectionManager) SaveRules(ctx context.Context, storageNamespace graveler.StorageNamespace, rules *graveler.GarbageCollectionRules) error

type RepositoryCommitGetter

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

func (*RepositoryCommitGetter) GetCommit

func (r *RepositoryCommitGetter) GetCommit(ctx context.Context, commitID graveler.CommitID) (*graveler.Commit, error)