[libbeat] Fix position writing in the disk queue

leehinman · Sep 29, 2020 · bb84f3f · bb84f3f
1 parent e6c3d89
commit bb84f3f
Showing 1 changed file with 9 additions and 7 deletions.
diff --git a/libbeat/publisher/queue/diskqueue/state_file.go b/libbeat/publisher/queue/diskqueue/state_file.go
@@ -82,12 +82,14 @@ func writeQueuePositionToHandle(
 	}
 
 	// Want to write: version (0), segment id, segment offset.
-	elems := []interface{}{uint32(0), position.segmentID, position.offset}
-	for _, elem := range elems {
-		err = binary.Write(file, binary.LittleEndian, &elem)
-		if err != nil {
-			return err
-		}
+	err = binary.Write(file, binary.LittleEndian, uint32(0))
+	if err != nil {
+		return err
+	}
+	err = binary.Write(file, binary.LittleEndian, position.segmentID)
+	if err != nil {
+		return err
 	}
-	return nil
+	err = binary.Write(file, binary.LittleEndian, position.offset)
+	return err
 }