summaryrefslogtreecommitdiff
path: root/interfaces/worker/factory.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2020-12-24 11:05:00 +0300
committerGitHub <[email protected]>2020-12-24 11:05:00 +0300
commit439c93225d7a9ebaf7cbf1010a54594b906f7d54 (patch)
treeadc7d78e28a9512cb1b1ba85cb4f19dec7d1323d /interfaces/worker/factory.go
parent40b6c3169931a3fef62b649db19ff01dc685b7d4 (diff)
parent62ee1770cc233328300438ffd690ea1d8fc747bb (diff)
Merge pull request #462 from spiral/feature/CLIv2.0.0-alpha29
feature/CLI
Diffstat (limited to 'interfaces/worker/factory.go')
-rw-r--r--interfaces/worker/factory.go6
1 files changed, 4 insertions, 2 deletions
diff --git a/interfaces/worker/factory.go b/interfaces/worker/factory.go
index 8db8ddcc..8412428d 100644
--- a/interfaces/worker/factory.go
+++ b/interfaces/worker/factory.go
@@ -3,16 +3,18 @@ package worker
import (
"context"
"os/exec"
+
+ "github.com/spiral/roadrunner/v2/interfaces/events"
)
// Factory is responsible of wrapping given command into tasks WorkerProcess.
type Factory interface {
// SpawnWorkerWithContext creates new WorkerProcess process based on given command with context.
// Process must not be started.
- SpawnWorkerWithTimeout(context.Context, *exec.Cmd) (BaseProcess, error)
+ SpawnWorkerWithTimeout(context.Context, *exec.Cmd, ...events.EventListener) (BaseProcess, error)
// SpawnWorker creates new WorkerProcess process based on given command.
// Process must not be started.
- SpawnWorker(*exec.Cmd) (BaseProcess, error)
+ SpawnWorker(*exec.Cmd, ...events.EventListener) (BaseProcess, error)
// Close the factory and underlying connections.
Close() error
}