limiter

package

v0.13.0-rc.2 Latest Latest Go to latest Published: May 17, 2020 License: BSD-2-Clause Imports: 2 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type NoopLimiter struct {
}

ServerLimiter provides interface to limit amount of requests

func (l NoopLimiter) Capacity() int

func (l NoopLimiter) Enter(ctx context.Context, s string) error

Enter claims one of free slots or blocks until there is one.

func (l NoopLimiter) Leave(ctx context.Context, s string)

Frees a slot in limiter

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

ServerLimiter provides interface to limit amount of requests

func (sl RealLimiter) Capacity() int

func (sl RealLimiter) Enter(ctx context.Context, s string) error

Enter claims one of free slots or blocks until there is one.

func (sl RealLimiter) Leave(ctx context.Context, s string)

Frees a slot in limiter

type ServerLimiter interface {
	Capacity() int
	Enter(ctx context.Context, s string) error
	Leave(ctx context.Context, s string)
}

func NewServerLimiter(servers []string, l int) ServerLimiter

NewServerLimiter creates a limiter for specific servers list.

type SimpleLimiter chan struct{}

func NewSimpleLimiter(l int) SimpleLimiter

func (l SimpleLimiter) Enter()

func (l SimpleLimiter) Leave()