feat(adapter/postgres): wip postgres remote adapter#689

Draft

Totodore wants to merge 14 commits intomainfrom

postgres-adapter

Owner

Totodore commented Mar 29, 2026 •

edited

Loading

Motivation

Add a postgres adapter implementation for socket.io clusters.

Closes issue #423

TODO:

Offload binary / > 8KB payloads to attachment table
Implement attachment item pruning
Documentation / Examples

Totodore and others added 6 commits

May 6, 2025 00:23

wip

471f94c


          feat(adapter/postgres): Driver wip

da03dc8

wip

092e447


          Merge remote-tracking branch 'origin/main' into postgres-adapter

25d607c

wip

818a306


          feat(adapter/postgre): wip

Totodore added C-Enhancement A-postgres-adapter labels

Totodore added 2 commits

March 29, 2026 14:36


          Merge remote-tracking branch 'origin/main' into postgres-adapter

5e3b767


          feat(adapter/postgre): wip

7acdde2

codspeed-hq bot commented Mar 29, 2026 •

edited

Loading

Merging this PR will not alter performance

✅ 87 untouched benchmarks

_{Comparing postgres-adapter (d6fbb14) with main (cad5c50)}


          feat(adapter/postgre): wip

db72426

github-advanced-security bot found potential problems

View reviewed changes

crates/socketioxide-postgres/src/drivers/mod.rs Fixed Show fixed Hide fixed

crates/socketioxide-postgres/src/drivers/mod.rs Fixed Show fixed Hide fixed

crates/socketioxide-postgres/src/drivers/mod.rs Fixed Show fixed Hide fixed

crates/socketioxide-postgres/src/drivers/mod.rs Fixed Show fixed Hide fixed

crates/socketioxide-postgres/src/drivers/mod.rs Fixed Show fixed Hide fixed

crates/socketioxide-postgres/src/drivers/mod.rs Fixed Show fixed Hide fixed

crates/socketioxide-postgres/src/drivers/mod.rs Fixed Show fixed Hide fixed

crates/socketioxide-postgres/src/drivers/sqlx.rs Fixed Show fixed Hide fixed

crates/socketioxide-postgres/src/lib.rs

+              #![warn(
+                  clippy::all,
+                  clippy::todo,
+                  clippy::empty_enums,

Check warning

Code scanning / clippy

unknown lint: clippy::empty_enums Warning

unknown lint: clippy::empty_enums

crates/socketioxide-postgres/src/lib.rs Fixed Show fixed Hide fixed

Totodore linked an issue

that may be closed by this pull request

Postgres adapter #423

Open

Totodore added 2 commits

March 29, 2026 14:48


          feat(adapter/postgre): wip

3453a86


          feat(adapter/postgre): wip

aa54305

github-advanced-security bot found potential problems

View reviewed changes

crates/socketioxide-postgres/src/drivers/mod.rs Fixed Show fixed Hide fixed

crates/socketioxide-postgres/src/drivers/mod.rs Fixed Show fixed Hide fixed

Totodore added 3 commits

March 29, 2026 18:28


          feat(adapter/postgre): wip


          feat(adapter/postgre): wip

0a36ade


          feat(adapter/postgre): add tests

d6fbb14

github-advanced-security bot found potential problems

View reviewed changes

crates/socketioxide-postgres/src/lib.rs

+              #![warn(
+                  clippy::all,
+                  clippy::todo,
+                  clippy::empty_enums,

Check warning

Code scanning / clippy

unknown lint: clippy::empty_enums Warning

unknown lint: clippy::empty_enums

crates/socketioxide-postgres/tests/fixture.rs

+                  /// Sender to emit outgoing NOTIFY messages (to be broadcast to other servers).
+                  tx: mpsc::Sender<StubNotification>,
+                  /// Handlers for incoming notifications per listened channel.
+                  handlers: Arc<RwLock<Vec<(String, mpsc::Sender<StubNotification>)>>>,

Check warning

Code scanning / clippy

very complex type used. Consider factoring parts into type definitions Warning test

