periodictask

type Config struct {
	TaskInterval    time.Duration
	TaskTimeout     time.Duration
	RunnerFrequency time.Duration
}

type Coordinator interface {
	locker.Locker

	LastRunTimestamp(
		ctx context.Context,
		key string,
	) (*time.Time, error)

	UpdateLastRunTimestamp(
		ctx context.Context,
		key string,
	) error
}

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