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
|
package workceptor
// WorkUnit represents a local unit of work.
type WorkUnit interface {
ID() string
UnitDir() string
StatusFileName() string
StdoutFileName() string
Save() error
Load() error
SetFromParams(params map[string]string) error
UpdateBasicStatus(state int, detail string, stdoutSize int64)
UpdateFullStatus(statusFunc func(*StatusFileData))
LastUpdateError() error
Status() *StatusFileData
UnredactedStatus() *StatusFileData
Start() error
Restart() error
Cancel() error
Release(force bool) error
}
type WorkerConfig interface {
GetWorkType() string
GetVerifySignature() bool
NewWorker(bwu BaseWorkUnitForWorkUnit, w *Workceptor, unitID string, workType string) WorkUnit
}
// NewWorkerFunc represents a factory of WorkUnit instances.
type NewWorkerFunc func(bwu BaseWorkUnitForWorkUnit, w *Workceptor, unitID string, workType string) WorkUnit
// StatusFileData is the structure of the JSON data saved to a status file.
// This struct should only contain value types, except for ExtraData.
type StatusFileData struct {
State int
Detail string
StdoutSize int64
WorkType string
ExtraData interface{}
}
|
