ayo/gocommon
8
0
Fork 1
Code Issues Pull Requests Projects Releases Wiki Activity

로그 추가

Browse Source
This commit is contained in:
mountain
2025-09-09 23:47:33 +09:00
parent a434b9bf84
commit 54eab23eb2
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
opensearch/client.go
View File

@ -144,12 +144,13 @@ func (c *Client) sendLoop(ctx context.Context) {
if err != nil { if err != nil {
if netoperr, ok := err.(*net.OpError); ok && netoperr.Op == "dial" { if netoperr, ok := err.(*net.OpError); ok && netoperr.Op == "dial" {
// 접속 안됨. 파일로 남기고 끝 // 접속 안됨. 파일로 남기고 끝
logger.Println("log send bulk failed :", err) logger.Println("log send bulk failed. no retry :", err)
for _, e := range sending { for _, e := range sending {
logger.Println(string(e)) logger.Println(string(e))
} }
} else { } else {
// 재시도 // 재시도
logger.Println("log send bulk failed. retry :", err)
failChan <- sending failChan <- sending
} }
return return