queueing

Documentation

Index

• Constants
• Variables
• func QueueRequests(name string, h http.Handler, limit, queueLimit uint, ...) http.Handler
• type Queue
  • func (s *Queue) Acquire() (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(name string, h http.Handler, limit, queueLimit uint, queueTimeout time.Duration) http.Handler

QueueRequests creates a new request queue name specifies the name of queue, used to label Prometheus metrics

Don't call QueueRequests twice with the same name argument!

h specifies a http.Handler which will handle the queue requests limit specifies number of requests run concurrently queueLimit specifies maximum number of requests that can be queued queueTimeout specifies the time limit of storing the request in the queue

Types

type Queue

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

func (*Queue) Acquire

func (s *Queue) Acquire() (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