limiter

Documentation

Index

• type ServerLimiter
  • func NewServerLimiter(servers []string, l int) *ServerLimiter
  • func (sl ServerLimiter) Capacity() int
  • func (sl ServerLimiter) Enter(ctx context.Context, s string) error
  • func (sl ServerLimiter) Leave(ctx context.Context, s string)

Types

type ServerLimiter

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

ServerLimiter provides interface to limit amount of requests

func NewServerLimiter

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

NewServerLimiter creates a limiter for specific servers list.

func (ServerLimiter) Capacity

func (sl ServerLimiter) Capacity() int

func (ServerLimiter) Enter

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

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

func (ServerLimiter) Leave

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

Frees a slot in limiter