proxies

package

Go to main page

Versions in this module

v2

v2.7.3

Mar 26, 2024

Changes in this version

type ServerPoolBaseSpec

+ SetUpstreamHost bool

v2.7.2

Mar 11, 2024

v2.7.1

Feb 22, 2024

v2.7.0

Dec 29, 2023

v2.6.4

Dec 4, 2023

Changes in this version

type HealthCheckSpec

+ func (s *HealthCheckSpec) GetInterval() time.Duration

+ func (s *HealthCheckSpec) GetTimeout() time.Duration

type HealthChecker

+ BaseSpec func() HealthCheckSpec

v2.6.3

Nov 23, 2023

Changes in this version

+ const LoadBalancePolicyCookieHash

v2.6.2

Oct 19, 2023

v2.6.1

Sep 1, 2023

v2.6.0

Aug 16, 2023

v2.5.3

Aug 2, 2023

v2.5.2

Jul 28, 2023

v2.5.1

Jul 24, 2023

Changes in this version

+ const KeyLen

+ const LoadBalancePolicyHeaderHash

+ const LoadBalancePolicyIPHash

+ const LoadBalancePolicyRandom

+ const LoadBalancePolicyRoundRobin

+ const LoadBalancePolicyWeightedRandom

+ const StickySessionDefaultLBCookieName

+ const StickySessionModeApplicationBased

+ const StickySessionModeCookieConsistentHash

+ const StickySessionModeDurationBased

+ type GeneralLoadBalancer struct

+ func NewGeneralLoadBalancer(spec *LoadBalanceSpec, servers []*Server) *GeneralLoadBalancer

+ func (glb *GeneralLoadBalancer) ChooseServer(req protocols.Request) *Server

+ func (glb *GeneralLoadBalancer) Close()

+ func (glb *GeneralLoadBalancer) Init(fnNewSessionSticker func(*StickySessionSpec) SessionSticker, ...)

+ func (glb *GeneralLoadBalancer) ReturnServer(server *Server, req protocols.Request, resp protocols.Response)

+ type HTTPHealthChecker struct

+ func (hc *HTTPHealthChecker) Check(svr *Server) bool

+ func (hc *HTTPHealthChecker) Close()

+ type HTTPSessionSticker struct

+ func (ss *HTTPSessionSticker) Close()

+ func (ss *HTTPSessionSticker) GetServer(req protocols.Request, sg *ServerGroup) *Server

+ func (ss *HTTPSessionSticker) ReturnServer(server *Server, req protocols.Request, resp protocols.Response)

+ func (ss *HTTPSessionSticker) UpdateServers(servers []*Server)

+ type HeaderHashLoadBalancePolicy struct

+ func (lbp *HeaderHashLoadBalancePolicy) ChooseServer(req protocols.Request, sg *ServerGroup) *Server

+ type HealthCheckSpec struct

+ Fails int

+ Interval string

+ Passes int

+ Path string

+ Timeout string

+ type HealthChecker interface

+ Check func(svr *Server) bool

+ Close func()

+ func NewHTTPHealthChecker(spec *HealthCheckSpec) HealthChecker

+ type IPHashLoadBalancePolicy struct

+ func (lbp *IPHashLoadBalancePolicy) ChooseServer(req protocols.Request, sg *ServerGroup) *Server

+ type LoadBalancePolicy interface

+ ChooseServer func(req protocols.Request, sg *ServerGroup) *Server

+ type LoadBalanceSpec struct

+ ForwardKey string

+ HeaderHashKey string

+ HealthCheck *HealthCheckSpec

+ Policy string

+ StickySession *StickySessionSpec

+ type LoadBalancer interface

+ ChooseServer func(req protocols.Request) *Server

+ Close func()

+ ReturnServer func(server *Server, req protocols.Request, resp protocols.Response)

+ type RandomLoadBalancePolicy struct

+ func (lbp *RandomLoadBalancePolicy) ChooseServer(req protocols.Request, sg *ServerGroup) *Server

+ type RequestMatcher interface

+ Match func(req protocols.Request) bool

+ func NewRequestMatcher(spec *RequestMatcherBaseSpec) RequestMatcher

+ type RequestMatcherBaseSpec struct

+ HeaderHashKey string

+ Headers map[string]*stringtool.StringMatcher

+ MatchAllHeaders bool

+ Permil uint32

+ Policy string

+ func (s *RequestMatcherBaseSpec) Validate() error

+ type RoundRobinLoadBalancePolicy struct

+ func (lbp *RoundRobinLoadBalancePolicy) ChooseServer(req protocols.Request, sg *ServerGroup) *Server

+ type Server struct

+ AddrIsHostName bool

+ HealthCounter int

+ KeepHost bool

+ Tags []string

+ URL string

+ Unhealth bool

+ Weight int

+ func (s *Server) CheckAddrPattern()

+ func (s *Server) Healthy() bool

+ func (s *Server) ID() string

+ func (s *Server) String() string

+ type ServerGroup struct

+ Servers []*Server

+ TotalWeight int

+ type ServerPoolBase struct

+ Name string

+ func (spb *ServerPoolBase) Close()

+ func (spb *ServerPoolBase) Done() <-chan struct{}

+ func (spb *ServerPoolBase) Init(spImpl ServerPoolImpl, super *supervisor.Supervisor, name string, ...)

+ func (spb *ServerPoolBase) LoadBalancer() LoadBalancer

+ type ServerPoolBaseSpec struct

+ LoadBalance *LoadBalanceSpec

+ ServerTags []string

+ Servers []*Server

+ ServiceName string

+ ServiceRegistry string

+ func (sps *ServerPoolBaseSpec) Validate() error

+ type ServerPoolImpl interface

+ CreateLoadBalancer func(spec *LoadBalanceSpec, servers []*Server) LoadBalancer

+ type SessionSticker interface

+ Close func()

+ GetServer func(req protocols.Request, sg *ServerGroup) *Server

+ ReturnServer func(server *Server, req protocols.Request, resp protocols.Response)

+ UpdateServers func(servers []*Server)

+ func NewHTTPSessionSticker(spec *StickySessionSpec) SessionSticker

+ type StickySessionSpec struct

+ AppCookieName string

+ LBCookieExpire string

+ LBCookieName string

+ Mode string

+ type WeightedRandomLoadBalancePolicy struct

+ func (lbp *WeightedRandomLoadBalancePolicy) ChooseServer(req protocols.Request, sg *ServerGroup) *Server

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL