Method Run

lib/proxy.go:29–63

(config *Config)

}

func (p *Proxy) Run(config *Config) error {

	// create our reverse proxy
	url, err := url.Parse(config.ProxyTo)
	if err != nil {
		return err
	}
	p.proxy = httputil.NewSingleHostReverseProxy(url)
	p.to = url

	server := http.Server{Handler: http.HandlerFunc(p.defaultHandler)}

	if config.CertFile != "" && config.KeyFile != "" {
		cer, err := tls.LoadX509KeyPair(config.CertFile, config.KeyFile)
		if err != nil {
			return err
		}

		server.TLSConfig = &tls.Config{Certificates: []tls.Certificate{cer}}

		p.listener, err = tls.Listen("tcp", fmt.Sprintf("%s:%d", config.Laddr, config.Port), server.TLSConfig)
		if err != nil {
			return err
		}
	} else {
		p.listener, err = net.Listen("tcp", fmt.Sprintf("%s:%d", config.Laddr, config.Port))
		if err != nil {
			return err
		}
	}

	go server.Serve(p.listener)

	return nil
}

func (p *Proxy) Close() error {
	return p.listener.Close()