cloud/blockstore/libs/diagnostics/hostname.cpp - main - githubmirror/nbs

cloud/blockstore/libs/diagnostics/hostname.cpp
247 строк7 KB
akilvein
[NBS] Use templatable Volume Monitoting dashboard URL on the monitoring pages (#4826)
29 дек 2025, 12:08
29 дек 2025, 12:08c3c3160
#include "hostname.h"

#include "config.h"

#include <util/generic/string.h>
#include <util/stream/printf.h>
#include <util/string/builder.h>
#include <util/system/hostname.h>

#include <array>
#include <span>

namespace NCloud::NBlockStore {

namespace {

////////////////////////////////////////////////////////////////////////////////

constexpr std::array<TStringBuf, 2> DefaultHandleClasses(
    {"GetFast", "PutUserData"});
constexpr std::array<TStringBuf, 3> LogHandleClasses(
    {"GetFast", "PutUserData", "PutTabletLog"});
constexpr std::array<TStringBuf, 4> MergedAndMixedHandleClasses(
    {"GetFast", "GetAsync", "PutUserData", "PutAsyncBlob"});

ui32 GetServicePort(EHostService serviceType, const TDiagnosticsConfig& config)
{
    switch (serviceType) {
        case EHostService::Kikimr: return config.GetKikimrMonPort();
        case EHostService::Nbs: return config.GetNbsMonPort();

        default:
            Y_ABORT("Wrong EHostService: %d", serviceType);
    }
}

[[nodiscard]] std::span<const TStringBuf> GetHandleClasses(
    const TString& channelKind)
{
    if (channelKind == "Log") {
        return LogHandleClasses;
    }

    if (channelKind == "Merged" || channelKind == "Mixed") {
        return MergedAndMixedHandleClasses;
    }

    return DefaultHandleClasses;
}

TString GetUrlFromTemplate(
    const TString& templateStr,
    const TDiagnosticsConfig& config,
    const TString& diskId)
{
    TString result = templateStr;
    const auto& data = config.GetMonitoringUrlData();

    SubstGlobal(result, "{MonitoringUrl}", data.MonitoringUrl);
    SubstGlobal(result, "{MonitoringProject}", data.MonitoringProject);
    SubstGlobal(result, "{MonitoringClusterName}", data.MonitoringClusterName);
    SubstGlobal(
        result,
        "{MonitoringVolumeDashboard}",
        data.MonitoringVolumeDashboard);
    SubstGlobal(
        result,
        "{MonitoringNBSAlertsDashboard}",
        data.MonitoringNBSAlertsDashboard);
    SubstGlobal(
        result,
        "{MonitoringNBSTVDashboard}",
        data.MonitoringNBSTVDashboard);
    SubstGlobal(result, "{MonitoringYDBProject}", data.MonitoringYDBProject);
    SubstGlobal(
        result,
        "{MonitoringYDBGroupDashboard}",
        data.MonitoringYDBGroupDashboard);
    SubstGlobal(result, "{diskId}", diskId);

    return result;
}

}    // namespace

////////////////////////////////////////////////////////////////////////////////

TString GetShortHostName(const TString& fullName)
{
    auto pos = fullName.find('.', 0);
    return pos != NPOS ? fullName.substr(0, pos) : fullName;
}

TString GetShortHostName()
{
    return GetShortHostName(HostName());
}

TString GetExternalHostUrl(
    const TString& hostName,
    EHostService serviceType,
    const TDiagnosticsConfig& config)
{
    TStringBuilder out;
    switch (config.GetHostNameScheme()) {
        case NProto::HOSTNAME_BASTION:
            out << "https://"
                << GetShortHostName(hostName)
                << '.'
                << config.GetBastionNameSuffix();

            if (serviceType != EHostService::Kikimr) {
                out << ':' << GetServicePort(serviceType, config);
            }
            break;

        case NProto::HOSTNAME_YDBVIEWER:
            out << "https://" << config.GetViewerHostName()
                << '/' << hostName
                << ':' << GetServicePort(serviceType, config);
            break;

        default:
            out << "http://" << hostName
                << ':' << GetServicePort(serviceType, config);
            break;
    }

    out << '/';
    return out;
}

TString GetMonitoringVolumeUrl(
    const TDiagnosticsConfig& config,
    const TString& diskId)
{
    TMonitoringUrlData data = config.GetMonitoringUrlData();

    if (data.MonitoringUrlTemplate.empty()) {
        return TStringBuilder()
               << data.MonitoringUrl << "/projects/" << data.MonitoringProject
               << "/dashboards/" << data.MonitoringVolumeDashboard
               << "?from=now-1d&to=now&refresh=60000&p.cluster="
               << data.MonitoringClusterName << "&p.volume=" << diskId;
    }

    return GetUrlFromTemplate(data.MonitoringUrlTemplate, config, diskId);
}

TString GetMonitoringVolumeUrlWithoutDiskId(const TDiagnosticsConfig& config)
{
    TMonitoringUrlData data = config.GetMonitoringUrlData();
    return TStringBuilder()
           << data.MonitoringUrl << "/projects/" << data.MonitoringProject
           << "/dashboards/" << data.MonitoringVolumeDashboard
           << "?from=now-1d&to=now&refresh=60000&p.cluster="
           << data.MonitoringClusterName << "&p.volume=";
}

TString GetMonitoringNBSAlertsUrl(const TDiagnosticsConfig& config)
{
    TMonitoringUrlData data = config.GetMonitoringUrlData();
    return TStringBuilder()
           << data.MonitoringUrl << "/projects/" << data.MonitoringProject
           << "/dashboards/" << data.MonitoringNBSAlertsDashboard
           << "?from=now-1d&to=now&refresh=60000&p.cluster="
           << data.MonitoringClusterName << "&p.host=" << GetShortHostName();
}

TString GetMonitoringNBSOverviewToTVUrl(const TDiagnosticsConfig& config)
{
    TMonitoringUrlData data = config.GetMonitoringUrlData();
    return TStringBuilder()
           << data.MonitoringUrl << "/projects/" << data.MonitoringProject
           << "/dashboards/" << data.MonitoringNBSTVDashboard
           << "?from=now-1d&to=now&refresh=60000&p.cluster="
           << data.MonitoringClusterName << "&p.host=" << GetShortHostName();
}

TString
GetQueries(ui32 groupId, const TString& storagePool, const TString& channelKind)
{
    auto handleClasses = GetHandleClasses(channelKind);

    TStringBuilder queries;
    TStringOutput stream(queries);

    char queryName = 'A';
    for (ui32 queryIdx = 0; queryIdx < handleClasses.size(); ++queryIdx) {
        Printf(
            stream,
            R"(q.%u.s=histogram_percentile(100, {project="kikimr", cluster="*", storagePool="%s", group="%)" PRIu32
            R"(", host="*", service="vdisks", subsystem="latency_histo", handleclass="%s"})&q.%u.name=%c&)",
            queryIdx,
            storagePool.c_str(),
            groupId,
            handleClasses[queryIdx].data(),
            queryIdx,
            queryName);
        ++queryName;
    }

    return queries;
}

