Class AzureFileJournal

java.lang.Object

io.leandev.appfuse.file.azure.AzureFileJournal

All Implemented Interfaces:

FileJournal

public class AzureFileJournal
extends Object
implements FileJournal

Azure Blob 的 FileJournal 實作

採「一筆事件一個 Blob」：

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

Blob 內容為 JournalLineCodec 序列化的單行。readEntries 以 listBlobs 列出後逐一下載。

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AzureFileJournal.Builder

Method Summary

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