О служебном управлении

using upstream_route_t = std::function<unsigned int (const char *, const char *, const char *)>;

class UpstreamManager
{
public:
    static int upstream_create_consistent_hash(const std::string& name,
                                                upstream_route_t consistent_hash);

    static int upstream_create_weighted_random(const std::string& name,
                                               bool try_another);

    static int upstream_create_manual(const std::string& name,
                                      upstream_route_t select,
                                      bool try_another,
                                      upstream_route_t consistent_hash);

    static int upstream_delete(const std::string& name);
    ...
};

#include "workflow/UpstreamManager.h"
#include "workflow/WFTaskFactory.h"

int main()
{
    UpstreamManager::upstream_create_weighted_random("www.sogou.com", false);
    struct AddressParams params = ADDRESS_PARAMS_DEFAULT;

    params.weight = 5;
    UpstreamManager::upstream_add_server("www.sogou.com", "www.sogou.com", &params);
    params.weight = 1;
    UpstreamManager::upstream_add_server("www.sogou.com", "127.0.0.1:8000", &params);
    params.weight = 4;
    UpstreamManager::upstream_add_server("www.sogou.com", "127.0.0.1:8080", &params);

    WFHttpTask *task = WFTaskFactory::create_http_task("http://www.sogou.com/index.html", ...);
    ...
}

#include "workflow/UpstreamManager.h"
#include "workflow/WFTaskFactory.h"

int my_select(const char *path, const char *query, const char *fragment)
{
    if (strcmp(query, "123") == 0)
        return 1;
    else if (strcmp(query, "abc") == 0)
        return 2;
    else
        return 0;
}

int main()
{
    UpstreamManager::upstream_create_manual("www.sogou.com", my_select, false, nullptr);

    UpstreamManager::upstream_add_server("www.sogou.com", "www.sogou.com");
    UpstreamManager::upstream_add_server("www.sogou.com", "127.0.0.1:8000");
    UpstreamManager::upstream_add_server("www.sogou.com", "127.0.0.1:8080");

    /* This URL will route to 127.0.0.1:8080 */
    WFHttpTask *task = WFTaskFactory::create_http_task("http://www.sogou.com/index.html?abc", ...);
    ...
}

int main()
{
    UpstreamManager::upstream_create_consistent_hash("redis.name", nullptr);

    UpstreamManager::upstream_add_server("redis.name", "10.135.35.53");
    UpstreamManager::upstream_add_server("redis.name", "10.135.35.54");
    UpstreamManager::upstream_add_server("redis.name", "10.135.35.55");
    ...
    UpstreamManager::upstream_add_server("redis.name", "10.135.35.62");

    auto *task = WFTaskFactory::create_redis_task("redis://:mypassword@redis.name/2?a=hello#111", ...);
    ...
}
~~~Наш Redis задачник не распознаёт часть запроса, поэтому её можно заполнить произвольно. Часть пути `/2` указывает на номер базы данных Redis.  
В этом случае функция `consistent_hash` получит три параметра: "/2", "a=hello" и "111". Поскольку мы передали `nullptr`, будет использована стандартная функция консистентного хеширования.  
Серверы внутри upstream не указывают порт, поэтому будет использован порт из URL. По умолчанию для Redis он равен 6379.  
Функция `consistent_hash` не имеет параметра `try_another`. При отказе выбранного сервера будет автоматически выбран другой. Для одного и того же URL будет выбрана одна и та же машина (дружественно к кэшу).

### Параметры сервера upstream

В первом примере мы установили параметр `weight` через параметр `params`. Однако параметры сервера не ограничиваются только весом. Эта структура определена следующим образом:
~~~cpp
// В файле EndpointParams.h
struct EndpointParams
{
    size_t max_connections;
    int connect_timeout;
    int response_timeout;
    int ssl_connect_timeout;
    bool use_tls_sni;
};

// В файле ServiceGovernance.h
struct AddressParams
{
    struct EndpointParams endpoint_params; ///< Настройки подключения
    unsigned int dns_ttl_default;          ///< В секундах, TTL DNS при успешном запросе сети
    unsigned int dns_ttl_min;             ///< В секундах, TTL DNS при неудачном запросе сети
/**
 * - Параметр max_fails устанавливает количество последовательных неудачных попыток связи с сервером.
 * - Через 30 секунд после отказа сервера, upstream проверяет сервер с помощью некоторых активных клиентских запросов.
 * - Если проверка проходит успешно, сервер помечается как работающий.
 * - Если max_fails установлено в 1, то сервер выйдет из выборки upstream за 30 секунд после единственной ошибки.
 */
    unsigned int max_fails;               ///< [1, INT32_MAX] max_fails = 0 означает max_fails = 1
    unsigned short weight;                ///< [1, 65535] weight = 0 означает weight = 1. Только для основного сервера
    int server_type;                      ///< 0 для основного и 1 для резервного
    int group_id;                         ///< -1 означает отсутствие группы. Резервный сервер без группы будет резервировать любой основной узел
};

    UpstreamManager::upstream_create_weighted_random("10.135.35.53", false);
    struct AddressParams params = ADDRESS_PARAMS_DEFAULT;
    params.endpoint_params.max_connections = 1000;
    UpstreamManager::upstream_add_server("10.135.35.53", "10.135.35.53", &params);