queueing

Documentation

Index

• Constants
• Variables
• func QueueRequests(h http.Handler, limit, queueLimit uint, queueTimeout time.Duration) http.Handler
• type Queue
  • func NewQueue(limit, queueLimit uint) *Queue
  • func (s *Queue) Acquire(timeout time.Duration) (err error)
  • func (s *Queue) Release()

Constants

const DefaultTimeout = 30 * time.Second

Variables

var ErrQueueingTimedout = &errQueueingTimedout{errors.New("queueing timedout")}

var ErrTooManyRequests = &errTooManyRequests{errors.New("too many requests queued")}

Functions

func QueueRequests

func QueueRequests(h http.Handler, limit, queueLimit uint, queueTimeout time.Duration) http.Handler

Types

type Queue

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

func NewQueue

func NewQueue(limit, queueLimit uint) *Queue

NewQueue creates a new queue limit specifies number of requests run concurrently queueLimit specifies maximum number of requests that can be queued if the number of requests is above the limit

func (*Queue) Acquire

func (s *Queue) Acquire(timeout time.Duration) (err error)

Acquire takes one slot from the Queue and returns when a request should be processed it allows up to (limit) of requests running at a time it allows to queue up to (queue-limit) requests

func (*Queue) Release

func (s *Queue) Release()

Release marks the finish of processing of requests It triggers next request to be processed if it's in queue