added operator for query result

Author: g2px1

examples/main.cpp

@@ -412,7 +412,7 @@ int main()
         /*max_pool_size*/ 32,
         usub::pg::PgPoolHealthConfig{
             .enabled = true,
-            .interval_ms = 3000
+            .interval_ms = 30000
         }
     );
 

include/upq/PgTypes.h

@@ -117,10 +117,26 @@ namespace usub::pg
         struct Row
         {
             std::vector<std::string> cols;
+
+            const std::string& operator[](size_t i) const noexcept {
+                return cols[i];
+            }
+
+            std::string& operator[](size_t i) noexcept {
+                return cols[i];
+            }
         };
 
         std::vector<Row> rows;
 
+        const Row& operator[](size_t i) const noexcept {
+            return rows[i];
+        }
+
+        Row& operator[](size_t i) noexcept {
+            return rows[i];
+        }
+
         bool ok{false};
         PgErrorCode code{PgErrorCode::Unknown};
 

src/upq/PgHealthChecker.cpp

@@ -21,29 +21,22 @@ namespace usub::pg
 
         for (;;)
         {
+            std::cout << "test" << std::endl;
             try
             {
-                PgPoolHealthConfig cur = cfg_;
-
-                if (!cur.enabled)
-                {
-                    co_await usub::uvent::system::this_coroutine::sleep_for(milliseconds(1000));
-                    continue;
-                }
-
                 this->stats_.iterations.fetch_add(1, std::memory_order_relaxed);
 
                 auto res = co_await pool_.query_awaitable("SELECT 1;");
 
                 if (res.ok)
                 {
                     this->stats_.ok_checks.fetch_add(1, std::memory_order_relaxed);
-                    next_sleep = milliseconds(cur.interval_ms ? cur.interval_ms : 1000);
+                    next_sleep = milliseconds(this->cfg_.interval_ms ? this->cfg_.interval_ms : 1000);
                 }
                 else
                 {
                     this->stats_.failed_checks.fetch_add(1, std::memory_order_relaxed);
-                    auto backoff = std::min<uint64_t>(cur.interval_ms ? cur.interval_ms * 2 : 2000, 15000);
+                    auto backoff = std::min<uint64_t>(this->cfg_.interval_ms ? this->cfg_.interval_ms * 2 : 2000, 15000);
                     next_sleep = milliseconds(backoff);
                 }
             }