algorithm

Feb 3, 2025

Changes in this version

+ type SessionAffinity struct

+ func NewSessionAffinity() *SessionAffinity

+ func (ss *SessionAffinity) Name() string

+ func (ss *SessionAffinity) NextServer(pool ServerPool, r *http.Request, w *http.ResponseWriter) *Server

Jan 28, 2025

Changes in this version

+ type StickySession struct

+ func NewStickySession() *StickySession

+ func (ss *StickySession) Name() string

+ func (ss *StickySession) NextServer(pool ServerPool, r *http.Request, w *http.ResponseWriter) *Server

Nov 14, 2024

Changes in this version

+ type AdaptiveLoadBalancer struct

+ func NewAdaptiveLoadBalancer() *AdaptiveLoadBalancer

+ func (alb *AdaptiveLoadBalancer) NextServer(pool ServerPool, r *http.Request) *Server

+ func (alb *AdaptiveLoadBalancer) RecordMetrics(algorithm string, responseTime time.Duration, isError bool)

+ type Algorithm interface

+ Name func() string

+ NextServer func(pool ServerPool, r *http.Request) *Server

+ func CreateAlgorithm(name string) Algorithm

+ type AlgorithmStats struct

+ ErrorCount int

+ RequestCount int

+ ResponseTimes []time.Duration

+ type BoundedLeastConnections struct

+ func NewBoundedLeastConnections(sampleSize int) *BoundedLeastConnections

+ func (blc *BoundedLeastConnections) Name() string

+ func (blc *BoundedLeastConnections) NextServer(pool ServerPool, _ *http.Request) *Server

+ type IPHash struct

+ func (ih *IPHash) Name() string

+ func (ih *IPHash) NextServer(pool ServerPool, r *http.Request) *Server

+ type LeastConnections struct

+ func (lc *LeastConnections) Name() string

+ func (lc *LeastConnections) NextServer(pool ServerPool, _ *http.Request) *Server

+ type LeastResponseTime struct

+ func NewLeastResponseTime() *LeastResponseTime

+ func (lrt *LeastResponseTime) Name() string

+ func (lrt *LeastResponseTime) NextServer(pool ServerPool, _ *http.Request) *Server

+ func (lrt *LeastResponseTime) UpdateResponseTime(serverURL string, duration time.Duration)

+ type RoundRobin struct

+ func (rr *RoundRobin) Name() string

+ func (rr *RoundRobin) NextServer(pool ServerPool, _ *http.Request) *Server

+ type Server struct

+ Alive bool

+ ConnectionCount int32

+ CurrentWeight int

+ LastResponseTime time.Duration

+ MaxConnections int32

+ URL string

+ Weight int

+ func (b *Server) CanAcceptConnection() bool

+ type ServerPool interface

+ GetBackends func() []*Server

+ GetCurrentIndex func() uint64

+ SetCurrentIndex func(idx uint64)

+ type WeightedRoundRobin struct

+ func (wrr *WeightedRoundRobin) Name() string

+ func (wrr *WeightedRoundRobin) NextServer(pool ServerPool, _ *http.Request) *Server