gocall

-- import "github.com/anikhasibul/gocall"

Package gocall gives you the ability to create your own out of the box load balancer and API gateway!

var lb = gocall.NewLoadBalancer([]string{
  "127.0.0.1:1234",
  "127.0.0.1:1235",
  "127.0.0.1:1236",
}, "/health", 10*time.Second)
func main() {
    fasthttp.ListenAndServe(":8081", proxify)
}
func proxify(ctx *fasthttp.RequestCtx) {
  // Check auth here
  // ....
  // Now pass the request to the target server
  lb.ProxyTheHealthiest(ctx)
}

Usage

func ReverseProxy

func ReverseProxy(target string, res http.ResponseWriter, req *http.Request)

ReverseProxy proxies the target with given http request

type LoadBalancer

type LoadBalancer struct {
	Fallback  func(http.ResponseWriter, *http.Request, error)
	HealthURL string
}

LoadBalancer holds basic load balancing mechanisms

func NewLoadBalancer

func NewLoadBalancer(hosts []string, healthCheckURL string, healthCheckDelay time.Duration) *LoadBalancer

NewLoadBalancer returns a load balancer

var lb = gocall.NewLoadBalancer([]string{
  "127.0.0.1:1234",
  "127.0.0.1:1235",
  "127.0.0.1:1236",
  }, "/health", 10*time.Second)
func main() {
    fasthttp.ListenAndServe(":8081", proxify)
}
func proxify(ctx *fasthttp.RequestCtx) {
  // Check auth here
  // ....
  // Now pass the request to the target server
  lb.ProxyTheHealthiest(ctx)
}

func (*LoadBalancer) FindTheHealthiest

func (b *LoadBalancer) FindTheHealthiest() string

FindTheHealthiest returns the server that has the minimum amount of request at calling time

func (*LoadBalancer) ProxyTheHealthiest

func (b *LoadBalancer) ProxyTheHealthiest(w http.ResponseWriter, r *http.Request)

ProxyTheHealthiest sends a reverse proxy request to the heathiest server returned by FindTheHealthiest()

func DefaultFallback

func DefaultFallback(w http.ResponseWriter, _ *http.Request, err error)

DefaultFallback function to response if any error occurs on reverse proxy