[libbeat] Fix position writing in the disk queue (elastic#21395)

(cherry picked from commit bb84f3f)
leehinman · Sep 30, 2020 · 136b1d8 · 136b1d8
1 parent 9d5ea60
commit 136b1d8
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
 }