change placeholder type from identifier to string (#175)

* change placeholder type to string

* change from identifier to string type

* dont redefine metrics record

* skip trunk publish when not a release

.github/workflows/extension_ci.yml

@@ -130,6 +130,8 @@ jobs:
         working-directory: ./
         run: trunk build
       - name: trunk publish
+        # only publish release events
+        if: github.event_name == 'release'
         working-directory: ./
         env:
           TRUNK_API_TOKEN: ${{ secrets.TRUNK_AUTH_TOKEN }}

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "pgmq"
-version = "1.1.0"
+version = "1.1.1"
 edition = "2021"
 authors = ["Tembo.io"]
 description = "Postgres extension for PGMQ"

sql/pgmq--1.1.0--1.1.1.sql

@@ -0,0 +1,38 @@
+-- get metrics for a single queue
+CREATE OR REPLACE FUNCTION pgmq.metrics(queue_name TEXT)
+RETURNS pgmq.metrics_result AS $$
+DECLARE
+    result_row pgmq.metrics_result;
+    query TEXT;
+BEGIN
+    query := FORMAT(
+        $QUERY$
+        WITH q_summary AS (
+            SELECT
+                count(*) as queue_length,
+                EXTRACT(epoch FROM (NOW() - max(enqueued_at)))::int as newest_msg_age_sec,
+                EXTRACT(epoch FROM (NOW() - min(enqueued_at)))::int as oldest_msg_age_sec,
+                NOW() as scrape_time
+            FROM pgmq.q_%s
+        ),
+        all_metrics AS (
+            SELECT CASE
+                WHEN is_called THEN last_value ELSE 0
+                END as total_messages
+            FROM pgmq.q_%s_msg_id_seq
+        )
+        SELECT 
+            '%s' as queue_name,
+            q_summary.queue_length,
+            q_summary.newest_msg_age_sec,
+            q_summary.oldest_msg_age_sec,
+            all_metrics.total_messages,
+            q_summary.scrape_time
+        FROM q_summary, all_metrics
+        $QUERY$,
+        queue_name, queue_name, queue_name
+    );
+    EXECUTE query INTO result_row;
+    RETURN result_row;
+END;
+$$ LANGUAGE plpgsql;

src/sql_src.sql

@@ -300,13 +300,13 @@ BEGIN
                 EXTRACT(epoch FROM (NOW() - max(enqueued_at)))::int as newest_msg_age_sec,
                 EXTRACT(epoch FROM (NOW() - min(enqueued_at)))::int as oldest_msg_age_sec,
                 NOW() as scrape_time
-            FROM pgmq.q_%I
+            FROM pgmq.q_%s
         ),
         all_metrics AS (
             SELECT CASE
                 WHEN is_called THEN last_value ELSE 0
                 END as total_messages
-            FROM pgmq.q_%I_msg_id_seq
+            FROM pgmq.q_%s_msg_id_seq
         )
         SELECT 
             '%s' as queue_name,