Restructuring for worker development.

2026-04-17 18:47:17 -04:00
parent 7dab8031ea
commit f83df839b5
4 changed files with 46 additions and 59 deletions
@@ -7,11 +7,7 @@ import (

 // Types

-type WorkerFactory func(
-	id string,
-	conn *transport.Connection,
-	onReconnect func() (*transport.Connection, error),
-) Worker
+type WorkerFactory func(id string, stop <-chan struct{}) Worker

 // Pool Config