ratelimiter.go

type Repository struct {
	apiRateLimitter *rate.Limiter
}

func NewRepository() *Repository {
	return &Repository{
		apiRateLimitter: rate.NewLimiter(rate.Every(time.Second/time.Duration(config.GetInt("API_RPS"))), 1),
	}
}

func (r *Repository) Call(ctx context.Context) error {
  	if err := r.apiRateLimitter.Wait(ctx); err != nil {
		return &retry.RetryableErr{
				Err:    err,
				Detail: "waiting to call",
		}
	}
  
    ...
}