Documentation
¶
Index ¶
- type GarbageCollectionCommits
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 ¶ added in v0.44.0
func (m *GarbageCollectionManager) GetAddressesLocation() string
func (*GarbageCollectionManager) GetCommitsCSVLocation ¶ added in v0.44.0
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
Click to show internal directories.
Click to hide internal directories.