load_balancer

Documentation

Index

• func ReverseProxyLoadBalancerHandler(logger log.Logger, config *Config) (router.RouteHandler, error)
• type AliasExceptions
  • func (e AliasExceptions) NotAliasException(originalURL string) bool
• type Backend
  • func NewBackend(serverURL *url.URL, loadBalancerFunc http.HandlerFunc, logger log.Logger) *Backend
  • func (b *Backend) HealthCheck() error
  • func (b *Backend) IsAlive() bool
  • func (b *Backend) ServeHTTP(writer http.ResponseWriter, request *http.Request)
  • func (b *Backend) SetAlive(alive bool)
• type Config
• type ExceptionRoute
  • func (r *ExceptionRoute) IsException(originalURL, method string) (bool, error)
• type ExceptionRoutes
  • func (r ExceptionRoutes) IsSkip(originalURL, method string) (bool, error)
• type ServerPool
  • func NewServerPool(config *Config, logger log.Logger) (*ServerPool, error)
  • func (s *ServerPool) AddBackend(backend *Backend)
  • func (s *ServerPool) LoadBalancer(writer http.ResponseWriter, request *http.Request)
  • func (s *ServerPool) ServeHTTP(writer http.ResponseWriter, request *http.Request)

Functions

func ReverseProxyLoadBalancerHandler

func ReverseProxyLoadBalancerHandler(logger log.Logger, config *Config) (router.RouteHandler, error)

Types

type AliasExceptions

type AliasExceptions []string

func (AliasExceptions) NotAliasException

func (e AliasExceptions) NotAliasException(originalURL string) bool

type Backend

type Backend struct {
	// contains filtered or unexported fields
}

func NewBackend

func NewBackend(serverURL *url.URL, loadBalancerFunc http.HandlerFunc, logger log.Logger) *Backend

func (*Backend) HealthCheck

func (b *Backend) HealthCheck() error

func (*Backend) IsAlive

func (b *Backend) IsAlive() bool

func (*Backend) ServeHTTP

func (b *Backend) ServeHTTP(writer http.ResponseWriter, request *http.Request)

func (*Backend) SetAlive

func (b *Backend) SetAlive(alive bool)

type Config

type Config struct {
	Path           string
	Servers        []string
	ModifyRequest  func(http.ResponseWriter, *http.Request) error
	ModifyResponse func(http.ResponseWriter, *http.Request) error
}

type ExceptionRoute

type ExceptionRoute struct {
	Path            string
	Method          string
	AliasExceptions AliasExceptions
	Restricted      bool
}

func (*ExceptionRoute) IsException

func (r *ExceptionRoute) IsException(originalURL, method string) (bool, error)

type ExceptionRoutes

type ExceptionRoutes []*ExceptionRoute

func (ExceptionRoutes) IsSkip

func (r ExceptionRoutes) IsSkip(originalURL, method string) (bool, error)

type ServerPool

type ServerPool struct {
	// contains filtered or unexported fields
}

func NewServerPool

func NewServerPool(config *Config, logger log.Logger) (*ServerPool, error)

func (*ServerPool) AddBackend

func (s *ServerPool) AddBackend(backend *Backend)

func (*ServerPool) LoadBalancer

func (s *ServerPool) LoadBalancer(writer http.ResponseWriter, request *http.Request)

func (*ServerPool) ServeHTTP

func (s *ServerPool) ServeHTTP(writer http.ResponseWriter, request *http.Request)