MCPcopy Index your code

hub / github.com/langchain-ai/langgraphjs / functions

Functions4,051 in github.com/langchain-ai/langgraphjs

⨍ Functions 4,051◇ Types & classes 1,207
↓ 18 callersFunctioncreateLifecycleTransformer
( options: LifecycleTransformerOptions = {} )
libs/langgraph-core/src/stream/transformers/lifecycle.ts:180
↓ 18 callersMethodemit
(meta: Meta, data: ChatModelStreamEvent, runId?: string)
libs/langgraph-core/src/pregel/messages-v2.ts:167
↓ 18 callersFunctionfetch
(input, init)
libs/sdk/src/client/stream/transport/http.test.ts:79
↓ 18 callersFunctionisRootNamespace
(namespace: readonly string[])
libs/sdk/src/stream/namespace.ts:13
↓ 18 callersMethodlocal
* Create an in-process-only channel. Values remain available through * `run.extensions.<key>` but are not forwarded to remote clients.
libs/langgraph-core/src/stream/stream-channel.ts:83
↓ 17 callersFunction_runWithRetry
( // eslint-disable-next-line @typescript-eslint/no-explicit-any pregelTask: PregelExecutableTask<N, C>,
libs/langgraph-core/src/pregel/retry.ts:67
↓ 17 callersFunctionassertSafeStorageKey
* Asserts that a value sourced from {@link RunnableConfig.configurable} (or * any other caller-influenced position) is safe to use as a property key
libs/checkpoint/src/memory.ts:60
↓ 17 callersFunctionflushPendingHeadlessToolInterrupts
( values: Record<string, unknown> | null | undefined, tools: HeadlessToolImplementation[] | undefined, h
libs/sdk/src/headless-tools.ts:469
↓ 17 callersMethodgetSubagentsByMessage
* Get all subagents triggered by a specific AI message.
libs/sdk/src/ui/manager.ts:271
↓ 17 callersFunctioninstallTransformer
( mux: StreamMux, transformer: NativeStreamTransformer<unknown> )
libs/langgraph-core/src/stream/transformers/lifecycle.test.ts:34
↓ 17 callersFunctionisLifecycle
(event: ProtocolEvent)
libs/langgraph-core/src/stream/transformers/lifecycle.test.ts:30
↓ 17 callersMethodonError
()
libs/sdk/src/client/stream/transport/websocket.ts:185
↓ 17 callersMethodsend
* Sends a command and optionally returns an immediate response. * * @param command - Protocol command to send over the transport.
libs/sdk/src/client/stream/transport.ts:62
↓ 17 callersMethodsetup
()
libs/checkpoint-redis/src/store.ts:380
↓ 17 callersFunctionsleep
(ms: number, signal?: AbortSignal)
libs/langgraph-core/src/tests/timeout.test.ts:32
↓ 16 callersFunctionBytesLineDecoder
()
libs/sdk/src/utils/sse.ts:9
↓ 16 callersMethod_emit
( values: Array<[StreamMode, unknown]>, namespace: string[] = this.checkpointNamespace )
libs/langgraph-core/src/pregel/loop.ts:1620
↓ 16 callersMethodcreate
* Create a run. * * @param threadId The ID of the thread. * @param assistantId Assistant ID to use for this run. * @param payload Payload
libs/sdk/src/client/runs/index.ts:131
↓ 16 callersFunctiondrainEvents
(mux: StreamMux)
libs/langgraph-core/src/stream/transformers/lifecycle.test.ts:41
↓ 16 callersFunctionfilterHistoryByNext
( history: StateSnapshot[], node: string )
libs/langgraph-core/src/tests/time_travel_helpers.ts:90
↓ 16 callersMethodmatchesFilter
* Evaluates if a document matches the given filter criteria. * Supports advanced operators like $gt, $lt, $in, etc.
libs/checkpoint-redis/src/store.ts:73
↓ 16 callersMethodrevoke
* Revoke the currently-cached object URL (if any). Subsequent * accesses to {@link objectURL} create a fresh URL from the Blob. * Idempotent.
libs/sdk/src/client/stream/media.ts:135
↓ 16 callersFunctionsetupValidGraph
()
libs/langgraph-core/src/pregel/validate.test.ts:23
↓ 15 callersFunction_applyWrites
( checkpoint: Checkpoint, channels: Cc, tasks: WritesProtocol<keyof Cc>[], // eslint-disable-next-line
libs/langgraph-core/src/pregel/algo.ts:269
↓ 15 callersFunction_getOverwriteValue
( value: unknown )
libs/langgraph-core/src/constants.ts:375
↓ 15 callersFunctionall
(value: T)
libs/langgraph-core/src/tests/interrupt.test-d.ts:8
↓ 15 callersMethodcancel
(id: string)
libs/sdk-vue/src/selectors.ts:512
↓ 15 callersFunctioncheckpointSummary
(history: any[])
libs/langgraph-core/src/tests/time_travel.test.ts:20
↓ 15 callersFunctioncreateMessagesTransformer
( path: Namespace, nodeFilter?: string )
libs/langgraph-core/src/stream/transformers/messages.ts:43
↓ 15 callersFunctionformatMessage
(message: BaseMessage)
libs/sdk-vue/src/tests/components/format.ts:12
↓ 15 callersMethodinitThreadId
* Trigger initial history fetch for the current thread ID. * Should be called once after construction when the initial threadId is known.
libs/sdk/src/ui/orchestrator.ts:378
↓ 15 callersMethodrecordMessages
* Record metadata for a list of messages. * * Skips messages whose existing entry already matches `metadata`; * those without an `id` (or wit
libs/sdk/src/stream/message-metadata-tracker.ts:245
↓ 15 callersMethodreset
()
libs/sdk-vue/src/use-video-player.ts:33
↓ 15 callersFunctionserialize
(runnable: Runnable | Promise<Runnable>)
libs/langgraph-core/src/tests/prebuilt.test.ts:3344
↓ 15 callersFunctionstreamWithRetry
( makeRequest: (params?: StreamRequestParams) => Promise<{ response: Response; stream: ReadableStrea
libs/sdk/src/utils/stream.ts:219
↓ 15 callersMethodtoolCalls
()
libs/sdk-angular/src/stream-service.ts:84
↓ 15 callersMethodunsubscribe
()
libs/sdk/src/client/stream/types.ts:170
↓ 14 callersFunctionareSetsEqual
(a: Set<T>, b: Set<T>)
libs/langgraph-core/src/channels/named_barrier_value.ts:4
↓ 14 callersMethodbufferCheckpoint
* Buffer a `checkpoints` event for later pairing with its values * companion. * * Defensive against missing / malformed payloads: * *
libs/sdk/src/stream/message-metadata-tracker.ts:197
↓ 14 callersFunctionbuildCounterGraph
()
libs/langgraph-core/src/tests/pregel.stream.test.ts:42
↓ 14 callersMethodconsumeCheckpoint
* Read-and-clear the buffered checkpoint envelope for `namespace`. * * Always pairs with a single {@link bufferCheckpoint} call: a values * e
libs/sdk/src/stream/message-metadata-tracker.ts:223
↓ 14 callersFunctioncreateThreadState
( values: Values, overrides: Partial<ThreadState<Values>> = {} )
libs/sdk/src/ui/messages.test.ts:20
↓ 14 callersMethodextend
* Extends or sets the metadata for a given schema. * @template TValue The value type of the schema. * @template TUpdate The update type of the s
libs/langgraph-core/src/graph/zod/meta.ts:116
↓ 14 callersFunctiongatherStream
(stream: AsyncGenerator<T>)
libs/sdk/src/client/runs/stream.test.ts:75
↓ 14 callersFunctiongetCurrentTaskInput
( config?: LangGraphRunnableConfig )
libs/langgraph-core/src/pregel/utils/config.ts:360
↓ 14 callersFunctionisNodeTimeoutError
(e?: unknown)
libs/langgraph-core/src/errors.ts:278
↓ 14 callersFunctionmakeRootBus
()
libs/sdk/src/stream/channel-registry.test.ts:20
↓ 14 callersFunctionmakeTrace
()
libs/sdk/src/stream/channel-registry.test.ts:55
↓ 14 callersFunctionopen
({ thread, store, rootBus })
libs/sdk/src/stream/projections/media.ts:59
↓ 14 callersMethodregisterFromToolCalls
* Register new subagent(s) from AI message tool calls. * * Called when an AI message is received with tool calls. * Creates pending subagent
libs/sdk/src/ui/subagents.ts:564
↓ 14 callersMethodrequestDrain
* Request that the current run drain cooperatively, stopping at the next * superstep boundary. Does not cancel work that is already running. *
libs/langgraph-core/src/pregel/runtime.ts:52
↓ 14 callersFunctionrunGraph
( graph: AnyStateGraph, input: Record<string, unknown> )
internal/bench/src/utils.ts:22
↓ 14 callersMethodsetThreadId
* Rebind this transport to a different thread. * * `client.threads.stream(threadId, { transport })` calls this (when * implemented) whenever
libs/sdk/src/client/stream/transport.ts:51
↓ 14 callersMethodupdate
(values: Value[])
libs/langgraph-core/src/channels/last_value.ts:34
↓ 14 callersFunctionvalidateNamespace
(namespace: string[])
libs/checkpoint-postgres/src/store/modules/utils.ts:20
↓ 14 callersFunctionwithLangGraph
( schema: TSchema, meta: SchemaMeta<TValue, TUpdate> )
libs/langgraph-core/src/graph/zod/meta.ts:284
↓ 13 callersFunction_isSend
(x: unknown)
libs/langgraph-core/src/constants.ts:283
↓ 13 callersFunctioncoerceTimeoutPolicy
( value?: number | TimeoutPolicy )
libs/langgraph-core/src/pregel/utils/timeout.ts:68
↓ 13 callersFunctioncreateSSEResponseBody
( chunks: Array<{ id?: string; event: string; data: unknown }> )
libs/sdk/src/client/runs/stream.test.ts:13
↓ 13 callersMethodgetThread
* Returns the bound {@link ThreadStream}, if one exists (`undefined` * until the thread is hydrated or the first submit completes). Prefer * the
libs/sdk-vue/src/use-stream.ts:375
↓ 13 callersFunctioninferChannel
(event: MatchableEvent)
libs/langgraph-core/src/stream/subscription.ts:148
↓ 13 callersFunctioninitializeAsyncLocalStorageSingleton
()
libs/langgraph-core/src/tests/browser.ts:48
↓ 13 callersFunctionisGetter
(input: ValueOrGetter<T> | undefined)
libs/sdk-svelte/src/selectors.svelte.ts:92
↓ 13 callersFunctionlifecycleEvent
( namespace: readonly string[], event: "started" | "completed" | "failed", seq = 1 )
libs/sdk/src/stream/discovery/subgraphs.test.ts:6
↓ 13 callersFunctionmakeEvent
( method: string, ns: Namespace = [], seq = 0 )
libs/langgraph-core/src/stream/transformers/subgraphs.test.ts:30
↓ 13 callersFunctionmakeStore
()
libs/sdk/src/stream/lifecycle-loading-tracker.test.ts:12
↓ 13 callersFunctionmakeThread
(name = "thread")
libs/sdk/src/stream/channel-registry.test.ts:27
↓ 13 callersFunctionmapCommand
( cmd: Command, pendingWrites: CheckpointPendingWrite[] )
libs/langgraph-core/src/pregel/io.ts:71
↓ 13 callersFunctionmessagesDeltaReducer
( state: BaseMessage[], writes: Messages[] )
libs/langgraph-core/src/graph/messages_reducer.ts:164
↓ 13 callersFunctionnsState
(ns: string)
libs/sdk/src/stream/discovery/namespace-from-history.test.ts:284
↓ 13 callersMethodputWrites
* Put writes for a task, to be read by the next tick. * @param taskId * @param writes
libs/langgraph-core/src/pregel/loop.ts:742
↓ 13 callersFunctionresolveNamespace
(target: SelectorTarget)
libs/sdk-svelte/src/selectors.svelte.ts:77
↓ 13 callersMethodsetBranch
* Set the active branch and notify listeners if the value changed. * * @param value - The branch identifier to switch to.
libs/sdk/src/ui/orchestrator.ts:397
↓ 13 callersMethodstart
(controller)
libs/sdk/src/client/stream/transport/http.ts:292
↓ 13 callersMethodstart
* Initialize the store: creates the {namespace, key} unique index and an optional * TTL index.
libs/checkpoint-mongodb/src/store.ts:724
↓ 13 callersMethodtoBeInterrupted
()
libs/langgraph-core/src/tests/matchers/interrupt.ts:45
↓ 13 callersFunctionuseStreamContext
()
libs/sdk-react/src/context.tsx:115
↓ 13 callersFunctionuseToolCalls
( stream: AnyStream, target?: SelectorTarget )
libs/sdk-react/src/selectors.ts:210
↓ 13 callersFunctionuseValues
( stream: AnyStream, target?: SelectorTarget, options?: { messagesKey?: string } )
libs/sdk-react/src/selectors.ts:266
↓ 12 callersMethod#getMessages
(value: StateType)
libs/sdk/src/ui/orchestrator.ts:412
↓ 12 callersMethod#send
( method: TMethod, params: CommandParamsMap[TMethod] )
libs/sdk/src/client/stream/index.ts:2430
↓ 12 callersMethodbindTools
(tools: BindToolsInput[])
internal/bench/src/utils.ts:114
↓ 12 callersFunctioncreateStream
(chunks: Uint8Array[])
libs/sdk/src/utils/sse.test.ts:17
↓ 12 callersFunctiondispose
()
libs/sdk/src/stream/projections/media.ts:78
↓ 12 callersFunctionensureMessageInstances
( messages: (Message | BaseMessage)[] )
libs/sdk/src/ui/messages.ts:155
↓ 12 callersFunctiongetNode
(name: string)
libs/langgraph-core/src/tests/python_port/graph_structure.test.ts:49
↓ 12 callersFunctiongetStringConfigValue
( name: string, value: unknown, { required = false }: { required?: boolean } = {} )
libs/checkpoint-mongodb/src/checkpoint.ts:34
↓ 12 callersFunctionhasPrefix
(ns: Namespace, prefix: Namespace)
libs/langgraph-core/src/stream/mux.ts:538
↓ 12 callersFunctionisDeltaSnapshot
( value: unknown )
libs/checkpoint/src/serde/types.ts:35
↓ 12 callersFunctionmakeGraph
()
libs/langgraph-core/src/state/schema.test.ts:951
↓ 12 callersFunctionmakeTask
* Build a minimal {@link PregelExecutableTask} that runs `func` and routes its * writes (via CONFIG_KEY_SEND) into the same `writes` buffer exposed a
libs/langgraph-core/src/tests/timeout.test.ts:53
↓ 12 callersFunctionmapDebugTasks
( tasks: readonly PregelExecutableTask<N, C>[] )
libs/langgraph-core/src/pregel/debug.ts:116
↓ 12 callersFunctiononFinishRequiresThreadState
(onFinish: unknown)
libs/sdk/src/ui/utils.ts:11
↓ 12 callersMethodrespond
(params: InputRespondParams)
libs/sdk/src/client/stream/types.ts:180
↓ 12 callersMethodwireChannels
* Scans a transformer projection for streaming and final-value primitives. * Remote stream channels are wired to auto-forward to the protocol event
libs/langgraph-core/src/stream/mux.ts:239
↓ 11 callersFunction_getModel
( llm: LanguageModelLike | ConfigurableModelInterface )
libs/langgraph-core/src/prebuilt/react_agent_executor.ts:380
↓ 11 callersFunctioncreateFetchRecorder
(options?: { response?: Response; error?: Error; })
libs/sdk/src/client/stream/transport/test-helpers.ts:23
↓ 11 callersFunctioncreateSSEStream
( chunks: Array<{ id?: string; event: string; data: unknown }> )
libs/sdk/src/utils/stream-retry.test.ts:12
↓ 11 callersFunctionfindHistoryByNext
( history: StateSnapshot[], node: string )
libs/langgraph-core/src/tests/time_travel_helpers.ts:83
↓ 11 callersMethodfromConnString
* Creates a PostgresStore instance from a connection string.
libs/checkpoint-postgres/src/store/index.ts:187
← previousnext →201–300 of 4,051, ranked by callers