TString GetMonitoringYDBGroupUrl(
    const TDiagnosticsConfig& config,
    ui32 groupId,
    const TString& storagePool,
    const TString& channelKind)
{
    constexpr TStringBuf Url =
        "%s/projects/%s/explorer/"
        "queries?%sfrom=now-1d&to=now&refresh=60000";

    auto queries = GetQueries(groupId, storagePool, channelKind);

    return Sprintf(
        Url.data(),
        config.GetMonitoringUrlData().MonitoringUrl.c_str(),
        config.GetMonitoringUrlData().MonitoringYDBProject.c_str(),
        queries.c_str());
}

TString GetMonitoringDashboardYDBGroupUrl(
    const TDiagnosticsConfig& config,
    ui32 groupId)
{
    const auto& monitoringYDBProject =
        config.GetMonitoringUrlData().MonitoringYDBProject;
    if (monitoringYDBProject.empty()) {
        return "";
    }

    constexpr TStringBuf Url =
        "%s/projects/%s/dashboards/"
        "%s?from=now-1d&to=now&refresh=60000&p.cluster=*&p.group=%" PRIu32;

    return Sprintf(
        Url.data(),
        config.GetMonitoringUrlData().MonitoringUrl.c_str(),
        monitoringYDBProject.c_str(),
        config.GetMonitoringUrlData().MonitoringYDBGroupDashboard.c_str(),
        groupId);
}

}   // namespace NCloud::NBlockStore