cleaner

package
v0.0.0-...-6cf1bc9 Latest Latest
Warning

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

Go to latest
Published: Oct 13, 2016 License: AGPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Manifold

func Manifold(config ManifoldConfig) dependency.Manifold

Manifold returns a Manifold that encapsulates the cleanup worker.

func NewCleaner

func NewCleaner(st StateCleaner) (worker.Worker, error)

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 ManifoldConfig

type ManifoldConfig engine.APIManifoldConfig

ManifoldConfig describes the resources used by the cleanup worker.

type StateCleaner

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

Jump to

Keyboard shortcuts

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