transport

Documentation

Index

• type Factory

Types

type Factory

type Factory interface {
	// SpawnWorkerWithTimeout 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
}

Factory is responsible for wrapping given command into tasks WorkerProcess.