Function initializeEndpoints

proxy/fadein_internal_test.go:56–97

(endpointAges []float64, algorithmName string, fadeInDuration time.Duration)

}

func initializeEndpoints(endpointAges []float64, algorithmName string, fadeInDuration time.Duration) (*routing.Route, *Proxy, []string) {
	var detectionTimes []time.Time
	now := time.Now()
	for _, ea := range endpointAges {
		endpointAgeDuration := multiply(ea, fadeInDuration)
		detectionTimes = append(detectionTimes, now.Add(-endpointAgeDuration))
	}

	var eps []string
	for i, ea := range endpointAges {
		endpointAgeDuration := multiply(ea, fadeInDuration)
		eps = append(eps, fmt.Sprintf("http://ep-%d-%s.test", i, endpointAgeDuration))
	}

	registry := routing.NewEndpointRegistry(routing.RegistryOptions{})
	eskipRoute := eskip.Route{BackendType: eskip.LBBackend, LBAlgorithm: algorithmName}
	for i := range eps {
		eskipRoute.LBEndpoints = append(eskipRoute.LBEndpoints, &eskip.LBEndpoint{Address: eps[i]})
		registry.GetMetrics(eps[i]).SetDetected(detectionTimes[i])
	}

	route := &routing.Route{
		Route:            eskipRoute,
		LBFadeInDuration: fadeInDuration,
		LBFadeInExponent: 1,
		LBEndpoints:      []routing.LBEndpoint{},
	}

	rt := loadbalancer.NewAlgorithmProvider().Do([]*routing.Route{route})
	route = rt[0]
	registry.Do([]*routing.Route{route})

	eps = []string{}
	for i, ea := range endpointAges {
		endpointAgeDuration := multiply(ea, fadeInDuration)
		eps = append(eps, fmt.Sprintf("ep-%d-%s.test:80", i, endpointAgeDuration))
		registry.GetMetrics(eps[i]).SetDetected(detectionTimes[i])
	}

	proxy := &Proxy{registry: registry, fadein: &fadeIn{rnd: rand.New(rand.NewPCG(0, 0))}, quit: make(chan struct{})}
	return route, proxy, eps
}

// This function is needed to calculate the duration needed to send fadeInRequestCount requests.
// It is needed to send number of requests close to fadeInRequestCount on one hand and to have them sent exactly