/
errors.go
89 lines (74 loc) · 1.65 KB
/
errors.go
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
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
package async
import "fmt"
type errCleaning struct {
workerID string
err error
}
func (e *errCleaning) Error() string {
if e.workerID == "" {
return fmt.Sprintf(
`error cleaning up after dead workers: %s`,
e.err,
)
}
return fmt.Sprintf(
`error cleaning up after dead worker "%s": %s`,
e.workerID,
e.err,
)
}
type errCleanerStopped struct {
err error
}
func (e *errCleanerStopped) Error() string {
if e.err == nil {
return "cleaner stopped"
}
return fmt.Sprintf("cleaner stopped: %s", e.err)
}
type errWorkerStopped struct {
workerID string
err error
}
func (e *errWorkerStopped) Error() string {
if e.err == nil {
return fmt.Sprintf(`worker "%s" stopped`, e.workerID)
}
return fmt.Sprintf(`worker "%s" stopped: %s`, e.workerID, e.err)
}
type errHeartStopped struct {
workerID string
err error
}
func (e *errHeartStopped) Error() string {
if e.err == nil {
return fmt.Sprintf(`worker "%s" heart stopped`, e.workerID)
}
return fmt.Sprintf(`worker "%s" heart stopped: %s`, e.workerID, e.err)
}
type errReceiveAndWorkStopped struct {
workerID string
err error
}
func (e *errReceiveAndWorkStopped) Error() string {
if e.err == nil {
return fmt.Sprintf(`worker "%s" errReceiveAndWork stopped`, e.workerID)
}
return fmt.Sprintf(
`worker "%s" errReceiveAndWork stopped: %s`,
e.workerID,
e.err,
)
}
type errDuplicateJob struct {
name string
}
func (e *errDuplicateJob) Error() string {
return fmt.Sprintf(`duplicate job name "%s"`, e.name)
}
type errJobNotFound struct {
name string
}
func (e *errJobNotFound) Error() string {
return fmt.Sprintf(`no job named "%s" is registered with the worker`, e.name)
}