Class PersistIntervalInstance

constructor

• new PersistIntervalInstance(bucket: string): PersistIntervalInstance

  Creates new interval marker persistence instance.

  Parameters

  • bucket: string

    Marker bucket identifier

  Returns PersistIntervalInstance

Readonlybucket

listIntervalData

• listIntervalData(): AsyncGenerator<string>

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

  Returns AsyncGenerator<string>

  AsyncGenerator yielding marker keys

readIntervalData

• readIntervalData(key: string): Promise<IntervalData>

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

  Parameters

  • key: string

    Marker key within the bucket

  Returns Promise<IntervalData>

  Promise resolving to stored data, or null

removeIntervalData

• removeIntervalData(key: string): Promise<void>

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

  Parameters

  • key: string

    Marker key within the bucket

  Returns Promise<void>

  Promise that resolves when removal is complete

waitForInit

• waitForInit(initial: boolean): Promise<void>

  Initializes the underlying PersistBase storage.

  Parameters

  • initial: boolean

    Whether this is the first initialization

  Returns Promise<void>

  Promise that resolves when initialization is complete

writeIntervalData

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

  Writes an interval marker under the given key.

  Parameters

  • data: IntervalData

    Data to store
  • key: string

    Marker key within the bucket

  Returns Promise<void>

  Promise that resolves when write is complete