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 以 readDir 列出後逐一讀取。

連線參數與 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 清單（無資料時回傳空清單）