Class ContinuationPersistence

constructor

• new ContinuationPersistence(
      store: ContinuationStore,
      options: { maxBytes: number; runStep?: <T>(step: () => T) => Promise<T> },
  ): ContinuationPersistence

  Parameters

  • store: ContinuationStore
  • options: { maxBytes: number; runStep?: <T>(step: () => T) => Promise<T> }

    • maxBytes: number

    • OptionalrunStep?: <T>(step: () => T) => Promise<T>

      Optional owner-thread preparation hook; disk writes use the CPU worker.

  Returns ContinuationPersistence

Readonlystore

stats

• get stats(): {
      dropped: number;
      failed: number;
      pendingBytes: number;
      pendingCount: number;
  }

  Returns { dropped: number; failed: number; pendingBytes: number; pendingCount: number }

begin

• begin(key: string): ContinuationAttempt

  Parameters

  • key: string

  Returns ContinuationAttempt

canRestore

• canRestore(key: string): boolean

  A completed response is ineligible immediately, before queued unlink.

  Parameters

  • key: string

  Returns boolean

complete

• complete(attempt: ContinuationAttempt): void

  Parameters

  • attempt: ContinuationAttempt

  Returns void

enqueue

• enqueue(
      attempt: ContinuationAttempt,
      state: Omit<ContinuationState, "seed">,
      metadata: {
          cacheNs: string;
          generatedTokens: number;
          key: string;
          originalPromptTokens: number;
          pendingToken: number;
          seed: number;
          seedWasExplicit: boolean;
      },
  ): void

  Takes ownership even when a completed/superseded attempt declines it.

  Parameters

  • attempt: ContinuationAttempt
  • state: Omit<ContinuationState, "seed">
  • metadata: {
        cacheNs: string;
        generatedTokens: number;
        key: string;
        originalPromptTokens: number;
        pendingToken: number;
        seed: number;
        seedWasExplicit: boolean;
    }

    • cacheNs: string

    • generatedTokens: number

    • key: string

    • originalPromptTokens: number

    • pendingToken: number

    • seed: number

      Actual sampler seed, including a server-generated default. Required to continue the random stream exactly after a restart.

    • seedWasExplicit: boolean

      True when seed was part of the client request rather than generated by the server.

  Returns void

flush

• flush(): Promise<{ durable: boolean; failed: number; pendingBytes: number }>

  Returns Promise<{ durable: boolean; failed: number; pendingBytes: number }>

release

• release(attempt: ContinuationAttempt): void

  Request cancellation/disposal preserves queued and durable state.

  Parameters

  • attempt: ContinuationAttempt

  Returns void