blob: 0ac82158029bf38334101a7cf2f685dc03900bf8 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
|
package worker
import (
"context"
"fmt"
"time"
"github.com/spiral/goridge/v3/interfaces/relay"
"github.com/spiral/roadrunner/v2/internal"
"github.com/spiral/roadrunner/v2/pkg/payload"
)
// Allocator is responsible for worker allocation in the pool
type Allocator func() (BaseProcess, error)
type BaseProcess interface {
fmt.Stringer
// Pid returns worker pid.
Pid() int64
// Created returns time worker was created at.
Created() time.Time
// State return receive-only WorkerProcess state object, state can be used to safely access
// WorkerProcess status, time when status changed and number of WorkerProcess executions.
State() internal.State
// Start used to run Cmd and immediately return
Start() error
// Wait must be called once for each WorkerProcess, call will be released once WorkerProcess is
// complete and will return process error (if any), if stderr is presented it's value
// will be wrapped as WorkerError. Method will return error code if php process fails
// to find or Start the script.
Wait() error
// Stop sends soft termination command to the WorkerProcess and waits for process completion.
Stop() error
// Kill kills underlying process, make sure to call Wait() func to gather
// error log from the stderr. Does not waits for process completion!
Kill() error
// Relay returns attached to worker goridge relay
Relay() relay.Relay
// AttachRelay used to attach goridge relay to the worker process
AttachRelay(rl relay.Relay)
}
type SyncWorker interface {
// BaseProcess provides basic functionality for the SyncWorker
BaseProcess
// Exec used to execute payload on the SyncWorker, there is no TIMEOUTS
Exec(rqs payload.Payload) (payload.Payload, error)
// ExecWithContext used to handle Exec with TTL
ExecWithTimeout(ctx context.Context, p payload.Payload) (payload.Payload, error)
}
|
