Method RegisterToConsul

src/plugin/net/src/AFCNetServiceManagerModule.cpp:233–266

}

ananas::Future<std::pair<bool, std::string>> AFCNetServiceManagerModule::RegisterToConsul(const int bus_id)
{
    auto reg_center = m_pBusModule->GetRegCenter();
    AFBusAddr bus(bus_id);
    auto bus_name = bus.ToString();

    const std::string app_whole_name = m_pBusModule->GetAppWholeName(bus.bus_id);
    const std::string app_name = m_pBusModule->GetAppName(static_cast<ARK_APP_TYPE>(bus.app_type));

    const AFProcConfig& self_proc = m_pBusModule->GetSelfProc();

    consul::service_data service;
    service.set_id(app_whole_name);
    service.set_name(reg_center.service_name);
    service.set_address(self_proc.intranet_ep.GetIP());
    service.set_port(self_proc.intranet_ep.GetPort());

    // multi-tag
    service.add_tags(app_name);
    service.add_tags(bus_name);

    // multi-meta
    service.mutable_meta()->insert({"busid", bus_name});

    // health check
    auto check = service.mutable_check();
    check->set_id(app_whole_name + "_check");
    check->set_name(app_whole_name);
    check->set_tcp(self_proc.intranet_ep.GetIP() + ":" + ARK_TO_STRING(self_proc.intranet_ep.GetPort()));
    check->set_interval(reg_center.check_interval);
    check->set_timeout(reg_center.check_timeout);

    return m_pConsulModule->RegisterService(service);
}

int AFCNetServiceManagerModule::DeregisterFromConsul(const int bus_id)
{