Skip to content

Commit d3b5a78

Browse files
committed
chore: replace deprecated apis
1 parent 3a583b6 commit d3b5a78

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

pkg/manager/manager.go

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ package manager
44
import (
55
"encoding/json"
66
"fmt"
7-
"io/ioutil"
7+
"io"
88
"os"
99
"time"
1010

@@ -64,9 +64,9 @@ func fromCheckpoint(checkpointFile string) (*CheckPoint, error) {
6464
if err != nil {
6565
return nil, err
6666
}
67-
defer jsonFile.Close()
67+
defer func() { _ = jsonFile.Close() }()
6868

69-
data, err := ioutil.ReadAll(jsonFile)
69+
data, err := io.ReadAll(jsonFile)
7070
if err != nil {
7171
return nil, err
7272
}
@@ -89,8 +89,8 @@ func NewManager(config *config.Config) (*Manager, error) {
8989
if err != nil {
9090
logger.Info("failed to parse checkpoint file")
9191
} else {
92-
for worker, info := range checkpoint.WorkerInfo {
93-
workersLastInvokeTime[worker] = info.LastInvokeTime
92+
for name, info := range checkpoint.WorkerInfo {
93+
workersLastInvokeTime[name] = info.LastInvokeTime
9494
}
9595
}
9696
newManager := Manager{
@@ -131,7 +131,7 @@ func (m *Manager) checkpoint() error {
131131
return err
132132
}
133133
ckpt := fmt.Sprintf("%s.tmp", m.config.Checkpoint)
134-
err = ioutil.WriteFile(ckpt, file, 0644)
134+
err = os.WriteFile(ckpt, file, 0644)
135135
if err != nil {
136136
return err
137137
}

0 commit comments

Comments
 (0)