gateway

Documentation

Index

• Constants
• func NewReverseProxyCreator() *reverseProxyCreator
• type Gateway
  • func New(port string, rpCreator ReverseProxyCreator) *Gateway
  • func (gw *Gateway) AddService(logger lager.Logger, spec ReverseProxySpec) error
  • func (gw *Gateway) RemoveService(logger lager.Logger, host string) error
  • func (gw *Gateway) ServeHTTP(rw http.ResponseWriter, req *http.Request)
  • func (gw *Gateway) Start(logger lager.Logger) error
  • func (gw *Gateway) Stop() bool
• type ReverseProxy
• type ReverseProxyCreator
• type ReverseProxySpec

Constants

const (
	DEFAULT_TIMEOUT = 10000 * time.Millisecond
)

Functions

func NewReverseProxyCreator

func NewReverseProxyCreator() *reverseProxyCreator

Types

type Gateway

type Gateway struct {
	sync.RWMutex

	Services map[string]ReverseProxy
	// contains filtered or unexported fields
}

func New

func New(port string, rpCreator ReverseProxyCreator) *Gateway

func (*Gateway) AddService

func (gw *Gateway) AddService(logger lager.Logger, spec ReverseProxySpec) error

func (*Gateway) RemoveService

func (gw *Gateway) RemoveService(logger lager.Logger, host string) error

func (*Gateway) ServeHTTP

func (gw *Gateway) ServeHTTP(rw http.ResponseWriter, req *http.Request)

func (*Gateway) Start

func (gw *Gateway) Start(logger lager.Logger) error

func (*Gateway) Stop

func (gw *Gateway) Stop() bool

type ReverseProxy

type ReverseProxy interface {
	ServeHTTP(http.ResponseWriter, *http.Request)
}

type ReverseProxyCreator

type ReverseProxyCreator interface {
	Create(lager.Logger, ReverseProxySpec) (ReverseProxy, error)
}

type ReverseProxySpec

type ReverseProxySpec struct {
	Host     string
	Backends []string
	// Timeout in Milliseconds
	Timeout time.Duration
}