Class DurableObjectRunner<TEnv>`Abstract`

Type Parameters

TEnv = unknown

Index

Constructors

Properties

Methods

alarm build fetch runLifecycle runOwnership scheduleSource webSocketClose webSocketError webSocketMessage workflowRemoteSteps

Constructors

constructor

new DurableObjectRunner<TEnv = unknown>(
state: DurableObjectRunnerState | undefined,
env: TEnv,
): DurableObjectRunner<TEnv>
Type Parameters
- TEnv = unknown
Parameters
- state: DurableObjectRunnerState | undefined
- env: TEnv
Returns DurableObjectRunner<TEnv>
- Defined in packages/flowsafe/src/do-runner/durable-object.ts:457

Properties

`Protected` `Readonly`env

env: TEnv

`Protected` `Optional` `Readonly`state

state?: DurableObjectRunnerState

Absent in Node tests; present under workerd for storage and the alarm.

Methods

alarm

alarm(): Promise<void>
Returns Promise<void>
- Defined in packages/flowsafe/src/do-runner/durable-object.ts:2462

`Protected` `Abstract`build

build(env: TEnv): RunnerRuntime
Define workflows via init() and return its runtime. Called once, lazily.
Parameters
- env: TEnv
Returns RunnerRuntime
- Defined in packages/flowsafe/src/do-runner/durable-object.ts:463

fetch

fetch(request: Request): Promise<Response>
Parameters
- request: Request
Returns Promise<Response>
- Defined in packages/flowsafe/src/do-runner/durable-object.ts:491

`Protected`runLifecycle

runLifecycle(_env: TEnv): DurableObjectRunLifecycleHooks | undefined
Required when the host exposes terminate or deadline lifecycle routes. Its optional reconcileApprovals files the approvals the object reaches from its alarm, or from a resume refused because its step moved on.
Parameters
- _env: TEnv
Returns DurableObjectRunLifecycleHooks | undefined
- Defined in packages/flowsafe/src/do-runner/durable-object.ts:485

`Protected` `Abstract`runOwnership

runOwnership(env: TEnv): DurableObjectRunOwnershipStore
The deployment-local ownership registry used for recoverable run starts.
Parameters
- env: TEnv
Returns DurableObjectRunOwnershipStore
- Defined in packages/flowsafe/src/do-runner/durable-object.ts:473

`Protected`scheduleSource

scheduleSource(_env: TEnv): ScheduleSourceStore | undefined
Existing schedules domain used only for target-verifiable schedule fires.
Parameters
- _env: TEnv
Returns ScheduleSourceStore | undefined
- Defined in packages/flowsafe/src/do-runner/durable-object.ts:476

webSocketClose

webSocketClose(_ws: WebSocketLike, _code: number, _reason: string): void
Parameters
- _ws: WebSocketLike
- _code: number
- _reason: string
Returns void
- Defined in packages/flowsafe/src/do-runner/durable-object.ts:3302

webSocketError

webSocketError(_ws: WebSocketLike, _error: unknown): void
Parameters
- _ws: WebSocketLike
- _error: unknown
Returns void
- Defined in packages/flowsafe/src/do-runner/durable-object.ts:3306

webSocketMessage

webSocketMessage(ws: WebSocketLike, message: string | ArrayBuffer): void
Parameters
- ws: WebSocketLike
- message: string | ArrayBuffer
Returns void
- Defined in packages/flowsafe/src/do-runner/durable-object.ts:3295

`Protected`workflowRemoteSteps

workflowRemoteSteps(
_env: TEnv,
_runtime: RunnerRuntime,
): Promise<WorkflowRemoteStepContinuationReader | undefined>
Parameters
- _env: TEnv
- _runtime: RunnerRuntime
Returns Promise<WorkflowRemoteStepContinuationReader | undefined>
- Defined in packages/flowsafe/src/do-runner/durable-object.ts:465