Injected context cancellation for dial and retry cancellation.

2026-04-18 17:11:22 -04:00
parent 0f3d4691a6
commit 10c29c8330
12 changed files with 182 additions and 230 deletions
@@ -1,13 +1,14 @@
 package initiatorpool

 import (
+	"context"
 	"git.wisehodl.dev/jay/go-honeybee/transport"
 	"time"
 )

 // Types

-type WorkerFactory func(id string, stop <-chan struct{}) (*Worker, error)
+type WorkerFactory func(ctx context.Context, id string) (*Worker, error)

 // Pool Config