Class S3FileJournal

java.lang.Object

io.leandev.appfuse.file.s3.S3FileJournal

All Implemented Interfaces:

FileJournal

public class S3FileJournal
extends Object
implements FileJournal

S3 的 FileJournal 實作

S3 物件不支援 append，故採「一筆事件一個物件」(append-safe)：

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

物件內容為 JournalLineCodec 序列化的單行。readEntries 以 ListObjectsV2 列出後逐一 GET。

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	S3FileJournal.Builder

Method Summary

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