Documentation
¶
Index ¶
- type ReloadableRateLimiter
- func (r *ReloadableRateLimiter) Accept()
- func (r *ReloadableRateLimiter) QPS() float32
- func (r *ReloadableRateLimiter) Set(limiter flowcontrol.RateLimiter)
- func (r *ReloadableRateLimiter) Stop()
- func (r *ReloadableRateLimiter) TryAccept() bool
- func (r *ReloadableRateLimiter) Wait(ctx context.Context) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ReloadableRateLimiter ¶
type ReloadableRateLimiter struct {
// contains filtered or unexported fields
}
func NewReloadableRateLimiter ¶
func NewReloadableRateLimiter(limiter flowcontrol.RateLimiter) *ReloadableRateLimiter
func (*ReloadableRateLimiter) Accept ¶
func (r *ReloadableRateLimiter) Accept()
func (*ReloadableRateLimiter) QPS ¶
func (r *ReloadableRateLimiter) QPS() float32
func (*ReloadableRateLimiter) Set ¶
func (r *ReloadableRateLimiter) Set(limiter flowcontrol.RateLimiter)
func (*ReloadableRateLimiter) Stop ¶
func (r *ReloadableRateLimiter) Stop()
func (*ReloadableRateLimiter) TryAccept ¶
func (r *ReloadableRateLimiter) TryAccept() bool
Source Files
Click to show internal directories.
Click to hide internal directories.