reaper

var Component = &component.Component{
	Name: "cluster.reaper",
	Dependencies: component.Components{
		reaper.Component,
		repeater.Component,
		discovery.Component,
	},
	Init: component.StepFunc(func(container container.Container) error {
		return container.Provide(NewReaper)
	}),
	Execute: component.StepFunc(func(container container.Container) error {
		return container.Invoke(func(r repeater.Repeater, m cluster.Manager, reaperConfig reaper.Config, reaper *Reaper) error {
			m.OnAddPeer().Subscribe(reaper.onAddPeer)
			m.OnDeletingPeer().Subscribe(reaper.onDeletingPeer)

			return r.AddProcess(repeater.NewTask("cluster.reaper", reaperConfig.Delay, reaper.Process))
		})
	}),
}