limiter

type LimiterStore ¶

type LimiterStore interface {
	// GetLimiter возвращает WaitLimiter для дальнейшего вызова его в запросе Tripper'а
	// На вход получет запрос от executor'а, по которому можно определить, например
	// токен доступа, по которому делается запрос, тем самым, создав лимитер под каждый
	// токен отдельно
	GetLimiter(*request.Request) (WaitLimiter, error)
}

LimiterStore это интерфейс для хранения всех лимитеров Вы можете реализовать свой собственный store, чтобы точнее контролировать лимитирование запросов, а также используемую оперативную память

func NewLimiterStoreTtlCache(
	rps int,
	limiterExpiration,
	cleanupCacheInterval time.Duration,
) LimiterStore

type LimiterTripper ¶

type LimiterTripper http.RoundTripper

LimiterTripper type

func New(rps int, limiterExpiration, cacheCleanupInterval time.Duration) LimiterTripper

func NewWithStore(store LimiterStore) LimiterTripper

type Tripper ¶

type Tripper struct {
	Tripper http.RoundTripper
	// contains filtered or unexported fields
}

Объект, хранящий в себе все лимитеры запросов на конкретный токен. Чтобы не засорять память, в случае, если у вас много (сотни или тысячи) различных токенов, в этом пакете используется кеширование лимитеров. Лимитеры токенов регулярно удаляются из памяти.

func (v *Tripper) RoundTrip(req *http.Request) (*http.Response, error)

type WaitLimiter ¶

type WaitLimiter interface {
	// Wait executes each request
	Wait(ctx context.Context) error
}

var DefaultLimiter WaitLimiter = &emptyLimiter{}