Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Index your code
hub
/
github.com/langchain-ai/langgraphjs
/ functions
Functions
4,051 in github.com/langchain-ai/langgraphjs
⨍
Functions
4,051
◇
Types & classes
1,207
↓ 8 callers
Function
getEnvironmentVariable
(name: string)
libs/sdk/src/utils/env.ts:1
↓ 8 callers
Method
getNode
()
libs/langgraph-core/src/pregel/read.ts:215
↓ 8 callers
Function
getStateTypeSchema
( graph: unknown, registry: SchemaMetaRegistry = schemaMetaRegistry )
libs/langgraph-core/src/graph/zod/schema.ts:81
↓ 8 callers
Function
getSubgraphState
( graph: any, config: any, subgraphName: string )
libs/langgraph-core/src/tests/time_travel.test.ts:34
↓ 8 callers
Method
getTuple
(config: RunnableConfig)
libs/checkpoint-sqlite/src/index.ts:145
↓ 8 callers
Method
handleLLMNewToken
( token: string, _idx: NewTokenIndices, runId: string, _parentRunId?: string, _tags?: stri
libs/langgraph-core/src/pregel/messages.ts:141
↓ 8 callers
Function
injectToolCalls
( stream: AnyStream, target?: SelectorTarget | Signal<SelectorTarget> )
libs/sdk-angular/src/selectors.ts:220
↓ 8 callers
Function
mapSubagentNamespaces
( history: AnyCheckpoint[], toolCallIds: string[], messagesKey = "messages" )
libs/sdk/src/stream/discovery/namespace-from-history.ts:188
↓ 8 callers
Function
metadata
(jsonSchemaExtra: SchemaMeta["jsonSchemaExtra"])
libs/langgraph-core/src/graph/zod/plugin.ts:66
↓ 8 callers
Function
overrideFetchImplementation
(fetch: (...args: any[]) => any)
libs/sdk/src/singletons/fetch.ts:18
↓ 8 callers
Function
prepareOptimisticInput
( raw: Record<string, unknown>, messagesKey: string, mintId: () => string )
libs/sdk/src/stream/optimistic-input.ts:155
↓ 8 callers
Function
pump
( source: AsyncIterable<StreamChunk>, mux: StreamMux )
libs/langgraph-core/src/stream/mux.ts:482
↓ 8 callers
Method
put
( config: RunnableConfig, checkpoint: Checkpoint, metadata: CheckpointMetadata )
libs/checkpoint-sqlite/src/index.ts:383
↓ 8 callers
Method
putWrites
( config: RunnableConfig, writes: PendingWrite[], taskId: string )
libs/langgraph-core/src/tests/utils.ts:102
↓ 8 callers
Function
reconcileMessagesFromValues
({ valueMessages, currentMessages, currentIndexById, previousValueMessageIds, streamedMessageIds,
libs/sdk/src/stream/message-reconciliation.ts:62
↓ 8 callers
Function
safeStringify
(value: unknown)
examples/ui-react/src/utils.ts:43
↓ 8 callers
Function
short
(value: unknown, limit = 120)
examples/streaming/src/api/_shared.ts:54
↓ 8 callers
Function
shouldInterrupt
( checkpoint: Checkpoint, interruptNodes: All | N[], tasks: PregelExecutableTask<N, C>[] )
libs/langgraph-core/src/pregel/algo.ts:127
↓ 8 callers
Method
subagents
()
libs/sdk-angular/src/stream-service.ts:116
↓ 8 callers
Function
takeMemorySnapshot
()
internal/bench/src/utils.ts:218
↓ 8 callers
Function
useMessageMetadata
( stream: AnyStream, messageId: string | undefined )
libs/sdk-react/src/selectors.ts:540
↓ 8 callers
Function
useSuspenseStream
( options: UseStreamOptions<InferStateType<T>> )
libs/sdk-react/src/suspense-stream.ts:127
↓ 8 callers
Function
useToolCalls
( stream: AnyStream, target?: MaybeRefOrGetter<SelectorTarget> )
libs/sdk-vue/src/selectors.ts:179
↓ 7 callers
Method
_emit
( meta: Meta, message: BaseMessage, runId: string | undefined, dedupe = false )
libs/langgraph-core/src/pregel/messages.ts:76
↓ 7 callers
Function
_removeInlineAgentName
(message: T)
libs/langgraph-core/src/prebuilt/agentName.ts:119
↓ 7 callers
Method
addMessageToSubagent
* Add a serialized message to a subagent from stream events. * * This method handles the raw serialized message data from SSE events. * Uses
libs/sdk/src/ui/subagents.ts:748
↓ 7 callers
Function
cardKey
(card: Card)
libs/sdk-react/src/tests/components/ParallelFanoutReconnectStream.tsx:225
↓ 7 callers
Function
cardKey
(card: Card)
libs/sdk-vue/src/tests/components/ParallelFanoutReconnectStream.tsx:23
↓ 7 callers
Function
combineAbortSignals
(...x: (AbortSignal | undefined)[])
libs/langgraph-core/src/pregel/utils/index.ts:155
↓ 7 callers
Function
compactingGraph
(saver: PostgresSaver)
libs/langgraph-core/src/tests/delta_channel.postgres.int.test.ts:119
↓ 7 callers
Function
compareChannelVersions
( a: ChannelVersion, b: ChannelVersion )
libs/checkpoint/src/base.ts:277
↓ 7 callers
Function
createGraph
({ mode, checkSignal, }: { mode: TestMode; checkSignal: boolean; })
libs/langgraph-core/src/tests/pregel/pregel.cancellation.test.ts:67
↓ 7 callers
Function
directMappingState
A checkpoint whose completed push task carries a result ToolMessage.
libs/sdk/src/stream/discovery/namespace-from-history.test.ts:20
↓ 7 callers
Function
discoveryThread
()
libs/sdk/src/stream/controller.test.ts:2073
↓ 7 callers
Function
emit
( ns: Namespace, status: AgentStatus, extras?: { cause?: LifecycleCause; error?: string } )
libs/langgraph-core/src/stream/transformers/lifecycle.ts:306
↓ 7 callers
Function
extensionProjection
( name: string, namespace: readonly string[] )
libs/sdk/src/stream/projections/extension.ts:14
↓ 7 callers
Method
fromConnString
( connString: string, config?: StoreConfig )
libs/checkpoint-redis/src/store.ts:358
↓ 7 callers
Method
getExtendedChannelSchemas
* Returns a modified schema that introspectively looks at all keys of the provided * object schema, and applies the augmentations based on meta pro
libs/langgraph-core/src/graph/zod/meta.ts:187
↓ 7 callers
Method
getHistory
* Fetch a slice of checkpoint history for the bound thread. Used * by branching and time-travel UIs. Optional — omitting it turns * those UIs in
libs/sdk/src/client/stream/transport.ts:131
↓ 7 callers
Function
getInputTypeSchema
( graph: unknown, registry: SchemaMetaRegistry = schemaMetaRegistry )
libs/langgraph-core/src/graph/zod/schema.ts:125
↓ 7 callers
Method
getJsonSchema
* Get the JSON schema for the full state type. * Used by Studio and API for schema introspection.
libs/langgraph-core/src/state/schema.ts:282
↓ 7 callers
Function
getOutputTypeSchema
( graph: unknown, registry: SchemaMetaRegistry = schemaMetaRegistry )
libs/langgraph-core/src/graph/zod/schema.ts:152
↓ 7 callers
Method
getSubagentsByType
* Get all subagents of a specific type.
libs/sdk/src/ui/manager.ts:264
↓ 7 callers
Function
getTablesWithSchema
(schema: string)
libs/checkpoint-postgres/src/sql.ts:46
↓ 7 callers
Function
getTarget
()
libs/sdk-svelte/src/selectors.svelte.ts:368
↓ 7 callers
Method
getTuple
()
libs/checkpoint/src/tests/checkpoints.test.ts:111
↓ 7 callers
Method
getWriters
()
libs/langgraph-core/src/pregel/read.ts:193
↓ 7 callers
Method
handleChainEnd
(outputs: ChainValues, runId: string)
libs/langgraph-core/src/pregel/messages.ts:224
↓ 7 callers
Method
hydrate
* Fetch the checkpointed thread state and seed the root snapshot. * Re-calling with a different `threadId` swaps the underlying * {@link ThreadS
libs/sdk/src/stream/controller.ts:500
↓ 7 callers
Function
idleReconnectStream
( options: IdleReconnectStreamOptions )
libs/sdk/src/utils/stream.ts:125
↓ 7 callers
Function
imagesProjection
( namespace: readonly string[], options?: MediaProjectionOptions )
libs/sdk/src/stream/projections/media.ts:138
↓ 7 callers
Function
inferChannel
(event: Event)
libs/sdk/src/client/stream/subscription.ts:67
↓ 7 callers
Function
isGraphInterrupt
(e?: unknown)
libs/langgraph-core/src/errors.ts:189
↓ 7 callers
Function
isInterruptIdKeyedResume
( resume: unknown, interrupts?: readonly ProtocolInterruptEntry[] )
libs/sdk/src/headless-tools.ts:316
↓ 7 callers
Function
isInterrupted
( values: unknown )
libs/langgraph-core/src/constants.ts:427
↓ 7 callers
Function
jsonishEqual
(previous: unknown, next: unknown)
libs/sdk/src/stream/message-reconciliation.ts:253
↓ 7 callers
Function
label
(resp: ProtocolResponse)
examples/streaming/src/api/commands.ts:49
↓ 7 callers
Function
last
(iter: AsyncIterableIterator<T>)
libs/langgraph-core/src/tests/pregel.test.ts:5713
↓ 7 callers
Function
mapOutputValues
( outputChannels: C | Array<C>, pendingWrites: readonly PendingWrite<C>[] | true, channels: Record<C, Ba
libs/langgraph-core/src/pregel/io.ts:168
↓ 7 callers
Method
markPending
* Mark a set of message ids as optimistically `"pending"`. * * Called from {@link StreamController}'s optimistic submit path right * after th
libs/sdk/src/stream/message-metadata-tracker.ts:278
↓ 7 callers
Function
messages
(v: unknown)
libs/langgraph-core/src/tests/delta_channel.test.ts:789
↓ 7 callers
Function
normalizeHitlInterruptPayload
(value: unknown)
libs/sdk/src/ui/hitl-interrupt-payload.ts:38
↓ 7 callers
Function
normalizeInterruptForClient
( interrupt: Interrupt<T> )
libs/sdk/src/ui/interrupts.ts:9
↓ 7 callers
Function
parseToolOutput
( value: unknown, toolCallId?: string )
libs/sdk/src/client/stream/handles/tools.ts:274
↓ 7 callers
Function
patchCheckpointMap
( config: RunnableConfig, metadata?: CheckpointMetadata )
libs/langgraph-core/src/pregel/utils/index.ts:131
↓ 7 callers
Function
pickFirstString
( record: Record<string, unknown>, keys: string[] )
examples/ui-react/src/components/cards/toolCardUtils.ts:39
↓ 7 callers
Method
putWrites
( config: RunnableConfig, writes: PendingWrite[], taskId: string )
libs/checkpoint-sqlite/src/index.ts:442
↓ 7 callers
Function
recastCheckpointNamespace
(namespace: string)
libs/langgraph-core/src/pregel/utils/config.ts:385
↓ 7 callers
Method
remove
* Removes the metadata associated with a given schema. * @param schema The schema to remove metadata for. * @returns The SchemaMetaRegistry inst
libs/langgraph-core/src/graph/zod/meta.ts:131
↓ 7 callers
Method
removeItem
(key: `lg:stream:${string}`)
libs/sdk/src/ui/types.ts:1318
↓ 7 callers
Function
resolveClientApiUrl
(options: { apiUrl?: string; transport?: "sse" | "websocket" | AgentServerAdapter; })
libs/sdk/src/client/stream/resolve-client-api-url.ts:10
↓ 7 callers
Function
selectFromTarget
* Internal helper that wires a reactive-or-static target into * {@link useProjection}. Encapsulates the bookkeeping every selector * otherwise repea
libs/sdk-svelte/src/selectors.svelte.ts:134
↓ 7 callers
Function
send
( url: string, threadId: string, payload: Record<string, unknown> )
examples/streaming/src/api/commands.ts:36
↓ 7 callers
Function
specTest
( initializer: CheckpointerTestInitializer<T>, filters?: TestTypeFilter[] )
libs/checkpoint-validation/src/spec/index.ts:27
↓ 7 callers
Function
stop
()
libs/sdk-vue/src/use-video-player.ts:130
↓ 7 callers
Method
subgraphs
()
libs/sdk-angular/src/stream-service.ts:124
↓ 7 callers
Method
switchThread
* Switch to a different thread (or clear the current thread). * Clears the active stream, cancels all queued runs on the previous * thread, fetc
libs/sdk/src/ui/orchestrator.ts:1189
↓ 7 callers
Function
tasksWithWrites
( tasks: PregelTaskDescription[] | readonly PregelExecutableTask<N, C>[], pendingWrites: CheckpointPending
libs/langgraph-core/src/pregel/debug.ts:270
↓ 7 callers
Function
toChatModelStreamEvent
(event: MessagesEvent)
libs/sdk/src/client/stream/messages.ts:660
↓ 7 callers
Function
useAudioPlayer
( media: AudioMedia | undefined, options?: UseAudioPlayerOptions )
libs/sdk-react/src/use-audio-player.ts:449
↓ 7 callers
Function
useChannel
( stream: AnyStream, channels: readonly Channel[], target?: SelectorTarget, options?: UseChannelOption
libs/sdk-react/src/selectors.ts:410
↓ 7 callers
Method
validate
(interrupt?: string[])
libs/langgraph-core/src/graph/graph.ts:599
↓ 7 callers
Function
valuesEvent
(messages: unknown[], seq: number)
libs/sdk/src/stream/controller.test.ts:113
↓ 7 callers
Function
wrap
(color: ConsoleColors, text: string)
libs/langgraph-core/src/pregel/debug.ts:53
↓ 6 callers
Method
#commit
()
libs/sdk/src/stream/discovery/subagents.ts:166
↓ 6 callers
Method
#subscribeRaw
( params: SubscribeParams, options: { unwrapNamedCustom?: boolean } = {} )
libs/sdk/src/client/stream/index.ts:1732
↓ 6 callers
Function
_generateKey
( threadId: string, checkpointNamespace: string, checkpointId: string )
libs/checkpoint/src/memory.ts:91
↓ 6 callers
Function
_isBaseChatModel
(model: LanguageModelLike)
libs/langgraph-core/src/prebuilt/react_agent_executor.ts:170
↓ 6 callers
Function
_isConfigurableModel
(model: any)
libs/langgraph-core/src/prebuilt/react_agent_executor.ts:185
↓ 6 callers
Method
appendOptimistic
* Append messages applied optimistically by a local `submit()`, * keyed by id so the eventual server echo reconciles cleanly. * * Unlike {@li
libs/sdk/src/stream/root-message-projection.ts:523
↓ 6 callers
Function
assert
(a: boolean)
libs/langgraph-core/src/hash.ts:77
↓ 6 callers
Method
call
( state: typeof StateAnnotation.State | Command )
libs/langgraph-core/src/tests/python_port/graph_structure.test.ts:622
↓ 6 callers
Method
cancelQueued
* Cancel a queued submission by id. Returns `true` when the entry * was found and removed, `false` otherwise. * * Today this only removes the
libs/sdk/src/stream/controller.ts:1183
↓ 6 callers
Function
cardKey
(card: Card)
libs/sdk-angular/src/tests/components/ParallelFanoutReconnectStream.ts:29
↓ 6 callers
Function
checkpointState
(ns: string, id: string)
libs/sdk/src/stream/controller.test.ts:2088
↓ 6 callers
Method
createCheckpointer
* Called before each set of validations is run. The checkpointer returned will be used during test execution. * * @returns A new checkpointer, o
libs/checkpoint-validation/src/types.ts:37
↓ 6 callers
Function
createErroringStream
( chunks: Array<{ id?: string; event: string; data: unknown }>, error: Error )
libs/sdk/src/utils/stream-retry.test.ts:47
↓ 6 callers
Function
createLargeDataset
(outerCount: number, innerCount: number)
internal/bench/src/index.bench.test.ts:91
↓ 6 callers
Function
createValuesTransformer
( path: Namespace )
libs/langgraph-core/src/stream/transformers/values.ts:19
↓ 6 callers
Method
destroyCheckpointer
* Called after each set of validations is run. Use this to clean up any resources that your checkpointer may * have been using. This should include
libs/checkpoint-validation/src/types.ts:45
← previous
next →
401–500 of 4,051, ranked by callers