balancer

Documentation

Index

• type LoadBalancer
  • func (lb *LoadBalancer) ConnConsumer()
  • func (lb *LoadBalancer) ForwardRequest(peekconn *connPeek.ReaderConn, clientconn, serverconn *net.TCPConn, ...)
  • func (lb *LoadBalancer) HandleConn(clientconn *net.TCPConn)
  • func (lb *LoadBalancer) Init(address string, chooser serverPick.ServerPicker, consumers int)
  • func (lb *LoadBalancer) Run()

Types

type LoadBalancer

type LoadBalancer struct {
	Chooser   serverPick.ServerPicker
	Address   string
	Consumers int
	Conns     chan *net.TCPConn
}

func (*LoadBalancer) ConnConsumer

func (lb *LoadBalancer) ConnConsumer()

func (*LoadBalancer) ForwardRequest

func (lb *LoadBalancer) ForwardRequest(peekconn *connPeek.ReaderConn, clientconn, serverconn *net.TCPConn, buf bytes.Buffer)

Actually send the request to "best" backend (first one for now)

func (*LoadBalancer) HandleConn

func (lb *LoadBalancer) HandleConn(clientconn *net.TCPConn)

func (*LoadBalancer) Init

func (lb *LoadBalancer) Init(address string, chooser serverPick.ServerPicker, consumers int)

TODO add support for multiple addresses?

func (*LoadBalancer) Run

func (lb *LoadBalancer) Run()