fetcher

Documentation

Index

• type Cacher
  • func NewCacher(f Fetcher) *Cacher
  • func (c *Cacher) AutoUpdate(ctx context.Context, interval time.Duration)
  • func (c *Cacher) Fetch(ctx context.Context, dataType int) ([]apiclient.APIResponse, error)
• type Fetcher
• type Limiter
  • func NewLimiter(fetcher Fetcher, maxParallel int64) *Limiter
  • func (l *Limiter) Fetch(ctx context.Context, dataType int) (results []apiclient.APIResponse, err error)
  • func (l *Limiter) GetLastUpdated(ctx context.Context, dataType int) (lastUpdated time.Time, err error)

Types

type Cacher

type Cacher struct {
	Fetcher
	// contains filtered or unexported fields
}

func NewCacher

func NewCacher(f Fetcher) *Cacher

func (*Cacher) AutoUpdate

func (c *Cacher) AutoUpdate(ctx context.Context, interval time.Duration)

func (*Cacher) Fetch

func (c *Cacher) Fetch(ctx context.Context, dataType int) ([]apiclient.APIResponse, error)

type Fetcher

type Fetcher interface {
	Fetch(ctx context.Context, dataType int) ([]apiclient.APIResponse, error)
	GetLastUpdated(ctx context.Context, dataType int) (time.Time, error)
	DataTypes() map[int]string
}

Fetcher retrieves data from an API

type Limiter

type Limiter struct {
	Fetcher
	// contains filtered or unexported fields
}

func NewLimiter

func NewLimiter(fetcher Fetcher, maxParallel int64) *Limiter

func (*Limiter) Fetch

func (l *Limiter) Fetch(ctx context.Context, dataType int) (results []apiclient.APIResponse, err error)

func (*Limiter) GetLastUpdated

func (l *Limiter) GetLastUpdated(ctx context.Context, dataType int) (lastUpdated time.Time, err error)