Implement Scheduler component

[swift1337]

Don't confuse it with cctx scheduling

We have a lot of repeated logic where we want to run certain tasks in the background on a predefined interval. We might also want to skip certain runs (e.g., app.IsOutboundObservationEnabled()). Additionally, the interval can be changed dynamically.

For these use cases, we have bg and ticker packages, but we lack a combined component that also supports metric reporting per run (e.g., last run, latency, outcome, ...). Thus, it's very handy to have something like this:

type Task interface {
	// ...
}

type Scheduler interface {
	Register(Task, Opts...)
}

Each ObserverSigner would receive Scheduler in Start(ctx context.context, s Scheduler) error and register its jobs there

func (os *Solana) Start(ctx context.Context, s *scheduler.Scheduler) error {
   s.Register(os.observer.ObserverInbound, /* options... */)
   s.Register(os.observer.ObserveGasPrice, /* options... */)
   s.Register(os.ScheduleOutbounds, /* options... */)
   
   return nil
}

Tasks

Preview Give feedback

1. Scheduler
2. Scheduler groups
3. Test Coverage
4. Automatic metrics provisioning