Initial buildout of worker pattern.

This commit is contained in:
Jay
2026-04-17 13:29:49 -04:00
parent 043fba0198
commit d27e783729
7 changed files with 272 additions and 102 deletions
+4 -4
View File
@@ -62,7 +62,7 @@ type pool struct {
errors chan error
done chan struct{}
config *PoolConfig
config *InitiatorPoolConfig
logger *slog.Logger
mu sync.RWMutex
@@ -147,12 +147,12 @@ type InitiatorPool struct {
dialer Dialer
}
func NewInitiatorPool(config *PoolConfig, logger *slog.Logger) (*InitiatorPool, error) {
func NewInitiatorPool(config *InitiatorPoolConfig, logger *slog.Logger) (*InitiatorPool, error) {
if config == nil {
config = GetDefaultPoolConfig()
config = GetDefaultInitiatorPoolConfig()
}
if err := validatePoolConfig(config); err != nil {
if err := validateInitiatorPoolConfig(config); err != nil {
return nil, err
}