Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrLimit = errors.New("limit exceeded")
Functions ¶
This section is empty.
Types ¶
type KeyConcurrentLimit ¶
type KeyConcurrentLimit struct {
// contains filtered or unexported fields
}
func NewLimit ¶
func NewLimit() *KeyConcurrentLimit
func (*KeyConcurrentLimit) Acquire ¶
func (s *KeyConcurrentLimit) Acquire(key string, limit int64) error
func (*KeyConcurrentLimit) Get ¶
func (s *KeyConcurrentLimit) Get(key string) int64
func (*KeyConcurrentLimit) Release ¶
func (s *KeyConcurrentLimit) Release(key string)
func (*KeyConcurrentLimit) Running ¶
func (s *KeyConcurrentLimit) Running() int
Click to show internal directories.
Click to hide internal directories.