Skip to content

Commit 71d7870

Browse files
committed
osiris_log_manifest: Use #chunk_info{} for chunk_written event
1 parent 1c7dbed commit 71d7870

File tree

2 files changed

+5
-6
lines changed

2 files changed

+5
-6
lines changed

src/osiris_log.erl

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2501,8 +2501,10 @@ write_chunk(Chunk,
25012501
counters:put(CntRef, ?C_OFFSET, NextOffset - 1),
25022502
counters:add(CntRef, ?C_CHUNKS, 1),
25032503
maybe_set_first_offset(Next, Cfg),
2504-
Event = {chunk_written, Next, Timestamp, Epoch,
2505-
Cur, Size, NumRecords, Chunk},
2504+
ChunkInfo = #chunk_info{id = Next, timestamp = Timestamp,
2505+
epoch = Epoch, num = NumRecords,
2506+
type = ChType, size = Size, pos = Cur},
2507+
Event = {chunk_written, ChunkInfo, Chunk},
25062508
Manifest = ManifestMod:handle_event(Event, Manifest0),
25072509
State#?MODULE{manifest = {ManifestMod, Manifest},
25082510
mode =

src/osiris_log_manifest.erl

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -9,10 +9,7 @@
99
-type event() :: {segment_opened,
1010
OldSegment :: file:filename_all() | undefined,
1111
NewSegment :: file:filename_all()} |
12-
{chunk_written, osiris:offset(), osiris:timestamp(),
13-
osiris:epoch(), Pos :: non_neg_integer(),
14-
Size :: non_neg_integer(), NumRecords :: non_neg_integer(),
15-
Chunk :: iodata()}.
12+
{chunk_written, #chunk_info{}, iolist()}.
1613

1714
-export_type([state/0, event/0]).
1815

0 commit comments

Comments
 (0)