summaryrefslogtreecommitdiff
path: root/factory.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2020-10-13 13:55:20 +0300
committerValery Piashchynski <[email protected]>2020-10-13 13:55:20 +0300
commit0dc44d54cfcc9dd3fa09a41136f35a9a8d26b994 (patch)
treeffcb65010bebe9f5b5436192979e64b2402a6ec0 /factory.go
parent08d6b6b7f773f83b286cd48c1a0fbec9a62fb42b (diff)
Initial commit of RR 2.0v2.0.0-alpha1
Diffstat (limited to 'factory.go')
-rw-r--r--factory.go15
1 files changed, 10 insertions, 5 deletions
diff --git a/factory.go b/factory.go
index 3c304824..482d39f8 100644
--- a/factory.go
+++ b/factory.go
@@ -1,13 +1,18 @@
package roadrunner
-import "os/exec"
+import (
+ "context"
+ "os/exec"
+)
-// Factory is responsible of wrapping given command into tasks worker.
+// Factory is responsible of wrapping given command into tasks WorkerProcess.
type Factory interface {
- // SpawnWorker creates new worker process based on given command.
+ // SpawnWorker creates new WorkerProcess process based on given command.
// Process must not be started.
- SpawnWorker(cmd *exec.Cmd) (w *Worker, err error)
+ SpawnWorkerWithContext(context.Context, *exec.Cmd) (WorkerBase, error)
+
+ SpawnWorker(*exec.Cmd) (WorkerBase, error)
// Close the factory and underlying connections.
- Close() error
+ Close(ctx context.Context) error
}