Commit 111a3dc 1 parent 9cc81dd commit 111a3dc Copy full SHA for 111a3dc
File tree 1 file changed +1
-3
lines changed
1 file changed +1
-3
lines changed Original file line number Diff line number Diff line change @@ -21,7 +21,6 @@ func WaitDBStartUp(db *sql.DB) {
21
21
// DBDisconnectDetector DBから切断されるとアプリを強制終了する検出器
22
22
type DBDisconnectDetector struct {
23
23
db []* sql.DB
24
- d int
25
24
t * Ticker
26
25
r time.Duration
27
26
s chan struct {}
@@ -36,13 +35,12 @@ NewDBDisconnectDetector 新たなDBDisconnectDetectorを作成
36
35
func NewDBDisconnectDetector (durationSec , pauseSec int ) * DBDisconnectDetector {
37
36
d := DBDisconnectDetector {
38
37
db : make ([]* sql.DB , 0 ),
39
- d : durationSec ,
40
38
r : time .Second * time .Duration (pauseSec ),
41
39
s : make (chan struct {}),
42
40
st : false ,
43
41
}
44
42
45
- d .t = NewTicker (d . d * 1000 , func () {
43
+ d .t = NewTicker (durationSec * 1000 , func () {
46
44
for _ , db := range d .db {
47
45
err := db .Ping ()
48
46
if err != nil {
You can’t perform that action at this time.
0 commit comments