cleanup

package
v1.1.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 30, 2026 License: MIT Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Options

type Options struct {
	DB        *ent.Client
	Storage   storage.Adapter
	Config    config.CleanupConfig
	Lifecycle *storagelifecycle.Service
	Now       func() time.Time
	Logger    *zerolog.Logger
	Metrics   metrics.Recorder
}

type Runner

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

func NewRunner

func NewRunner(service *Service, logger zerolog.Logger, storageReady <-chan struct{}) *Runner

func (*Runner) Run added in v1.1.1

func (r *Runner) Run(ctx context.Context)

type Service

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

func NewService

func NewService(options Options) *Service

func (*Service) RunCacheEntries

func (s *Service) RunCacheEntries(ctx context.Context) (int, error)

func (*Service) RunOrphanedStorage added in v1.1.1

func (s *Service) RunOrphanedStorage(ctx context.Context) (int, error)

func (*Service) RunParts

func (s *Service) RunParts(ctx context.Context) (int, error)

func (*Service) RunPendingStorageLocations added in v1.1.1

func (s *Service) RunPendingStorageLocations(ctx context.Context) (int, error)

func (*Service) RunReaderLeases added in v1.1.1

func (s *Service) RunReaderLeases(ctx context.Context) (int, error)

func (*Service) RunStorageDeletions added in v1.0.6

func (s *Service) RunStorageDeletions(ctx context.Context) (int, error)

func (*Service) RunStorageLocations

func (s *Service) RunStorageLocations(ctx context.Context) (int, error)

func (*Service) RunUploads

func (s *Service) RunUploads(ctx context.Context) (int, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL