JAYICE c1e39b2cef lib/persistentqueue: flush pending persistent queue data to chunk file before updating metadata ...

Previously, reader could advance writer offset at metadata without actual data write.
It may produce corrupted persistent queue, if vmagent crashed.

 This commit changes flush behavior to perform f-sync flush, only if there is some recently written data.

Related to https://github.com/VictoriaMetrics/VictoriaMetrics/issues/11192

2026-07-10 17:52:30 +02:00

..

fastqueue_test.go

app/vmagent: prioritise recently ingested data to the queue

2026-06-19 13:47:49 +02:00

fastqueue_timing_test.go

lib/persistentqueue: run go fix -rangeint

2026-02-18 14:28:31 +01:00

fastqueue.go

app/vmagent: prioritise recently ingested data to the queue

2026-06-19 13:47:49 +02:00

filenames.go

lib/{fs,persistentqueue}: use filepath.Join() instead of concatenating path parts with /

2023-04-13 20:13:45 -07:00

persistentqueue_synctest_test.go

lib/persistentqueue: flush pending persistent queue data to chunk file before updating metadata

2026-07-10 17:52:30 +02:00

persistentqueue_test.go

all: run go fix -fmtappendf

2026-02-18 18:21:02 +01:00

persistentqueue_timing_test.go

lib/persistentqueue: run go fix -rangeint

2026-02-18 14:28:31 +01:00

persistentqueue.go

lib/persistentqueue: flush pending persistent queue data to chunk file before updating metadata

2026-07-10 17:52:30 +02:00