Function getNginxUpstreamServers

agent/app/service/website_utils.go:1813–1847

(upstreamServers []*components.UpstreamServer)

}

func getNginxUpstreamServers(upstreamServers []*components.UpstreamServer) []dto.NginxUpstreamServer {
	var servers []dto.NginxUpstreamServer
	for _, ups := range upstreamServers {
		server := dto.NginxUpstreamServer{
			Server: ups.Address,
		}
		parameters := ups.Parameters
		if weight, ok := parameters["weight"]; ok {
			num, err := strconv.Atoi(weight)
			if err == nil {
				server.Weight = num
			}
		}
		if maxFails, ok := parameters["max_fails"]; ok {
			num, err := strconv.Atoi(maxFails)
			if err == nil {
				server.MaxFails = num
			}
		}
		if failTimeout, ok := parameters["fail_timeout"]; ok {
			server.FailTimeout, server.FailTimeoutUnit, _ = parseTimeString(failTimeout)
		}
		if maxConns, ok := parameters["max_conns"]; ok {
			num, err := strconv.Atoi(maxConns)
			if err == nil {
				server.MaxConns = num
			}
		}
		for _, flag := range ups.Flags {
			server.Flag = flag
		}
		servers = append(servers, server)
	}
	return servers
}

func getManualWebsiteSSL(req request.WebsiteHTTPSOp) (model.WebsiteSSL, error) {
	var websiteSSL model.WebsiteSSL