very complex type used. Consider factoring parts into type definitions

crates/socketioxide-postgres/tests/fixture.rs

+                  /// Sender to emit outgoing NOTIFY messages (to be broadcast to other servers).
+                  tx: mpsc::Sender<StubNotification>,
+                  /// Handlers for incoming notifications per listened channel.
+                  handlers: Arc<RwLock<Vec<(String, mpsc::Sender<StubNotification>)>>>,

Check warning

Code scanning / clippy

very complex type used. Consider factoring parts into type definitions Warning test

very complex type used. Consider factoring parts into type definitions

crates/socketioxide-postgres/tests/fixture.rs

+                  /// Sender to emit outgoing NOTIFY messages (to be broadcast to other servers).
+                  tx: mpsc::Sender<StubNotification>,
+                  /// Handlers for incoming notifications per listened channel.
+                  handlers: Arc<RwLock<Vec<(String, mpsc::Sender<StubNotification>)>>>,

Check warning

Code scanning / clippy

very complex type used. Consider factoring parts into type definitions Warning test

very complex type used. Consider factoring parts into type definitions

crates/socketioxide-postgres/tests/fixture.rs

+                  /// Sender to emit outgoing NOTIFY messages (to be broadcast to other servers).
+                  tx: mpsc::Sender<StubNotification>,
+                  /// Handlers for incoming notifications per listened channel.
+                  handlers: Arc<RwLock<Vec<(String, mpsc::Sender<StubNotification>)>>>,

Check warning

Code scanning / clippy

very complex type used. Consider factoring parts into type definitions Warning test

very complex type used. Consider factoring parts into type definitions

crates/socketioxide-postgres/tests/fixture.rs

+              /// Pipe incoming notifications to the matching channel handlers.
+              async fn pipe_handlers(
+                  mut rx: mpsc::Receiver<StubNotification>,
+                  handlers: Arc<RwLock<Vec<(String, mpsc::Sender<StubNotification>)>>>,

Check warning

Code scanning / clippy

very complex type used. Consider factoring parts into type definitions Warning test

very complex type used. Consider factoring parts into type definitions

crates/socketioxide-postgres/tests/fixture.rs

+              /// Pipe incoming notifications to the matching channel handlers.
+              async fn pipe_handlers(
+                  mut rx: mpsc::Receiver<StubNotification>,
+                  handlers: Arc<RwLock<Vec<(String, mpsc::Sender<StubNotification>)>>>,

Check warning

Code scanning / clippy

very complex type used. Consider factoring parts into type definitions Warning test

very complex type used. Consider factoring parts into type definitions

crates/socketioxide-postgres/tests/fixture.rs

+              /// Pipe incoming notifications to the matching channel handlers.
+              async fn pipe_handlers(
+                  mut rx: mpsc::Receiver<StubNotification>,
+                  handlers: Arc<RwLock<Vec<(String, mpsc::Sender<StubNotification>)>>>,

Check warning

Code scanning / clippy

very complex type used. Consider factoring parts into type definitions Warning test

very complex type used. Consider factoring parts into type definitions

crates/socketioxide-postgres/tests/fixture.rs

+              /// Pipe incoming notifications to the matching channel handlers.
+              async fn pipe_handlers(
+                  mut rx: mpsc::Receiver<StubNotification>,
+                  handlers: Arc<RwLock<Vec<(String, mpsc::Sender<StubNotification>)>>>,

Check warning

Code scanning / clippy

very complex type used. Consider factoring parts into type definitions Warning test

very complex type used. Consider factoring parts into type definitions

crates/socketioxide-postgres/tests/fixture.rs

+              /// Pipe incoming notifications to the matching channel handlers.
+              async fn pipe_handlers(
+                  mut rx: mpsc::Receiver<StubNotification>,
+                  handlers: Arc<RwLock<Vec<(String, mpsc::Sender<StubNotification>)>>>,

Check warning

Code scanning / clippy

very complex type used. Consider factoring parts into type definitions Warning test

very complex type used. Consider factoring parts into type definitions

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

A-postgres-adapter C-Enhancement