retention

Documentation

Index

• type GarbageCollectionCommits
  • func GetGarbageCollectionCommits(ctx context.Context, branchIterator graveler.BranchIterator, ...) (*GarbageCollectionCommits, error)
• type GarbageCollectionManager
  • func NewGarbageCollectionManager(blockAdapter block.Adapter, refManager graveler.RefManager, ...) *GarbageCollectionManager
  • func (m *GarbageCollectionManager) GetAddressesLocation() string
  • func (m *GarbageCollectionManager) GetCommitsCSVLocation(runID string) string
  • 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 GarbageCollectionCommits

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

func GetGarbageCollectionCommits

func GetGarbageCollectionCommits(ctx context.Context, branchIterator graveler.BranchIterator, 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.

type GarbageCollectionManager

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

func NewGarbageCollectionManager

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

func (*GarbageCollectionManager) GetAddressesLocation

func (m *GarbageCollectionManager) GetAddressesLocation() string

func (*GarbageCollectionManager) GetCommitsCSVLocation

func (m *GarbageCollectionManager) GetCommitsCSVLocation(runID string) string

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)