proxy

May 21, 2025

Changes in this version

+ type GRPCProxy struct

+ func NewGRPCProxy(ch chan seed.Seed, log *slog.Logger, lb LoadBalancer) *GRPCProxy

+ func (p *GRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (p *GRPCProxy) Start(ctx context.Context)

+ type LatencyBased struct

+ func NewLatencyBased(log *slog.Logger) *LatencyBased

+ func (rr *LatencyBased) Next() *Server

+ func (rr *LatencyBased) Update(servers []*Server)

+ type LoadBalancer interface

+ Next func() *Server

+ Update func([]*Server)

+ type Proxy struct

+ func (p *Proxy) Live() bool

+ func (p *Proxy) Ready() bool

+ func (p *Proxy) Start(ctx context.Context, update Updater)

+ func (p *Proxy) Stats() []ServerStat

+ type RPCProxy struct

+ func NewRPCProxy(ch chan seed.Seed, cfg config.HealthConfig, log *slog.Logger, lb LoadBalancer) *RPCProxy

+ func (p *RPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (p *RPCProxy) Start(ctx context.Context)

+ type RatedServer struct

+ Rate float64

+ type RestProxy struct

+ func NewRestProxy(ch chan seed.Seed, cfg config.HealthConfig, log *slog.Logger, lb LoadBalancer) *RestProxy

+ func (p *RestProxy) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (p *RestProxy) Start(ctx context.Context)

+ type RoundRobin struct

+ func NewRoundRobin(log *slog.Logger) *RoundRobin

+ func (rr *RoundRobin) Next() *Server

+ func (rr *RoundRobin) Update(servers []*Server)

+ type Server struct

+ Url *url.URL

+ func (s *Server) ErrorRate() float64

+ func (s *Server) Healthy() bool

+ type ServerStat struct

+ Avg time.Duration

+ Degraded bool

+ ErrorRate float64

+ Initialized bool

+ Name string

+ Requests int64

+ URL string

+ type Updater func(s seed.Seed)