clean

package

v1.4.0 Latest Latest Go to latest Published: Mar 1, 2025 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)

StartCleanTimer starts timer in loop for doing clean tasks

type Cleaner interface {
	Clean(ctx context.Context, ID string) error
}

Cleaner interface for one Clean job

type CleanerGroup struct {
	Jobs []Cleaner
}

CleanerGroup is a list of cleaners

func (c *CleanerGroup) Clean(ctx context.Context, ID string) error

Clean runs all cleaners in the group

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

LocalFile is a struct for local file cleaner

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

NewFileCleaners creates file cleaners based on provided paths

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

NewLocalFile creates file cleaner

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

Clean removes files matching the pattern

type OldIDsProvider interface {
	GetExpired(ctx context.Context) ([]string, error)
}

OldIDsProvider return old ids for cleaning service

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

TimerData keeps clean timer info