Code
Hub
Workspaces
Following
Digest
Agents
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
↓ 1,194 callers
Method
addEdge
(startKey: N | typeof START, endKey: N | typeof END)
libs/langgraph-core/src/graph/graph.ts:410
↓ 1,084 callers
Method
push
* Injects a new {@link ProtocolEvent} into the mux pipeline. The * event is routed through every registered transformer (including * the emittin
libs/langgraph-core/src/stream/types.ts:224
↓ 1,009 callers
Method
addNode
( ...args: | [ key: K, action: NodeAction<NodeInput, NodeOutput, C>, o
libs/langgraph-core/src/graph/graph.ts:328
↓ 831 callers
Method
invoke
( input: PregelInputType, options?: Partial<PregelOptions<Nodes, Channels, ContextType>> )
libs/langgraph-core/src/pregel/types.ts:447
↓ 654 callers
Function
test
()
internal/environment_tests/test-exports-esm/src/index.ts:8
↓ 616 callers
Method
compile
({ checkpointer, interruptBefore, interruptAfter, name, transformers, }: { checkpoin
libs/langgraph-core/src/graph/graph.ts:521
↓ 406 callers
Method
get
(params: StateGetParams)
libs/sdk/src/client/stream/types.ts:185
↓ 266 callers
Function
gatherIterator
( i: | AsyncIterable<T> | Promise<AsyncIterable<T>> | Iterable<T> | Promise<Iterable<T>> )
libs/langgraph-core/src/utils.ts:136
↓ 265 callers
Method
join
* Block until a run is done. * * @param threadId The ID of the thread. * @param runId The ID of the run. * @returns
libs/sdk/src/client/runs/index.ts:384
↓ 220 callers
Method
getSnapshot
* Return the current version number, incremented on every state change. * Useful as a React `useSyncExternalStore` snapshot. * * @returns The
libs/sdk/src/ui/orchestrator.ts:251
↓ 208 callers
Method
has
* Checks if metadata exists for a given schema. * @param schema The schema to check. * @returns True if metadata exists, false otherwise.
libs/langgraph-core/src/graph/zod/meta.ts:141
↓ 206 callers
Method
close
* Shuts down the transport and releases any underlying resources.
libs/sdk/src/client/stream/transport.ts:91
↓ 201 callers
Method
stream
( input: PregelInputType, options?: Partial<PregelOptions<Nodes, Channels, ContextType>> )
libs/langgraph-core/src/pregel/types.ts:442
↓ 178 callers
Method
set
( pairs: { key: CacheFullKey; value: V; ttl?: number }[] )
libs/checkpoint/src/cache/memory.ts:44
↓ 177 callers
Method
submit
* Dispatch a new run on the bound thread. * * `input` is typed as `Partial<StateType>` so IDE autocompletion * surfaces the state keys declar
libs/sdk-vue/src/use-stream.ts:248
↓ 154 callers
Method
put
( config: RunnableConfig, checkpoint: Checkpoint, metadata: CheckpointMetadata, newVersions: C
libs/checkpoint-redis/src/index.ts:180
↓ 152 callers
Function
eventOf
( method: Event["method"], channelData: Event extends infer T ? T extends { method: typeof method; par
libs/sdk/src/client/stream/test/utils.ts:349
↓ 147 callers
Function
useStream
( options: UseStreamOptions<InferStateType<T>> )
libs/sdk-vue/src/use-stream.ts:455
↓ 141 callers
Method
entries
Read-only snapshot of all pending entries.
libs/sdk/src/ui/queue.ts:102
↓ 141 callers
Method
invoke
* Run the graph with a single input and config. * @param input The input to the graph. * @param options The configuration to use for the run.
libs/langgraph-core/src/pregel/index.ts:2549
↓ 130 callers
Method
pipe
( coerceable: RunnableLike )
libs/langgraph-core/src/pregel/read.ts:265
↓ 129 callers
Method
dispose
()
libs/sdk/src/stream/types.ts:530
↓ 129 callers
Method
update
* Update the channel's value with the given sequence of updates. * The order of the updates in the sequence is arbitrary. * * @throws {Invali
libs/checkpoint/src/serde/types.ts:77
↓ 125 callers
Function
uuid6
(clockseq: number)
libs/checkpoint/src/id.ts:13
↓ 122 callers
Method
add
* Add a pending run entry.
libs/sdk/src/ui/queue.ts:63
↓ 117 callers
Function
useStream
( options: UseStreamOptions<InferStateType<T>> )
libs/sdk-svelte/src/use-stream.svelte.ts:438
↓ 116 callers
Function
useStream
( options: UseStreamOptions<InferStateType<T>> )
libs/sdk-react/src/use-stream.ts:465
↓ 114 callers
Method
getState
( config: RunnableConfig, options?: { subgraphs?: boolean } )
libs/langgraph-core/src/pregel/types.ts:426
↓ 112 callers
Function
cn
(...inputs: ClassValue[])
examples/ai-elements/src/lib/utils.ts:4
↓ 108 callers
Method
values
()
libs/sdk-angular/src/stream-service.ts:76
↓ 107 callers
Method
addConditionalEdges
( source: | N | BranchOptions<RunInput, N, LangGraphRunnableConfig<StateType<C>>>, path?:
libs/langgraph-core/src/graph/graph.ts:453
↓ 101 callers
Function
createReactAgent
( params: CreateReactAgentParams<A, StructuredResponseFormat, C> )
libs/langgraph-core/src/prebuilt/react_agent_executor.ts:669
↓ 99 callers
Function
task
(value: Partial<StateSnapshot["tasks"][number]>)
libs/langgraph-core/src/tests/pregel.test.ts:12072
↓ 97 callers
Method
delete
* Delete a run. * * @param threadId The ID of the thread. * @param runId The ID of the run. * @returns
libs/sdk/src/client/runs/index.ts:464
↓ 96 callers
Method
get
* Return the current value of the channel. * * @throws {EmptyChannelError} if the channel is empty (never updated yet). * @returns {ValueType
libs/checkpoint/src/serde/types.ts:85
↓ 93 callers
Function
useStream
( options: UseStreamOptions<InferStateType<T>>, destroyRef?: DestroyRef )
libs/sdk-angular/src/use-stream.ts:432
↓ 89 callers
Function
n
(n: number | string)
libs/langgraph-core/src/hash.ts:30
↓ 89 callers
Method
toString
()
libs/langgraph-core/src/tests/utils.ts:157
↓ 87 callers
Method
addEdge
(_from: string, _to: string)
libs/sdk-vue/src/tests/fixtures/langgraph-mocks.ts:54
↓ 83 callers
Method
clear
()
libs/sdk-vue/src/selectors.ts:513
↓ 81 callers
Method
then
( onfulfilled?: | ((value: AIMessage) => TResult1 | PromiseLike<TResult1>) | null, onrejec
libs/sdk/src/client/stream/messages.ts:395
↓ 80 callers
Function
interrupt
(value: I)
libs/langgraph-core/src/interrupt.ts:63
↓ 78 callers
Method
streamEvents
( input: InputType | CommandType | null, options: Partial<PregelOptions<Nodes, Channels, ContextType>>
libs/langgraph-core/src/pregel/index.ts:2173
↓ 77 callers
Function
cleanupRender
(screen: unknown)
libs/sdk-react/src/tests/test-utils.ts:25
↓ 77 callers
Method
subscribe
Subscribe; returns an unsubscribe handle.
libs/sdk/src/stream/types.ts:278
↓ 75 callers
Method
addEventListener
( type: string, listener: EventListenerOrEventListenerObject, options?: AddEventListenerOptions |
libs/sdk/src/client/stream/transport/websocket.test.ts:35
↓ 75 callers
Method
pushEvent
(event: Event)
libs/sdk/src/client/stream/test/utils.ts:60
↓ 72 callers
Method
addNode
( _name: K, _fn: (state: TState) => Promise<TReturn>, )
libs/sdk-vue/src/tests/fixtures/langgraph-mocks.ts:39
↓ 69 callers
Method
isInstance
(value: unknown)
libs/langgraph-core/src/constants.ts:346
↓ 68 callers
Function
resolve
(specifier, context, nextResolve)
libs/langgraph-api/src/graph/load.hooks.mjs:18
↓ 66 callers
Method
consume
* Fold a single `messages` event. Non-media blocks and * informational events (e.g. `content-block-finish`) are no-ops.
libs/sdk/src/client/stream/media.ts:698
↓ 66 callers
Method
handleMessage
* Apply a `messages` channel event to the projection. * * Captures role/tool metadata on `message-start`, feeds the chunk * to the assembler,
libs/sdk/src/stream/root-message-projection.ts:298
↓ 65 callers
Method
getStateHistory
( config: RunnableConfig, options?: CheckpointListOptions )
libs/langgraph-core/src/pregel/types.ts:431
↓ 63 callers
Method
bind
* Rebind every live entry to a new {@link ThreadStream} (or detach * when `thread == null`). * * Each live entry has its current runtime disp
libs/sdk/src/stream/channel-registry.ts:148
↓ 61 callers
Method
join
(channels: Array<string>)
libs/langgraph-core/src/pregel/read.ts:240
↓ 61 callers
Method
stop
* Stop the active run on the current thread. By default cancels the * run server-side and disconnects the client; pass `{ cancel: false }` * or
libs/sdk-vue/src/use-stream.ts:258
↓ 60 callers
Function
checkpoint
( input: Partial< Omit<StateSnapshot, "metadata"> & { metadata?: Record<string, unknown> }
libs/langgraph-core/src/tests/pregel.test.ts:12063
↓ 60 callers
Method
stream
* Streams the execution of the graph, emitting state updates as they occur. * This is the primary method for observing graph execution in real-time
libs/langgraph-core/src/pregel/index.ts:1961
↓ 59 callers
Function
createCheckpointer
()
libs/checkpoint-validation/src/tests/redis_initializer.ts:22
↓ 58 callers
Method
subscribeTo
( channels: string | string[], options?: | SingleChannelSubscriptionOptions | MultipleChan
libs/langgraph-core/src/pregel/index.ts:249
↓ 56 callers
Function
assertSafeKeyComponent
( field: string, value: unknown, options: { allowEmpty?: boolean } = {} )
libs/checkpoint-redis/src/utils.ts:64
↓ 55 callers
Method
compile
()
libs/sdk-vue/src/tests/fixtures/langgraph-mocks.ts:58
↓ 55 callers
Method
put
(config: RunnableConfig)
libs/checkpoint/src/tests/checkpoints.test.ts:117
↓ 54 callers
Method
subscribe
( channel: TChannel, options?: SubscribeOptions )
libs/sdk/src/client/stream/handles/subgraphs.ts:40
↓ 54 callers
Method
writeTo
* Creates a ChannelWrite that specifies how to write values to channels. * This is used to define how nodes send output to channels. * * @exa
libs/langgraph-core/src/pregel/index.ts:314
↓ 53 callers
Method
batch
* Execute a batch of operations (Put, Get, ListNamespaces, Search). * Operations are processed in order, but multiple consecutive Puts are batched.
libs/checkpoint-mongodb/src/store.ts:210
↓ 53 callers
Method
fetch
( path: string, options?: RequestInit & { json?: unknown; params?: Record<string, unknown>
libs/sdk/src/client/base.ts:303
↓ 52 callers
Function
emptyCheckpoint
()
libs/checkpoint/src/base.ts:75
↓ 52 callers
Method
process
* Called for each {@link ProtocolEvent} before it is appended to the main log. * * @param event - Next protocol envelope for this run. * @ret
libs/langgraph-core/src/stream/types.ts:183
↓ 51 callers
Function
injectStream
( options?: UseStreamOptions<Record<string, unknown>> )
libs/sdk-angular/src/inject-stream.ts:48
↓ 50 callers
Function
makeEvent
( method: string, data: unknown, namespace: string[] = [], node?: string, seq = 0 )
libs/langgraph-core/src/stream/transformers.test.ts:12
↓ 49 callers
Method
put
* Put an item with optional indexing configuration and TTL.
libs/checkpoint-postgres/src/store/index.ts:86
↓ 49 callers
Method
search
( namespacePrefix: string[], options?: { filter?: Filter; query?: string; limit?: nu
libs/checkpoint-redis/src/store.ts:643
↓ 48 callers
Function
collect
( filter: Record<string, unknown> )
libs/checkpoint-sqlite/src/tests/checkpoints.test.ts:251
↓ 48 callers
Function
drainFlush
* Drain one macrotask so the projection's batched `setTimeout(0)` * flush commits to the store. The projection coalesces a burst of * synchronous wr
libs/sdk/src/stream/root-message-projection.test.ts:49
↓ 47 callers
Method
add
( schema: S, ..._meta: undefined extends Meta & { [key: string]: unknown } ? [$replace<Meta & {
libs/langgraph-core/src/graph/zod/zod-registry.ts:46
↓ 45 callers
Function
createOptions
( overrides?: Partial<AnyStreamOptions<TestState>> )
libs/sdk/src/ui/orchestrator.test.ts:64
↓ 44 callers
Method
getState
* Gets the current state of the graph. * Requires a checkpointer to be configured. * * @param config - Configuration for retrieving the state
libs/langgraph-core/src/pregel/index.ts:1056
↓ 44 callers
Method
values
()
libs/sdk/src/ui/manager.ts:685
↓ 43 callers
Method
loadsTyped
(type: string, data: Uint8Array | string)
libs/checkpoint/src/serde/base.ts:5
↓ 42 callers
Method
messages
()
libs/sdk-angular/src/stream-service.ts:80
↓ 41 callers
Method
updateState
( inputConfig: LangGraphRunnableConfig, values: Record<string, unknown> | unknown, asNode?: keyof
libs/langgraph-core/src/pregel/types.ts:436
↓ 39 callers
Method
error
()
libs/sdk/src/ui/manager.ts:689
↓ 39 callers
Method
getTuple
(config: RunnableConfig)
libs/checkpoint-redis/src/index.ts:126
↓ 38 callers
Function
scanContentForAgents
( content: string, filePath: string = "test.ts" )
libs/create-langgraph/src/config.ts:50
↓ 37 callers
Method
removeEventListener
( type: string, listener: EventListenerOrEventListenerObject )
libs/sdk/src/client/stream/transport/websocket.test.ts:55
↓ 36 callers
Method
end
()
libs/checkpoint-redis/src/index.ts:837
↓ 36 callers
Method
search
* Search for items in the store with support for text search, vector search, and filtering. * * @param namespacePrefix - The namespace prefix to
libs/checkpoint-postgres/src/store/index.ts:543
↓ 35 callers
Method
abort
* Programmatically abort this run. Equivalent to calling * `signal.abort(reason)`. * * @param reason - Optional abort reason passed to the si
libs/langgraph-core/src/stream/run-stream.ts:347
↓ 35 callers
Method
addTransformer
* Registers a transformer and replays all buffered events through it so * it catches up with events already processed by the mux. When the event
libs/langgraph-core/src/stream/mux.ts:183
↓ 35 callers
Method
getTuple
(config: RunnableConfig)
libs/langgraph-core/src/tests/pregel.test.ts:302
↓ 35 callers
Method
listNamespaces
(options?: { prefix?: string[]; suffix?: string[]; maxDepth?: number; limit?: number; offs
libs/checkpoint-redis/src/store.ts:797
↓ 35 callers
Function
makeProjection
()
libs/sdk/src/stream/root-message-projection.test.ts:31
↓ 35 callers
Function
useStream
(options: any)
libs/sdk/src/react/stream.tsx:44
↓ 34 callers
Method
isInstance
( value: unknown )
libs/langgraph-core/src/state/schema.ts:468
↓ 34 callers
Method
toHaveInterruptValue
(expected: unknown)
libs/langgraph-core/src/tests/matchers/interrupt.ts:46
↓ 33 callers
Function
lifecyclePayload
(event: ProtocolEvent)
libs/langgraph-core/src/stream/transformers/lifecycle.test.ts:45
↓ 33 callers
Method
next
()
libs/sdk/src/client/stream/messages.ts:235
↓ 33 callers
Method
withConfig
(config: RunnableConfig)
libs/langgraph-core/src/pregel/types.ts:407
↓ 32 callers
Method
init
* Called once before the run starts. * * @returns Initial projection merged into `GraphRunStream.extensions`. * Any named {@link StreamChan
libs/langgraph-core/src/stream/types.ts:154
next →
1–100 of 4,051, ranked by callers