batchSize

service/msg_process.go

@@ -26,7 +26,8 @@ func MsgProcess(msg string) {
 	msgInfluxProcess(traceMsg)
 }
 
-var pointSlice = make([]*client.Point, 0, 1000)
+var batchSize = 1000
+var pointSlice = make([]*client.Point, 0, batchSize)
 
 func msgInfluxProcess(traceMsgs []TraceMsg) {
 
@@ -64,9 +65,9 @@ func msgInfluxProcess(traceMsgs []TraceMsg) {
 
 		unix := time.Unix(0, traceMsg.Timestamp*1000)
 
-		if len(pointSlice) == 1000 {
+		if len(pointSlice) == batchSize {
 			go batchWrite(pointSlice)
-			pointSlice = make([]*client.Point, 0)
+			pointSlice = make([]*client.Point, 0, batchSize)
 		}
 
 		point, _ := client.NewPoint("trace_info", tags, fields, unix)