-
Notifications
You must be signed in to change notification settings - Fork 0
/
store.go
38 lines (30 loc) · 802 Bytes
/
store.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
package main
import "sync"
type failureInfo struct {
numFailures int
failedURLs []string
}
type store struct {
lock sync.RWMutex
failureCount map[int]*failureInfo // Key: build number
}
func newStore() *store {
return &store{
failureCount: make(map[int]*failureInfo),
}
}
func (s *store) get(buildNumber int) *failureInfo {
s.lock.RLock()
defer s.lock.RUnlock()
return s.failureCount[buildNumber]
}
func (s *store) push(buildNumber int, jobURL string) *failureInfo {
s.lock.Lock()
defer s.lock.Unlock()
if s.failureCount[buildNumber] == nil {
s.failureCount[buildNumber] = &failureInfo{}
}
s.failureCount[buildNumber].numFailures++
s.failureCount[buildNumber].failedURLs = append(s.failureCount[buildNumber].failedURLs, jobURL)
return s.failureCount[buildNumber]
}