32 lines · 1.0 KB · TypeScript
RawDownload
/** * OrchestrationReactor - Composite orchestration reactor service interface. * * Coordinates startup of orchestration runtime reactors that translate domain * events into downstream side effects. * * @module OrchestrationReactor */import * as Context from "effect/Context";import type * as Effect from "effect/Effect";import type * as Scope from "effect/Scope"; /** * OrchestrationReactorShape - Service API for orchestration reactor lifecycle. */export interface OrchestrationReactorShape {  /**   * Start orchestration-side reactors for provider/runtime/checkpoint flows.   *   * The returned effect must be run in a scope so all worker fibers can be   * finalized on shutdown.   */  readonly start: () => Effect.Effect<void, never, Scope.Scope>;} /** * OrchestrationReactor - Service tag for orchestration reactor coordination. */export class OrchestrationReactor extends Context.Service<  OrchestrationReactor,  OrchestrationReactorShape>()("t3/orchestration/Services/OrchestrationReactor") {}

Keyboard shortcuts

General

Show keyboard shortcuts
?
Focus the current search
/

Issues and pull requests

Open filters
f

Issues, pull requests and Inbox

Select next item
j↓
Select previous item
k↑
Open selected item
Enter
Dismiss filters or clear selection
Esc

Repository code

Go to file
t