refresher

Documentation

Index

• func OnErrorLog(logger *log.Logger) func(error, time.Time)
• type HandlerFunc
• type Refresher
  • func NewRefresher[T any](logger *log.Logger, tickerDuration time.Duration, handler HandlerFunc[T], ...) *Refresher[T]
  • func (r *Refresher[T]) Data(ctx context.Context) T
  • func (r *Refresher[T]) Stop()

Functions

func OnErrorLog

func OnErrorLog(logger *log.Logger) func(error, time.Time)

Types

type HandlerFunc

type HandlerFunc[T any] func(context.Context) (T, error)

type Refresher

type Refresher[T any] struct {
	Logger *log.Logger
	// contains filtered or unexported fields
}

func NewRefresher

func NewRefresher[T any](logger *log.Logger, tickerDuration time.Duration, handler HandlerFunc[T], onErrorFunc func(error, time.Time)) *Refresher[T]

func (*Refresher[T]) Data

func (r *Refresher[T]) Data(ctx context.Context) T

func (*Refresher[T]) Stop

func (r *Refresher[T]) Stop()