MCPcopy Index your code

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

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

↓ 1,194 callersMethodaddEdge
(startKey: N | typeof START, endKey: N | typeof END)
libs/langgraph-core/src/graph/graph.ts:410
↓ 1,084 callersMethodpush
* 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 callersMethodaddNode
( ...args: | [ key: K, action: NodeAction<NodeInput, NodeOutput, C>, o
libs/langgraph-core/src/graph/graph.ts:328
↓ 831 callersMethodinvoke
( input: PregelInputType, options?: Partial<PregelOptions<Nodes, Channels, ContextType>> )
libs/langgraph-core/src/pregel/types.ts:447
↓ 654 callersFunctiontest
()
internal/environment_tests/test-exports-esm/src/index.ts:8
↓ 616 callersMethodcompile
({ checkpointer, interruptBefore, interruptAfter, name, transformers, }: { checkpoin
libs/langgraph-core/src/graph/graph.ts:521
↓ 406 callersMethodget
(params: StateGetParams)
libs/sdk/src/client/stream/types.ts:185
↓ 266 callersFunctiongatherIterator
( i: | AsyncIterable<T> | Promise<AsyncIterable<T>> | Iterable<T> | Promise<Iterable<T>> )
libs/langgraph-core/src/utils.ts:136
↓ 265 callersMethodjoin
* 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 callersMethodgetSnapshot
* 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 callersMethodhas
* 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 callersMethodclose
* Shuts down the transport and releases any underlying resources.
libs/sdk/src/client/stream/transport.ts:91
↓ 201 callersMethodstream
( input: PregelInputType, options?: Partial<PregelOptions<Nodes, Channels, ContextType>> )
libs/langgraph-core/src/pregel/types.ts:442
↓ 178 callersMethodset
( pairs: { key: CacheFullKey; value: V; ttl?: number }[] )
libs/checkpoint/src/cache/memory.ts:44
↓ 177 callersMethodsubmit
* 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 callersMethodput
( config: RunnableConfig, checkpoint: Checkpoint, metadata: CheckpointMetadata, newVersions: C
libs/checkpoint-redis/src/index.ts:180
↓ 152 callersFunctioneventOf
( method: Event["method"], channelData: Event extends infer T ? T extends { method: typeof method; par
libs/sdk/src/client/stream/test/utils.ts:349
↓ 147 callersFunctionuseStream
( options: UseStreamOptions<InferStateType<T>> )
libs/sdk-vue/src/use-stream.ts:455
↓ 141 callersMethodentries
Read-only snapshot of all pending entries.
libs/sdk/src/ui/queue.ts:102
↓ 141 callersMethodinvoke
* 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 callersMethodpipe
( coerceable: RunnableLike )
libs/langgraph-core/src/pregel/read.ts:265
↓ 129 callersMethoddispose
()
libs/sdk/src/stream/types.ts:530
↓ 129 callersMethodupdate
* 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 callersFunctionuuid6
(clockseq: number)
libs/checkpoint/src/id.ts:13
↓ 122 callersMethodadd
* Add a pending run entry.
libs/sdk/src/ui/queue.ts:63
↓ 117 callersFunctionuseStream
( options: UseStreamOptions<InferStateType<T>> )
libs/sdk-svelte/src/use-stream.svelte.ts:438
↓ 116 callersFunctionuseStream
( options: UseStreamOptions<InferStateType<T>> )
libs/sdk-react/src/use-stream.ts:465
↓ 114 callersMethodgetState
( config: RunnableConfig, options?: { subgraphs?: boolean } )
libs/langgraph-core/src/pregel/types.ts:426
↓ 112 callersFunctioncn
(...inputs: ClassValue[])
examples/ai-elements/src/lib/utils.ts:4
↓ 108 callersMethodvalues
()
libs/sdk-angular/src/stream-service.ts:76
↓ 107 callersMethodaddConditionalEdges
( source: | N | BranchOptions<RunInput, N, LangGraphRunnableConfig<StateType<C>>>, path?:
libs/langgraph-core/src/graph/graph.ts:453
↓ 101 callersFunctioncreateReactAgent
( params: CreateReactAgentParams<A, StructuredResponseFormat, C> )
libs/langgraph-core/src/prebuilt/react_agent_executor.ts:669
↓ 99 callersFunctiontask
(value: Partial<StateSnapshot["tasks"][number]>)
libs/langgraph-core/src/tests/pregel.test.ts:12072
↓ 97 callersMethoddelete
* 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 callersMethodget
* 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 callersFunctionuseStream
( options: UseStreamOptions<InferStateType<T>>, destroyRef?: DestroyRef )
libs/sdk-angular/src/use-stream.ts:432
↓ 89 callersFunctionn
(n: number | string)
libs/langgraph-core/src/hash.ts:30
↓ 89 callersMethodtoString
()
libs/langgraph-core/src/tests/utils.ts:157
↓ 87 callersMethodaddEdge
(_from: string, _to: string)
libs/sdk-vue/src/tests/fixtures/langgraph-mocks.ts:54
↓ 83 callersMethodclear
()
libs/sdk-vue/src/selectors.ts:513
↓ 81 callersMethodthen
( onfulfilled?: | ((value: AIMessage) => TResult1 | PromiseLike<TResult1>) | null, onrejec
libs/sdk/src/client/stream/messages.ts:395
↓ 80 callersFunctioninterrupt
(value: I)
libs/langgraph-core/src/interrupt.ts:63
↓ 78 callersMethodstreamEvents
( input: InputType | CommandType | null, options: Partial<PregelOptions<Nodes, Channels, ContextType>>
libs/langgraph-core/src/pregel/index.ts:2173
↓ 77 callersFunctioncleanupRender
(screen: unknown)
libs/sdk-react/src/tests/test-utils.ts:25
↓ 77 callersMethodsubscribe
Subscribe; returns an unsubscribe handle.
libs/sdk/src/stream/types.ts:278
↓ 75 callersMethodaddEventListener
( type: string, listener: EventListenerOrEventListenerObject, options?: AddEventListenerOptions |
libs/sdk/src/client/stream/transport/websocket.test.ts:35
↓ 75 callersMethodpushEvent
(event: Event)
libs/sdk/src/client/stream/test/utils.ts:60
↓ 72 callersMethodaddNode
( _name: K, _fn: (state: TState) => Promise<TReturn>, )
libs/sdk-vue/src/tests/fixtures/langgraph-mocks.ts:39
↓ 69 callersMethodisInstance
(value: unknown)
libs/langgraph-core/src/constants.ts:346
↓ 68 callersFunctionresolve
(specifier, context, nextResolve)
libs/langgraph-api/src/graph/load.hooks.mjs:18
↓ 66 callersMethodconsume
* 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 callersMethodhandleMessage
* 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 callersMethodgetStateHistory
( config: RunnableConfig, options?: CheckpointListOptions )
libs/langgraph-core/src/pregel/types.ts:431
↓ 63 callersMethodbind
* 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 callersMethodjoin
(channels: Array<string>)
libs/langgraph-core/src/pregel/read.ts:240
↓ 61 callersMethodstop
* 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 callersFunctioncheckpoint
( input: Partial< Omit<StateSnapshot, "metadata"> & { metadata?: Record<string, unknown> }
libs/langgraph-core/src/tests/pregel.test.ts:12063
↓ 60 callersMethodstream
* 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 callersFunctioncreateCheckpointer
()
libs/checkpoint-validation/src/tests/redis_initializer.ts:22
↓ 58 callersMethodsubscribeTo
( channels: string | string[], options?: | SingleChannelSubscriptionOptions | MultipleChan
libs/langgraph-core/src/pregel/index.ts:249
↓ 56 callersFunctionassertSafeKeyComponent
( field: string, value: unknown, options: { allowEmpty?: boolean } = {} )
libs/checkpoint-redis/src/utils.ts:64
↓ 55 callersMethodcompile
()
libs/sdk-vue/src/tests/fixtures/langgraph-mocks.ts:58
↓ 55 callersMethodput
(config: RunnableConfig)
libs/checkpoint/src/tests/checkpoints.test.ts:117
↓ 54 callersMethodsubscribe
( channel: TChannel, options?: SubscribeOptions )
libs/sdk/src/client/stream/handles/subgraphs.ts:40
↓ 54 callersMethodwriteTo
* 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 callersMethodbatch
* 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 callersMethodfetch
( path: string, options?: RequestInit & { json?: unknown; params?: Record<string, unknown>
libs/sdk/src/client/base.ts:303
↓ 52 callersFunctionemptyCheckpoint
()
libs/checkpoint/src/base.ts:75
↓ 52 callersMethodprocess
* 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 callersFunctioninjectStream
( options?: UseStreamOptions<Record<string, unknown>> )
libs/sdk-angular/src/inject-stream.ts:48
↓ 50 callersFunctionmakeEvent
( method: string, data: unknown, namespace: string[] = [], node?: string, seq = 0 )
libs/langgraph-core/src/stream/transformers.test.ts:12
↓ 49 callersMethodput
* Put an item with optional indexing configuration and TTL.
libs/checkpoint-postgres/src/store/index.ts:86
↓ 49 callersMethodsearch
( namespacePrefix: string[], options?: { filter?: Filter; query?: string; limit?: nu
libs/checkpoint-redis/src/store.ts:643
↓ 48 callersFunctioncollect
( filter: Record<string, unknown> )
libs/checkpoint-sqlite/src/tests/checkpoints.test.ts:251
↓ 48 callersFunctiondrainFlush
* 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 callersMethodadd
( schema: S, ..._meta: undefined extends Meta & { [key: string]: unknown } ? [$replace<Meta & {
libs/langgraph-core/src/graph/zod/zod-registry.ts:46
↓ 45 callersFunctioncreateOptions
( overrides?: Partial<AnyStreamOptions<TestState>> )
libs/sdk/src/ui/orchestrator.test.ts:64
↓ 44 callersMethodgetState
* 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 callersMethodvalues
()
libs/sdk/src/ui/manager.ts:685
↓ 43 callersMethodloadsTyped
(type: string, data: Uint8Array | string)
libs/checkpoint/src/serde/base.ts:5
↓ 42 callersMethodmessages
()
libs/sdk-angular/src/stream-service.ts:80
↓ 41 callersMethodupdateState
( inputConfig: LangGraphRunnableConfig, values: Record<string, unknown> | unknown, asNode?: keyof
libs/langgraph-core/src/pregel/types.ts:436
↓ 39 callersMethoderror
()
libs/sdk/src/ui/manager.ts:689
↓ 39 callersMethodgetTuple
(config: RunnableConfig)
libs/checkpoint-redis/src/index.ts:126
↓ 38 callersFunctionscanContentForAgents
( content: string, filePath: string = "test.ts" )
libs/create-langgraph/src/config.ts:50
↓ 37 callersMethodremoveEventListener
( type: string, listener: EventListenerOrEventListenerObject )
libs/sdk/src/client/stream/transport/websocket.test.ts:55
↓ 36 callersMethodend
()
libs/checkpoint-redis/src/index.ts:837
↓ 36 callersMethodsearch
* 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 callersMethodabort
* 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 callersMethodaddTransformer
* 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 callersMethodgetTuple
(config: RunnableConfig)
libs/langgraph-core/src/tests/pregel.test.ts:302
↓ 35 callersMethodlistNamespaces
(options?: { prefix?: string[]; suffix?: string[]; maxDepth?: number; limit?: number; offs
libs/checkpoint-redis/src/store.ts:797
↓ 35 callersFunctionmakeProjection
()
libs/sdk/src/stream/root-message-projection.test.ts:31
↓ 35 callersFunctionuseStream
(options: any)
libs/sdk/src/react/stream.tsx:44
↓ 34 callersMethodisInstance
( value: unknown )
libs/langgraph-core/src/state/schema.ts:468
↓ 34 callersMethodtoHaveInterruptValue
(expected: unknown)
libs/langgraph-core/src/tests/matchers/interrupt.ts:46
↓ 33 callersFunctionlifecyclePayload
(event: ProtocolEvent)
libs/langgraph-core/src/stream/transformers/lifecycle.test.ts:45
↓ 33 callersMethodnext
()
libs/sdk/src/client/stream/messages.ts:235
↓ 33 callersMethodwithConfig
(config: RunnableConfig)
libs/langgraph-core/src/pregel/types.ts:407
↓ 32 callersMethodinit
* 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