Updated

Author: djthorpe

pkg/pgqueue/config/task.go

@@ -167,6 +167,11 @@ func (t *task) Conn() pg.PoolConn {
 	return t.manager.Conn()
 }
 
+// Namespace returns the namespace of the queue.
+func (t *task) Namespace() string {
+	return t.manager.Namespace()
+}
+
 // RegisterTicker registers a periodic task (ticker) with a callback function.
 // It returns the metadata of the registered ticker.
 func (t *task) RegisterTicker(ctx context.Context, meta schema.TickerMeta, fn server.PGCallback) (*schema.Ticker, error) {

plugin.go

@@ -119,6 +119,9 @@ type PGQueue interface {
 	// Conn returns the underlying connection pool object.
 	Conn() pg.PoolConn
 
+	// Namespace returns the namespace of the queue.
+	Namespace() string
+
 	// RegisterTicker registers a periodic task (ticker) with a callback function.
 	// It returns the metadata of the registered ticker.
 	RegisterTicker(context.Context, pgschema.TickerMeta, PGCallback) (*pgschema.Ticker, error)