loadbalancer

Documentation

Index

• type Config
• type LoadBalancer
  • func New(cfg Config) *LoadBalancer
  • func (lb *LoadBalancer) AddServer(srv *Server)
  • func (lb *LoadBalancer) IsEmpty() bool
  • func (lb *LoadBalancer) Rebalance()
  • func (lb *LoadBalancer) RemoveServer(srv *Server)
  • func (lb *LoadBalancer) ServeHTTP(rw http.ResponseWriter, r *http.Request)
  • func (lb *LoadBalancer) Start()
  • func (lb *LoadBalancer) Stop()
• type Mode
  • func (mode *Mode) ValidateUpdate() bool
• type Server
  • func NewServer(name string, url types.URL, weight weightType, handler http.Handler) *Server
  • func (srv *Server) String() string

Types

type Config

type Config struct {
	Link   string
	Mode   Mode
	Weight weightType
}

TODO: stats of each server. TODO: support weighted mode.

type LoadBalancer

type LoadBalancer struct {
	Config
	// contains filtered or unexported fields
}

TODO: stats of each server. TODO: support weighted mode.

func New

func New(cfg Config) *LoadBalancer

func (*LoadBalancer) AddServer

func (lb *LoadBalancer) AddServer(srv *Server)

func (*LoadBalancer) IsEmpty

func (lb *LoadBalancer) IsEmpty() bool

func (*LoadBalancer) Rebalance

func (lb *LoadBalancer) Rebalance()

func (*LoadBalancer) RemoveServer

func (lb *LoadBalancer) RemoveServer(srv *Server)

func (*LoadBalancer) ServeHTTP

func (lb *LoadBalancer) ServeHTTP(rw http.ResponseWriter, r *http.Request)

func (*LoadBalancer) Start

func (lb *LoadBalancer) Start()

func (*LoadBalancer) Stop

func (lb *LoadBalancer) Stop()

type Mode

type Mode string

const (
	RoundRobin Mode = "roundrobin"
	LeastConn  Mode = "leastconn"
	IPHash     Mode = "iphash"
)

func (*Mode) ValidateUpdate

func (mode *Mode) ValidateUpdate() bool

type Server

type Server struct {
	Name   string
	URL    types.URL
	Weight weightType
	// contains filtered or unexported fields
}

func NewServer

func NewServer(name string, url types.URL, weight weightType, handler http.Handler) *Server

func (*Server) String

func (srv *Server) String() string