PersistIntervalInstance

Implements IPersistIntervalInstance

Default file-based implementation of IPersistIntervalInstance.

Features:

• Wraps PersistBase for atomic JSON writes
• Soft delete via removed: true flag
• listIntervalData filters out removed markers

Constructor

constructor(bucket: string);
Copy

Properties

bucket

bucket: string
Copy

_storage

_storage: any
Copy

Underlying file-based storage for this bucket

Methods

waitForInit

waitForInit(initial: boolean): Promise<void>;
Copy

Initializes the underlying PersistBase storage.

readIntervalData

readIntervalData(key: string): Promise<IntervalData | null>;
Copy

Reads an interval marker by key. Returns null if marker is missing or soft-deleted.

writeIntervalData

writeIntervalData(data: IntervalData, key: string): Promise<void>;
Copy

Writes an interval marker under the given key.

removeIntervalData

removeIntervalData(key: string): Promise<void>;
Copy

Soft-deletes a marker by writing removed: true flag while preserving the file. Subsequent reads will return null, allowing the interval to fire again.

listIntervalData

listIntervalData(): AsyncGenerator<string>;
Copy

Iterates all markers in the bucket, yielding keys of non-removed markers only.