Method addServer

internal/data_plane/haproxy/manager.go:174–188

(ipAddress string, port int, transaction string, version int64)

}

func (api *API) addServer(ipAddress string, port int, transaction string, version int64) {
	name := fmt.Sprintf("%s%d", DataplanePrefix, rand.Int())
	url := fmt.Sprintf("%s:%d", ipAddress, port)

	api.mutex.Lock()
	defer api.mutex.Unlock()

	if _, ok := api.addressToName[url]; ok {
		return
	} else {
		api.persistServerMetadata(name, ipAddress, port, transaction, version)
		api.addressToName[url] = name
		logrus.Infof("Added data plane with address %s:%d to HAProxy backend.", ipAddress, port)
	}
}

func (api *API) addRegistrationServer(ipAddress string, port int, transaction string, version int64) {
	name := fmt.Sprintf("%s%d", RegistrationServerPrefix, rand.Int())