refresh

package

v1.5.1 Latest Latest Go to latest Published: May 10, 2026 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Clock interface {
	Now() time.Time
}

type ProviderLister interface {
	List(ctx context.Context) ([]provider.Provider, error)
}

type RefreshFunc func(ctx context.Context, providerID int64) error

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

func NewScheduler(repo ProviderLister, refresh RefreshFunc, interval time.Duration) *Scheduler

func (s *Scheduler) RunOnce(ctx context.Context)

func (s *Scheduler) Start(ctx context.Context)

func (s *Scheduler) WithClock(c Clock) *Scheduler

func (s *Scheduler) WithLogger(l *log.Logger) *Scheduler

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

func NewService(providers *provider.Repository, fetcher *fetch.Client) *Service

func (s *Service) RefreshProvider(ctx context.Context, providerID int64) error