cleaner

Documentation

Index

• func NewCleaner(st StateCleaner) worker.Worker
• type Cleaner
  • func (c *Cleaner) Handle(_ <-chan struct{}) error
  • func (c *Cleaner) SetUp() (watcher.NotifyWatcher, error)
  • func (c *Cleaner) TearDown() error
• type StateCleaner

Functions

func NewCleaner

func NewCleaner(st StateCleaner) worker.Worker

NewCleaner returns a worker.Worker that runs state.Cleanup() if the CleanupWatcher signals documents marked for deletion.

Types

type Cleaner

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

Cleaner is responsible for cleaning up the state.

func (*Cleaner) Handle

func (c *Cleaner) Handle(_ <-chan struct{}) error

func (*Cleaner) SetUp

func (c *Cleaner) SetUp() (watcher.NotifyWatcher, error)

func (*Cleaner) TearDown

func (c *Cleaner) TearDown() error

type StateCleaner

type StateCleaner interface {
	Cleanup() error
	WatchCleanups() (watcher.NotifyWatcher, error)
}