blob: 299ac95fe24219d2020c812b0075085d67f3a6cf (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
|
package transport
import (
"context"
"os/exec"
"github.com/spiral/roadrunner/v2/pkg/events"
"github.com/spiral/roadrunner/v2/pkg/worker"
)
// 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, ...events.Listener) (*worker.Process, error)
// SpawnWorker creates new WorkerProcess process based on given command.
// Process must not be started.
SpawnWorker(*exec.Cmd, ...events.Listener) (*worker.Process, error)
// Close the factory and underlying connections.
Close() error
}
|
