Class SftpFileJournal

java.lang.Object

io.leandev.appfuse.file.sftp.SftpFileJournal

All Implemented Interfaces:

FileJournal

public class SftpFileJournal
extends Object
implements FileJournal

SFTP 的 FileJournal 實作

寫入採「一筆事件一個檔案」：

{basePath}/journal/{partition}/{epochMillis}-{uuid}

檔案內容為 JournalLineCodec 序列化的單行。

上述檔名僅是寫入策略，不是讀取格式限制。readEntries(String) 會列出 partition 目錄下的項目， 並逐檔、逐行交由 JournalLineCodec 解析，因此也能讀取 LocalFileJournal 寫入的每日多行 .log。雙向互讀的前提是 Local 與 SFTP 指向同一個實體 journal root。

連線參數與 SftpFileStorage 相同（共用同一 SshClient）。

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SftpFileJournal.Builder

Method Summary

Modifier and Type	Method	Description
static SftpFileJournal.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 SftpFileJournal.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 清單（無資料時回傳空清單）