Generated Reference
API Reference
Generated from packages/ts exports and source JSDoc. Choose a package area first; symbol pages keep signatures, parameters, returns, examples, remarks, and source paths together.
Core
23 exports
- batch()
- isTerminalComplete()
- isTerminalError()
- terminalErrorValue()
- depCount()
- isTerminalNone()
- depWaves()
- depBatch()
- depLatest()
- depTerminal()
- Dispatcher
- Node
Graph
32 exports
- normalizeTopology()
- canonicalTopologyJson()
- canonicalTopologyBytes()
- withBlueprintHash()
- withBlueprintProvenance()
- graphBlueprintDiagnostics()
- reactiveCascadingCache()
- pipe()
- reachable()
- explainPath()
- validateNoIslands()
- EnvironmentDrivers
Operators
46 exports
- combine()
- withLatestFrom()
- zip()
- concat()
- race()
- buffer()
- bufferCount()
- sample()
- takeUntil()
- switchMap()
- mergeMap()
- flatMap()
Sources
36 exports
- parseCron()
- matchesCron()
- fromCron()
- fromProcess()
- runProcessWithOptions()
- fromHttp()
- fromHttpWithOptions()
- fromSSE()
- fromSSEWithOptions()
- fromWebSocket()
- fromWebSocketWithOptions()
- fromWebhook()
Data Structures
10 exports
- restoreReactiveList()
- restoreReactiveLog()
- restoreReactiveMap()
- restoreReactiveIndex()
- reactiveIndex()
- reactiveList()
- reactiveLog()
- mergeReactiveLogs()
- scanLog()
- reactiveMap()
Storage
68 exports
- appendLogKey()
- readAppendLogPage()
- appendLogStorage()
- multiWriterAppendLogStorage()
- memoryAppendLog()
- memoryMultiWriterAppendLog()
- hasStoragePutIfAbsent()
- requireStoragePutIfAbsent()
- hasStorageVersioned()
- requireStorageVersioned()
- webStorageBackend()
- memoryBackend()
Adapters
118 exports
- agenticMemoryRecordsSnapshotKey()
- agenticMemoryRecordSnapshotFrame()
- agenticMemoryRecordChangeFrame()
- assertAgenticMemoryRecordSnapshotFrame()
- assertAgenticMemoryRecordChangeFrame()
- loadAgenticMemoryRecordsState()
- persistAgenticMemoryRecords()
- openPersistentAgenticMemoryRecords()
- CanonicalProtobufError
- decodeCanonicalWireBridgeEnvelope()
- decodeCanonicalWireEdgeFrame()
- encodeCanonicalWireEdgeFrame()
Composition
3 exports
Messaging
6 exports
Cqrs
10 exports
- cqrsCommandHandler()
- cqrs()
- cqrsProjection()
- cqrsMessagingRecipe()
- cqrsMessageCommand()
- cqrsMessageAckCommands()
- cqrsEventOutboxCommands()
- cqrsWorkQueueRecipe()
- cqrsSubmitCommand()
- cqrsWorkQueueDispositionCommand()
Orchestration
42 exports
- requestToolProviderAdapterRun()
- toolProviderAdapterRunProjector()
- structuredAgentDecisionInterpreter()
- effectRunCompletionProjector()
- buildToolProviderExecutorOutcome()
- fakeExecutorResult()
- fakeExecutorFailure()
- fakeExecutorBlocked()
- fakeExecutorTimeout()
- fakeExecutorCanceled()
- executorOutcomeViewProjector()
- agentRequestProposalFromDecision()
Patterns
13 exports
- eventFlow()
- eventFlowProjection()
- profileSummary()
- memoryRetrievalBundle()
- knowledgeGraphReducerBundle()
- cosineSimilarity()
- memoryFragmentValidAt()
- memoryFragmentMatchesQuery()
- filterMemoryFragments()
- validateMemoryFragment()
- admissionScored()
- admissionFilter3D()
Solutions
132 exports
- workItemDomainActionAdmissionProjector()
- agenticMemoryBundle()
- agenticMemoryConsolidationApplicationBundle()
- agenticMemoryConsolidationBundle()
- agenticMemoryContextPackingBundle()
- agenticMemoryRecordFrame()
- assertAgenticMemoryRecordFrame()
- agenticMemoryRecordFrameCodec()
- agenticMemoryRecordCodec()
- agenticMemoryKgProjectionBundle()
- agenticMemoryRecordAdmissionBundle()
- admitAgenticMemoryRecordProposals()
Testing
1 exports
Work Queue
1 exports
Inspection
1 exports
Executors
11 exports
- localBuiltinToolProviderBinding()
- localBuiltinToolProviderAdapterPack()
- processToolProviderBinding()
- processToolProviderAdapterPack()
- processToolProviderCatalog()
- httpToolProviderCatalog()
- httpToolProviderRuntime()
- toolProviderExecutionRecipe()
- executorWorkQueueRecipe()
- executorSubmitCommand()
- attachToolProviderAdapterRuntime()
Json
6 exports
Memory
1 exports
Reactive Layout
28 exports
- columnGeometry()
- sanitizeFlowContainer()
- sanitizeFlowColumns()
- sanitizeObstacles()
- blockedIntervalsForBand()
- measurementIssue()
- measurementOk()
- latestMeasurementValue()
- tryMeasureHyphenWidth()
- validMeasurementSize()
- textMeasurementFacts()
- inputNode()
Scoring
4 exports