cleaner

Documentation

Index

• type Cleaner
  • func NewDbCleaner(cfg CleanerConfig) Cleaner
• type CleanerConfig
• type PackageCleanerEvent
• type RepoEventCleaner
• type SenderStatus

Types

type Cleaner

type Cleaner interface {
	Start()
	Close()
}

func NewDbCleaner

func NewDbCleaner(cfg CleanerConfig) Cleaner

type CleanerConfig

type CleanerConfig struct {
	WorkerCount      int
	CleanerBatchSize uint64
	Repo             RepoEventCleaner
	CleanerChannel   <-chan PackageCleanerEvent
	CleanupInterval  time.Duration
	GaugeSubFunc     func(float64)
}

type PackageCleanerEvent

type PackageCleanerEvent struct {
	Status  SenderStatus
	EventID uint64
}

type RepoEventCleaner

type RepoEventCleaner interface {
	Unlock(eventIDs []uint64) error
	Remove(eventIDs []uint64) error
}

type SenderStatus

type SenderStatus uint8

const (
	Ok SenderStatus = iota
	Fail
)