server

Documentation

Index

• func HealthCheck(s *Server, healthCheckInterval time.Duration)
• type Config
  • func LoadConfig(file string) (Config, error)
• type LoadBalancer
  • func (lb *LoadBalancer) GetNextServer(servers []*Server) *Server
• type Server
  • func (s *Server) ReverseProxy() *httputil.ReverseProxy

Functions

func HealthCheck

func HealthCheck(s *Server, healthCheckInterval time.Duration)

Types

type Config

type Config struct {
	Port                string   `json:"port"`
	HealthCheckInterval string   `json:"healthCheckInterval"`
	Servers             []string `json:"servers"`
}

func LoadConfig

func LoadConfig(file string) (Config, error)

type LoadBalancer

type LoadBalancer struct {
	Current int
	Mutex   sync.Mutex
}

func (*LoadBalancer) GetNextServer

func (lb *LoadBalancer) GetNextServer(servers []*Server) *Server

type Server

type Server struct {
	URL       *url.URL
	IsHealthy bool
	Mutex     sync.Mutex
}

func (*Server) ReverseProxy

func (s *Server) ReverseProxy() *httputil.ReverseProxy