fix: a panic error occurs in the func WritePoint when dbserver has be…

…en down (#81) Signed-off-by: LENOVO\zhang <[email protected]> Co-authored-by: ZhangJian He <[email protected]>
openGemini · Jun 28, 2024 · f39ed79 · f39ed79
1 parent a9068f3
commit f39ed79
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/opengemini/write.go b/opengemini/write.go
@@ -87,7 +87,11 @@ func (c *client) WritePoint(ctx context.Context, database string, point *Point,
 
 	resp, err := c.innerWrite(database, &buffer)
 	if err != nil {
-		callback(errors.New("innerWrite request failed, error: " + err.Error()))
+		err := errors.New("innerWrite request failed, error: " + err.Error())
+		if callback != nil {
+			callback(err)
+		}
+		return nil
 	}
 
 	defer resp.Body.Close()