manager

type IDGenerator ¶

type IDGenerator func(string) int

type Manager ¶

type Manager struct {
	Quit chan bool // Channel to signal that the manager is done
	// contains filtered or unexported fields
}

func NewManager() *Manager

func (m *Manager) AddUnit(unit WorkUnit, name string) *WorkUnitManager

func (m *Manager) Shutdown()

func (m *Manager) ShutdownOn(sig ...os.Signal)

func (m *Manager) Start()

func (m *Manager) Units() map[string]WorkUnit

type UnitManager ¶

type UnitManager interface {
	ShouldStop() <-chan bool
	Done()
	Panic(any)

	RequestShutdown()
}

The UnitManager interface is used to manage a unit of work. The ShouldStop method returns a channel that will be closed when the unit should stop. The Done method should be called when the unit is done.

type WorkUnit ¶

type WorkUnit interface {
	Run(UnitManager)
}

The WorkUnit interface is used to define a unit of work. The Run method will be called in a goroutine.

type WorkUnitManager ¶

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

func (w *WorkUnitManager) Done()

func (w *WorkUnitManager) Panic(val any)

func (m *WorkUnitManager) RequestShutdown()

func (wu *WorkUnitManager) SetRecoverable()

func (w *WorkUnitManager) ShouldStop() <-chan bool