Function newCustomTestProxy

proxy/proxy_test.go:211–247

(predicates []routing.PredicateSpec, fr filters.Registry, doc string, params Params, preprocs []routing.PreProcessor)

}

func newCustomTestProxy(predicates []routing.PredicateSpec, fr filters.Registry, doc string, params Params, preprocs []routing.PreProcessor) (*testProxy, error) {
	dc, err := testdataclient.NewDoc(doc)
	if err != nil {
		return nil, err
	}

	if fr == nil {
		fr = builtin.MakeRegistry()
	}

	tl := loggingtest.New()
	if params.EndpointRegistry == nil {
		params.EndpointRegistry = routing.NewEndpointRegistry(routing.RegistryOptions{})
	}
	opts := routing.Options{
		FilterRegistry: fr,
		PollTimeout:    sourcePollTimeout,
		DataClients:    []routing.DataClient{dc},
		PostProcessors: []routing.PostProcessor{loadbalancer.NewAlgorithmProvider(), params.EndpointRegistry},
		Log:            tl,
		Predicates:     append([]routing.PredicateSpec{teePredicate.New()}, predicates...),
	}
	if len(preprocs) > 0 {
		opts.PreProcessors = preprocs
	}
	rt := routing.New(opts)

	params.Routing = rt
	p := WithParams(params)
	p.log = tl

	if err := tl.WaitFor("route settings applied", time.Second); err != nil {
		return nil, err
	}

	return &testProxy{tl, dc, rt, p}, nil
}

func newTestProxyWithFiltersAndParams(fr filters.Registry, doc string, params Params, preprocs []routing.PreProcessor) (*testProxy, error) {
	return newCustomTestProxy(nil, fr, doc, params, preprocs)