blob: f491dfa588778ff06b259133d4311ecd1ba4ef1c (
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
|
package roadrunner
const (
// EventCreated thrown when new worker is spawned.
EventCreated = iota
// EventDestruct thrown before worker destruction.
EventDestruct
// EventError thrown any worker related even happen (error passed as context)
EventError
)
// Pool managed set of inner worker processes.
type Pool interface {
// Exec one task with given payload and context, returns result or error.
Exec(rqs *Payload) (rsp *Payload, err error)
// Workers returns worker list associated with the pool.
Workers() (workers []*Worker)
// Destroy all underlying workers (but let them to complete the task).
Destroy()
}
|
