monitor

type Worker ¶

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

Worker records completed work, not a separate heartbeat that could keep reporting healthy while the real worker is stuck.

func NewWorker(enabled bool, budget time.Duration) *Worker

func (m *Worker) Begin(now time.Time)

func (m *Worker) End(now time.Time, err error)

func (m *Worker) Snapshot(now time.Time) ranjit.WorkerStatus

func (m *Worker) Stop()