ratelimit

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

type BackendError struct {
	Source error
}

type ContextCancelled struct {
}

type InMemoryBackendLimiter struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type InvalidUnitError struct {
	BadUnit int
}

type LimitReached struct {
}

type RateLimiter interface {

	//Take given units
	//Returns LimitReached if limit reached
	//Returns InvalidUnitError if unit <= 0 or > the max limit
	Take(ctx context.Context, unit int) error

	//Limit gets the current limit
	Limit() int

	//SetLimit sets the limit. 0 means there is no limit
	//Returns InvalidUnitError if newLimit < 0
	SetLimit(newLimit int) error
}