timers.go


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

package main

import (
	"context"
	"time"
)

func FuncTicker(interval time.Duration, ctx context.Context, fn func(context.Context) error) func() error {
	return func() error {
		ticker := time.NewTicker(interval)
		defer ticker.Stop()
		for {
			select {
			case <-ctx.Done():
				return nil
			case <-ticker.C:
			}
			if err := fn(ctx); err != nil {
				return err
			}
		}
	}
}