Method genericRevise

internal/data_plane/haproxy/manager.go:263–338

(backend string, addressesToKeep []string)

}

func (api *API) genericRevise(backend string, addressesToKeep []string) (success bool, anyChanges bool) {
	errorIn := ""

	switch backend {
	case DataplaneBackend:
		errorIn = "data planes"
	case RegistrationServerBackend:
		errorIn = "registration servers"
	default:
		logrus.Fatalf("Invalid backend name for HAProxy backend revision function.")
	}

	version, err := api.client.Configuration.GetVersion("")
	if err != nil {
		logrus.Errorf("Failed to revise %s. Error obtaining configuration version - %v", errorIn, err)
		return false, false
	}

	transaction, err := api.client.Configuration.StartTransaction(version)
	if err != nil {
		logrus.Errorf("Failed to revise %s. Error starting HAProxy transaction - %v", errorIn, err)
		return false, false
	}

	version, servers, err := api.client.Configuration.GetServers(backend, transaction.ID)
	if err != nil {
		logrus.Errorf("Failed to revise %s. Error obtaining list of existing servers - %v", errorIn, err)
		return false, false
	}

	var existingURLs []string
	existingAddresses := make(map[string]string)
	for _, server := range servers {
		url := fmt.Sprintf("%s:%d", server.Address, *server.Port)

		existingURLs = append(existingURLs, url)
		existingAddresses[url] = server.Name
	}

	toAdd := _map.Difference(addressesToKeep, existingURLs)
	toRemove := _map.Difference(existingURLs, addressesToKeep)
	anyChanges = (len(toAdd) != 0) || (len(toRemove) != 0)

	// REMOVAL
	switch backend {
	case DataplaneBackend:
		for _, server := range toRemove {
			ipAddress, port := grpc_helpers.SplitAddress(server)
			api.removeServerByName(ipAddress, port, transaction.ID, 0)
		}
	case RegistrationServerBackend:
		api.removeRegistrationServers(transaction.ID)
	}

	// ADDITION
	switch backend {
	case DataplaneBackend:
		for _, address := range toAdd {