Method Start

diagnostic/server.go:39–87

(ctx context.Context)

}

func (s *Server) Start(ctx context.Context) error {
	var err error
	if s.ln, err = new(net.ListenConfig).Listen(ctx, "tcp", s.Addr); err != nil {
		return err
	}
	s.Addr = s.ln.Addr().String()

	s.proxy = &tcpproxy.Proxy{
		ListenFunc: func(string, string) (net.Listener, error) {
			return s.ln, nil
		},
	}

	lnTLS := &tcpproxy.TargetListener{
		Address: s.Addr,
	}

	s.proxy.AddSNIRouteFunc(s.Addr, func(context.Context, string) (tcpproxy.Target, bool) {
		return lnTLS, true
	})

	lnHTTP := &tcpproxy.TargetListener{
		Address: s.Addr,
	}

	s.proxy.AddRoute(s.Addr, lnHTTP)

	s.server = &http.Server{
		Addr: s.Addr,

		Handler: http.HandlerFunc(s.serveHTTP),

		BaseContext: func(net.Listener) context.Context { return ctx },
		ErrorLog:    discardLogger,
	}

	s.errg.Go(func() error {
		return s.server.Serve(lnHTTP)
	})
	s.errg.Go(func() error {
		return s.server.Serve(tls.NewListener(lnTLS, &tls.Config{
			NextProtos:     []string{"h2", "http/1.1"},
			GetCertificate: s.getCertificate,
		}))
	})

	s.tlsc = make(chan struct{})
	return s.proxy.Start()
}

func (s *Server) EnableTLS() {
	s.tlso.Do(func() { close(s.tlsc) })