-
Notifications
You must be signed in to change notification settings - Fork 0
/
error_container.go
76 lines (55 loc) · 1.41 KB
/
error_container.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
package actions
import "fmt"
type errorReport struct {
errors []error
actionType string
name string
retries int
passed bool
action string
}
func (er *errorReport) push(err error) *errorReport {
er.errors = append(er.errors, err)
er.retries = er.retries + 1
return er
}
func (er *errorReport) pass() *errorReport {
er.passed = true
return er
}
type errorContainer struct {
reports map[string]*errorReport
errorCount int
}
func (ec *errorContainer) push(action string, name string, err error) *errorContainer {
errorReport, valid := ec.reports[ec.key(action, name)]
if valid {
ec.reports[ec.key(action, name)] = errorReport.push(err)
return ec
}
ec.reports[ec.key(action, name)] = newErrorReport(action, name, err)
ec.errorCount = ec.errorCount + 1
return ec
}
func (ec *errorContainer) clear(action, name string) {
errorReport, valid := ec.reports[ec.key(action, name)]
if valid && ec.errorCount > 0 {
ec.errorCount = ec.errorCount - 1
}
ec.reports[ec.key(action, name)] = errorReport.pass()
}
func (ec *errorContainer) hasErrors() bool {
return ec.errorCount > 0
}
func (ec *errorContainer) list() []string {
list := []string{}
for _, errorReport := range ec.reports {
if !errorReport.passed {
list = append(list, errorReport.name)
}
}
return list
}
func (ec *errorContainer) key(action, name string) string {
return fmt.Sprintf("%v-%v", action, name)
}