Renamed package

Author: meshin-dev

.github/workflows/tests.yml

@@ -1,4 +1,4 @@
-name: PG Listener Tests
+name: PG Watcher Tests
 
 on:
   push:

README.md

@@ -1,6 +1,6 @@
-# PG Listener
+# PG Watcher
 
-[![PG Listener Tests](https://github.com/smarter-day/pg-listener/actions/workflows/tests.yml/badge.svg)](https://github.com/smarter-day/pg-listener/actions/workflows/tests.yml)
+[![PG Watcher Tests](https://github.com/smarter-day/pg-listener/actions/workflows/tests.yml/badge.svg)](https://github.com/smarter-day/pg-listener/actions/workflows/tests.yml)
 
 A lightweight Go library for listening to PostgreSQL notifications in parallel across channels while preserving in-order delivery within each channel. It reconnects on errors, ensuring fault tolerance and redundancy.
 
@@ -37,7 +37,7 @@ import (
     "time"
 
     "github.com/jackc/pgx/v5/pgxpool"
-    "github.com/smarter-day/pg-listener"
+    "github.com/smarter-day/pgwatcher"
 )
 
 func main() {
@@ -49,10 +49,10 @@ func main() {
     defer dbpool.Close()
 
     // 2. Create an IListener
-    l := listener.NewListener(dbpool)
+    l := pgwatcher.NewListener(dbpool)
 
     // 3. Create and run the notifier
-    n := listener.NewNotifier(l)
+    n := pgwatcher.NewNotifier(l)
     ctx, cancel := context.WithCancel(context.Background())
     if err := n.Run(ctx); err != nil {
         panic(err)

examples/two-collections/main.go

@@ -4,7 +4,7 @@ import (
 	"context"
 	"github.com/jackc/pgx/v5/pgxpool"
 	"github.com/jackc/pgx/v5/tracelog"
-	"listener"
+	"github.com/smarter-day/pgwatcher"
 	"log"
 	"os"
 	"time"
@@ -44,8 +44,8 @@ func main() {
 	defer pool.Close()
 
 	// Initialize IListener and INotifier
-	l := listener.NewListener(pool)
-	n := listener.NewNotifier(l)
+	l := pgwatcher.NewListener(pool)
+	n := pgwatcher.NewNotifier(l)
 
 	// Run INotifier with context cancellation
 	ctx, cancel := context.WithTimeout(context.Background(), time.Hour)

go.mod

@@ -1,4 +1,4 @@
-module listener
+module github.com/smarter-day/pgwatcher
 
 go 1.22.8
 

listener.go

@@ -1,4 +1,4 @@
-package listener
+package pgwatcher
 
 import (
 	"context"

notifier.go

@@ -1,4 +1,4 @@
-package listener
+package pgwatcher
 
 import (
 	"context"

notifier_test.go

@@ -1,9 +1,9 @@
-package listener_test
+package pgwatcher_test
 
 import (
 	"context"
 	"errors"
-	"listener"
+	"github.com/smarter-day/pgwatcher"
 	"sync"
 	"testing"
 	"time"
@@ -16,13 +16,13 @@ type mockListener struct {
 	mu             sync.Mutex
 	connected      bool
 	channels       map[string]bool
-	notificationsC chan *listener.Notification
+	notificationsC chan *pgwatcher.Notification
 }
 
 func newMockListener() *mockListener {
 	return &mockListener{
 		channels:       make(map[string]bool),
-		notificationsC: make(chan *listener.Notification, 100),
+		notificationsC: make(chan *pgwatcher.Notification, 100),
 	}
 }
 
@@ -58,7 +58,7 @@ func (m *mockListener) UnListen(ctx context.Context, channel string) error {
 	return nil
 }
 
-func (m *mockListener) WaitForNotification(ctx context.Context) (*listener.Notification, error) {
+func (m *mockListener) WaitForNotification(ctx context.Context) (*pgwatcher.Notification, error) {
 	select {
 	case <-ctx.Done():
 		return nil, ctx.Err()
@@ -80,7 +80,7 @@ func (m *mockListener) Ping(ctx context.Context) error {
 }
 
 // pushNotification simulates server pushing a notification.
-func (m *mockListener) pushNotification(ntf *listener.Notification) {
+func (m *mockListener) pushNotification(ntf *pgwatcher.Notification) {
 	m.notificationsC <- ntf
 }
 
@@ -94,7 +94,7 @@ func TestNotifierWithSingleChannel(t *testing.T) {
 	defer cancel()
 
 	mockL := newMockListener()
-	n := listener.NewNotifier(mockL)
+	n := pgwatcher.NewNotifier(mockL)
 
 	// Start the Notifier (it will Connect automatically in the runLoop).
 	err := n.Run(ctx)
@@ -109,7 +109,7 @@ func TestNotifierWithSingleChannel(t *testing.T) {
 	go func() {
 		time.Sleep(200 * time.Millisecond) // Let it set up
 		for _, w := range want {
-			mockL.pushNotification(&listener.Notification{
+			mockL.pushNotification(&pgwatcher.Notification{
 				Channel: "foo",
 				Payload: []byte(w),
 			})
@@ -141,7 +141,7 @@ func TestNotifierWithMultipleChannels(t *testing.T) {
 	defer cancel()
 
 	mockL := newMockListener()
-	n := listener.NewNotifier(mockL)
+	n := pgwatcher.NewNotifier(mockL)
 	err := n.Run(ctx)
 	is.NoErr(err)
 
@@ -152,10 +152,10 @@ func TestNotifierWithMultipleChannels(t *testing.T) {
 	// We want to ensure concurrency across channels, so we push them at the same time.
 	go func() {
 		time.Sleep(200 * time.Millisecond)
-		mockL.pushNotification(&listener.Notification{Channel: "foo", Payload: []byte("foo1")})
-		mockL.pushNotification(&listener.Notification{Channel: "bar", Payload: []byte("bar1")})
-		mockL.pushNotification(&listener.Notification{Channel: "foo", Payload: []byte("foo2")})
-		mockL.pushNotification(&listener.Notification{Channel: "bar", Payload: []byte("bar2")})
+		mockL.pushNotification(&pgwatcher.Notification{Channel: "foo", Payload: []byte("foo1")})
+		mockL.pushNotification(&pgwatcher.Notification{Channel: "bar", Payload: []byte("bar1")})
+		mockL.pushNotification(&pgwatcher.Notification{Channel: "foo", Payload: []byte("foo2")})
+		mockL.pushNotification(&pgwatcher.Notification{Channel: "bar", Payload: []byte("bar2")})
 	}()
 
 	var gotFoo, gotBar []string

types.go

@@ -1,4 +1,4 @@
-package listener
+package pgwatcher
 
 import "context"