mirrors2/orca
1
0
Fork 0
mirror of https://github.com/zhengkai/orca.git synced 2026-02-04 15:02:26 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix es body close

Browse Source
This commit is contained in:
Zheng Kai
2023-06-14 11:03:43 +08:00
parent 8457bf7efa
commit ba6e6f047c
2 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
server/src/es/insert.go
View File

@@ -25,9 +25,10 @@ func Insert(d *pb.EsMetrics) {
index := indexName(uint32(d.Ts / 1000)) index := indexName(uint32(d.Ts / 1000))
_, err = theClient.Index(index, bytes.NewReader(ab)) re, err := theClient.Index(index, bytes.NewReader(ab))
if err != nil { if err != nil {
zj.W(`insert fail:`, err) zj.W(`insert fail:`, err)
return return
} }
re.Body.Close()
} }

2
server/src/es/test.go
View File

@@ -64,6 +64,6 @@ func Test() {
} }
Insert(d) Insert(d)
time.Sleep(time.Second / 2) time.Sleep(time.Second / 10)
} }
} }