JournalBufferWriter Methods

Base class for in-memory journal buffers used to assemble a pending journal batch.

CreateJournalStreamWriter(JournalStreamId)

public JournalStreamWriter CreateJournalStreamWriter(JournalStreamId streamId)

Creates a writer for entries belonging to streamId.

A journal stream writer for the specified state.

public void Dispose()

Releases resources used by this writer.

abstract

protected abstract void FinishEntry(JournalStreamId streamId)

Writes any format-owned entry suffix or patches framing bytes.

public ArcBuffer GetBuffer()

Gets a pinned snapshot of the accumulated journal bytes which are safe to persist.

An ArcBuffer containing the accumulated journal bytes. The caller owns and must dispose the returned buffer.

protected byte GetEntryByte(int offset)

Gets a byte at the specified offset in the active entry.

public void Reset()

Clears all buffered data so the writer can be reused for another batch.

virtual

protected virtual void StartEntry(JournalStreamId streamId)

Writes any format-owned entry prefix and prepares the payload writer.

protected void WriteAt(int offset, ReadOnlySpan<byte> value)

Patches format-owned framing bytes at the specified offset in the active entry.

virtual

protected virtual void WritePreservedEntry(JournalStreamId streamId, IPreservedJournalEntry entry)

Appends a format-owned entry for retired or unknown state preservation.