file_cleaner

Documentation

Index

• Variables
• type FileCleaner
  • func NewFileCleaner(indexDir string, indexingLock *indexing_lock.IndexingLock) *FileCleaner
  • func (c *FileCleaner) Clean(ctx context.Context) error
  • func (c *FileCleaner) Init() error
  • func (c *FileCleaner) MarkRepoForDeletion(repoID uint32) error
  • func (c *FileCleaner) RemoveNodeUUID() error
  • func (c *FileCleaner) RemoveShardsFor(repoID uint32) error
  • func (c *FileCleaner) StartCleanInterval(ctx context.Context, interval time.Duration) error
  • func (c *FileCleaner) Truncate() error
  • func (c *FileCleaner) TruncateExceptUUID() error

Variables

var (
	IDRegex = regexp.MustCompile(`^\d+`)
)

Types

type FileCleaner

type FileCleaner struct {
	IndexDir     string
	Ticker       *time.Ticker
	IndexingLock *indexing_lock.IndexingLock
	// contains filtered or unexported fields
}

func NewFileCleaner

func NewFileCleaner(indexDir string, indexingLock *indexing_lock.IndexingLock) *FileCleaner

func (*FileCleaner) Clean

func (c *FileCleaner) Clean(ctx context.Context) error

func (*FileCleaner) Init

func (c *FileCleaner) Init() error

func (*FileCleaner) MarkRepoForDeletion

func (c *FileCleaner) MarkRepoForDeletion(repoID uint32) error

func (*FileCleaner) RemoveNodeUUID

func (c *FileCleaner) RemoveNodeUUID() error

func (*FileCleaner) RemoveShardsFor

func (c *FileCleaner) RemoveShardsFor(repoID uint32) error

func (*FileCleaner) StartCleanInterval

func (c *FileCleaner) StartCleanInterval(ctx context.Context, interval time.Duration) error

func (*FileCleaner) Truncate

func (c *FileCleaner) Truncate() error

func (*FileCleaner) TruncateExceptUUID

func (c *FileCleaner) TruncateExceptUUID() error