Merge branch 'main' into separate_indexes_primary_keys

.github/workflows/image.yml

@@ -71,9 +71,8 @@ jobs:
           # if that file is present
           # and if the branch is 'main' or starts with 'release/'
           tag_cargo_version_if_present: ${{ steps.tags.outputs.tag_cargo }}
-          # Tag with 'latest'
-          # if the branch is 'main'
-          publish_latest: ${{ steps.tags.outputs.tag_latest }}
+          # never publish latest - that is handled in other workflow
+          publish_latest: false
           # If we are publishing latest, also tag it with calver
           publish_calver: ${{ steps.tags_outputs.tag_latest }}
           quay_user: ${{ secrets.QUAY_USER_TEMBO }}

Cargo.toml

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

core/src/errors.rs

@@ -18,6 +18,6 @@ pub enum PgmqError {
 
     /// a queue name error
     /// queue names must be alphanumeric and start with a letter
-    #[error("naming error: {name}")]
+    #[error("invalid queue name: '{name}'")]
     InvalidQueueName { name: String },
 }

src/api.rs

@@ -2,8 +2,8 @@ use pgrx::prelude::*;
 use pgrx::spi;
 use pgrx::spi::SpiTupleTable;
 
+use crate::errors::PgmqExtError;
 use crate::partition::PARTMAN_SCHEMA;
-use crate::PgmqExtError;
 use pgmq_crate::query::{destroy_queue, PGMQ_SCHEMA, TABLE_PREFIX};
 
 #[pg_extern]

src/errors.rs

@@ -0,0 +1,17 @@
+use pgmq_crate::errors::PgmqError;
+use thiserror::Error;
+
+#[derive(Error, Debug)]
+pub enum PgmqExtError {
+    #[error("unexpected error")]
+    SqlError(#[from] pgrx::spi::Error),
+
+    #[error("{0}")]
+    Core(#[from] PgmqError),
+
+    #[error("{0} invalid types")]
+    TypeErrorError(String),
+
+    #[error("missing dependency: {0}")]
+    MissingDependency(String),
+}

src/lib.rs

@@ -6,31 +6,18 @@ use pgrx::warning;
 pgrx::pg_module_magic!();
 
 pub mod api;
+pub mod errors;
 pub mod metrics;
 pub mod partition;
 
 use pgmq_crate::errors::PgmqError;
 use pgmq_crate::query::{
     archive, check_input, delete, init_queue, pop, read, PGMQ_SCHEMA, TABLE_PREFIX,
 };
-use thiserror::Error;
 
-use std::time::Duration;
-
-#[derive(Error, Debug)]
-pub enum PgmqExtError {
-    #[error("")]
-    SqlError(#[from] pgrx::spi::Error),
-
-    #[error("")]
-    QueueError(#[from] PgmqError),
+use errors::PgmqExtError;
 
-    #[error("{0} invalid types")]
-    TypeErrorError(String),
-
-    #[error("missing dependency: {0}")]
-    MissingDependency(String),
-}
+use std::time::Duration;
 
 #[pg_extern]
 fn pgmq_create_non_partitioned(queue_name: &str) -> Result<(), PgmqExtError> {