48 lines
1.0 KiB
Go
48 lines
1.0 KiB
Go
|
package scheduler
|
||
|
|
|
||
|
|
import (
|
||
|
|
"context"
|
||
|
|
"database/sql"
|
||
|
|
"time"
|
||
|
|
|
||
|
|
logging "github.com/ipfs/go-log/v2"
|
||
|
|
)
|
||
|
|
|
||
|
|
var log = logging.Logger("scheduler")
|
||
|
|
|
||
|
|
// Scheduler manages the execution of jobs triggered
|
||
|
|
// by tickers. Not externally configuable at runtime.
|
||
|
|
type Scheduler struct {
|
||
|
|
db *sql.DB
|
||
|
|
}
|
||
|
|
|
||
|
|
// PrepareScheduler returns a ready-to-run Scheduler
|
||
|
|
func PrepareScheduler(db *sql.DB) *Scheduler {
|
||
|
|
return &Scheduler{db}
|
||
|
|
}
|
||
|
|
|
||
|
|
// Start the scheduler jobs at the defined intervals
|
||
|
|
func (s *Scheduler) Start(ctx context.Context) {
|
||
|
|
log.Debug("Starting Scheduler")
|
||
|
|
|
||
|
|
go func() {
|
||
|
|
// run once on start after schema has initialized
|
||
|
|
time.Sleep(5 * time.Second)
|
||
|
|
if err := refreshTopMinerByBaseReward(ctx, s.db); err != nil {
|
||
|
|
log.Errorf(err.Error())
|
||
|
|
}
|
||
|
|
refreshTopMinerCh := time.NewTicker(6 * time.Hour)
|
||
|
|
defer refreshTopMinerCh.Stop()
|
||
|
|
for {
|
||
|
|
select {
|
||
|
|
case <-refreshTopMinerCh.C:
|
||
|
|
if err := refreshTopMinerByBaseReward(ctx, s.db); err != nil {
|
||
|
|
log.Errorf(err.Error())
|
||
|
|
}
|
||
|
|
case <-ctx.Done():
|
||
|
|
return
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}()
|
||
|
|
}
|