jsq

Documentation

Index

• type JoinShortestQueueBalancer
  • func NewJoinShortestQueueBalancer(balancees []url.URL, options JoinShortestQueueBalancerOptions, ...) *JoinShortestQueueBalancer
  • func (b *JoinShortestQueueBalancer) Add(u *url.URL) error
  • func (b *JoinShortestQueueBalancer) HighWatermark(u *url.URL) int
  • func (b *JoinShortestQueueBalancer) NumberOfBalancees() int
  • func (b *JoinShortestQueueBalancer) OutstandingRequests(u *url.URL) int
  • func (b *JoinShortestQueueBalancer) Remove(u *url.URL) error
  • func (b *JoinShortestQueueBalancer) RequestCount(u *url.URL) int
  • func (b *JoinShortestQueueBalancer) ServeHTTP(w http.ResponseWriter, req *http.Request)
• type JoinShortestQueueBalancerOptions

Types

type JoinShortestQueueBalancer

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

JoinShortestQueueBalancer is a bookkeeping struct

func NewJoinShortestQueueBalancer

func NewJoinShortestQueueBalancer(balancees []url.URL, options JoinShortestQueueBalancerOptions, next http.Handler) *JoinShortestQueueBalancer

NewJoinShortestQueueBalancer gives a new ChoiceOfBalancer back

func (*JoinShortestQueueBalancer) Add

func (b *JoinShortestQueueBalancer) Add(u *url.URL) error

Add a url to the loadbalancer

func (*JoinShortestQueueBalancer) HighWatermark

func (b *JoinShortestQueueBalancer) HighWatermark(u *url.URL) int

HighWatermark returns the most outstanding requests for a particular balancee

func (*JoinShortestQueueBalancer) NumberOfBalancees

func (b *JoinShortestQueueBalancer) NumberOfBalancees() int

NumberOfBalancees returns the number of balancees that this balancer knows about

func (*JoinShortestQueueBalancer) OutstandingRequests

func (b *JoinShortestQueueBalancer) OutstandingRequests(u *url.URL) int

OutstandingRequests returns the number of outstanding requests for a particular balancee

func (*JoinShortestQueueBalancer) Remove

func (b *JoinShortestQueueBalancer) Remove(u *url.URL) error

Remove a url from the loadbalancer.

func (*JoinShortestQueueBalancer) RequestCount

func (b *JoinShortestQueueBalancer) RequestCount(u *url.URL) int

RequestCount gives back the number of requests that have come into a particular URL

func (*JoinShortestQueueBalancer) ServeHTTP

func (b *JoinShortestQueueBalancer) ServeHTTP(w http.ResponseWriter, req *http.Request)

type JoinShortestQueueBalancerOptions

type JoinShortestQueueBalancerOptions struct {
	IsTesting bool
}