Class LocalFileJournal

java.lang.Object

io.leandev.appfuse.file.local.LocalFileJournal

All Implemented Interfaces:

FileJournal

public class LocalFileJournal
extends Object
implements FileJournal

本地檔案系統的 FileJournal 實作（自訂 TSV 格式，append-only）

日誌與檔案存於同一介質、同一失敗域。寫入佈局為：

{basePath}/journal/{partition}/{yyyy-MM-dd}.log

本地檔案系統支援原子 append，故同一天的事件累積於單一 .log 檔（每行一筆，格式見 JournalLineCodec）。寫入採 best-effort：失敗只記 log、不中斷業務流程。

上述檔名僅是寫入策略，不是讀取格式限制。readEntries(String) 會讀取 partition 目錄下的所有 一般檔案，並逐行交由 JournalLineCodec 解析，因此也能讀取 SftpFileJournal 寫入的「一筆一檔」journal。雙向互讀的前提是 Local 與 SFTP 指向同一個實體 journal root。

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	LocalFileJournal.Builder

Method Summary

Modifier and Type	Method	Description
static LocalFileJournal.Builder	builder()
List<String>	partitions()	列出所有有日誌的 partition，供 FileOrphanSweepTask 逐區對帳
List<JournalEntry>	readEntries(String partition)	讀取指定 partition 的所有事件，供 FileOrphanSweepTask 對帳使用
void	record(JournalEntry entry)	記錄一筆檔案交易事件（append-only，不得拋出例外中斷業務流程）

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

builder

public static LocalFileJournal.Builder builder()

record

public void record(JournalEntry entry)

Description copied from interface: FileJournal

記錄一筆檔案交易事件（append-only，不得拋出例外中斷業務流程）

Specified by:

record in interface FileJournal

Parameters:

entry - 事件

readEntries

public List<JournalEntry> readEntries(String partition)

Description copied from interface: FileJournal

讀取指定 partition 的所有事件，供 FileOrphanSweepTask 對帳使用

Specified by:

readEntries in interface FileJournal

Parameters:

partition - 儲存分區鍵

Returns:

事件清單（依時間排序；無資料時回傳空清單）

partitions

public List<String> partitions()

Description copied from interface: FileJournal

列出所有有日誌的 partition，供 FileOrphanSweepTask 逐區對帳

Specified by:

partitions in interface FileJournal

Returns:

partition 清單（無資料時回傳空清單）