clean

package

v0.1.0 Latest Latest Go to latest Published: Dec 9, 2021 License: BSD-3-Clause Imports: 8 Imported by: 2

Details

This section is empty.

This section is empty.

func StartCleanTimer(ctx context.Context, data *TimerData) (<-chan struct{}, error)

type Cleaner interface {
	Clean(ID string) error
}

type CleanerGroup struct {
	Jobs []Cleaner
}

func (c *CleanerGroup) Clean(ID string) error

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

func NewFileCleaners(fs string, patterns []string) ([]*LocalFile, error)

func NewLocalFile(storagePath string, pattern string) (*LocalFile, error)

func (fs *LocalFile) Clean(ID string) error

type OldIDsProvider interface {
	GetExpired() ([]string, error)
}

OldIDsProvider return old ids for cleaning service

type TimerData struct {
	RunEvery    time.Duration
	Cleaner     Cleaner
	IDsProvider OldIDsProvider
}