taskreaper

Documentation

Index

• type TaskReaper
  • func New(store *store.MemoryStore) *TaskReaper
  • func (tr *TaskReaper) Run()
  • func (tr *TaskReaper) Stop()

Types

type TaskReaper

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

A TaskReaper deletes old tasks when more than TaskHistoryRetentionLimit tasks exist for the same service/instance or service/nodeid combination.

func New

func New(store *store.MemoryStore) *TaskReaper

New creates a new TaskReaper.

func (*TaskReaper) Run

func (tr *TaskReaper) Run()

Run is the TaskReaper's main loop.

func (*TaskReaper) Stop

func (tr *TaskReaper) Stop()

Stop stops the TaskReaper and waits for the main loop to exit.