blob: a956aabb1aeac9f6a17d9c3fd118cb2bde753aa6 (
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
|
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 {
// Observe all caused events to attached watcher.
Observe(o func(event int, ctx 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()
}
|
