Function AddActiveStatus

be/src/util/default-path-handlers.cc:307–352

Add active or standby status for catalog or statestore.

// Add active or standby status for catalog or statestore.
void AddActiveStatus(Document* document, MetricGroup* metric_group) {
  DaemonEnv* d_env = DaemonEnv::GetInstance();
  bool is_statestore = false;
  bool is_catalog = false;
  if (d_env != nullptr) {
    if (d_env->name() == "statestore") {
      is_statestore = true;
    } else if (d_env->name() == "catalog") {
      is_catalog = true;
    } else {
      // Only deal with the status of catalog or statestore.
      return;
    }
    document->AddMember("is_statestore", is_statestore, document->GetAllocator());
    document->AddMember("is_catalog", is_catalog, document->GetAllocator());
  }

  if (metric_group != nullptr) {
    if (is_catalog) {
      BooleanProperty* metric = metric_group->FindMetricForTesting<BooleanProperty>(
          "catalog-server.active-status");
      if (metric != nullptr) {
        if (metric->GetValue()) {
          document->AddMember(
              "catalogd_active_status", "Active", document->GetAllocator());
        } else {
          document->AddMember(
              "catalogd_active_status", "Standby", document->GetAllocator());
        }
      }
    }
    if (is_statestore) {
      BooleanProperty* metric =
          metric_group->FindMetricForTesting<BooleanProperty>("statestore.active-status");
      if (metric != nullptr) {
        if (metric->GetValue()) {
          document->AddMember(
              "statestore_active_status", "Active", document->GetAllocator());
        } else {
          document->AddMember(
              "statestore_active_status", "Standby", document->GetAllocator());
        }
      }
    }
  }
}

void RootHandler(
    const Webserver::WebRequest& req, Document* document, MetricGroup* metric_group) {