Method CreateUnstarted

proxy/proxytest/proxytest.go:79–127

()

}

func (c Config) CreateUnstarted() *TestProxy {
	waitTime := 3 * time.Second
	if c.WaitTime > 0 {
		waitTime = c.WaitTime
	}

	endpointRegistry := routing.NewEndpointRegistry(routing.RegistryOptions{})
	tl := loggingtest.New()
	var dc *testdataclient.Client

	if len(c.RoutingOptions.DataClients) == 0 {
		dc = testdataclient.New(c.Routes)
		c.RoutingOptions.DataClients = []routing.DataClient{dc}
	}

	c.RoutingOptions.Log = tl
	c.RoutingOptions.PostProcessors = append(c.RoutingOptions.PostProcessors, loadbalancer.NewAlgorithmProvider(), endpointRegistry)

	rt := routing.New(c.RoutingOptions)
	c.ProxyParams.Routing = rt
	c.ProxyParams.EndpointRegistry = endpointRegistry

	pr := proxy.WithParams(c.ProxyParams)

	var tsp *httptest.Server

	if len(c.Certificates) > 0 {
		tsp = httptest.NewUnstartedServer(pr)
		tsp.TLS = &tls.Config{Certificates: c.Certificates}
	} else {
		tsp = httptest.NewUnstartedServer(pr)
	}

	if err := tl.WaitFor("route settings applied", waitTime); err != nil {
		panic(err)
	}

	_, port, _ := net.SplitHostPort(tsp.Listener.Addr().String())

	return &TestProxy{
		URL:     tsp.URL,
		Port:    port,
		Log:     tl,
		dc:      dc,
		routing: rt,
		proxy:   pr,
		server:  tsp,
	}
}

func (p *TestProxy) Start() {
	if p.server.TLS != nil {