Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/cloudwego/eino
/ functions
Functions
3,994 in github.com/cloudwego/eino
⨍
Functions
3,994
◇
Types & classes
1,204
↓ 2 callers
Function
cloneWithoutNilCheck
(m M)
internal/gmap/gmap.go:115
↓ 2 callers
Method
close
()
compose/stream_reader.go:32
↓ 2 callers
Function
commitEvents
commitEvents appends a slice of new events to the correct parent lane or main event log.
adk/runctx.go:447
↓ 2 callers
Method
commitLocked
()
adk/turn_loop.go:474
↓ 2 callers
Function
compileAnyGraph
(ctx context.Context, g AnyGraph, opts ...GraphCompileOption)
compose/generic_graph.go:127
↓ 2 callers
Function
concatInstructions
(instructions ...string)
adk/utils.go:79
↓ 2 callers
Function
convAgenticToolsNodeCallbackOutput
(src callbacks.CallbackInput)
utils/callbacks/template.go:786
↓ 2 callers
Function
convTools
(ctx context.Context, params convToolsParams)
compose/tool_node.go:489
↓ 2 callers
Function
convToolsNodeCallbackOutput
(src callbacks.CallbackInput)
utils/callbacks/template.go:653
↓ 2 callers
Function
convertCallbacks
convertCallbacks reads graph call options, extract host.MultiAgentCallback and convert it to callbacks.Handler.
flow/agent/multiagent/host/callback.go:92
↓ 2 callers
Method
convertCheckPoint
convertCheckPoint if value in checkpoint is streamReader, convert it to non-stream
compose/checkpoint.go:302
↓ 2 callers
Function
convertTo
(mappings map[string]any, typ reflect.Type)
compose/field_mapping.go:237
↓ 2 callers
Method
convertValues
(fn func(map[string]any) error)
compose/graph_manager.go:34
↓ 2 callers
Function
copyItem
(item any, n int)
compose/graph_run.go:1020
↓ 2 callers
Function
copyMap
(m map[K]V)
adk/utils.go:62
↓ 2 callers
Function
copyMessage
(msg M)
adk/wrappers.go:472
↓ 2 callers
Function
ctxWithNewTypedRunCtx
(ctx context.Context, input *TypedAgentInput[M], sharedParentSession bool)
adk/runctx.go:537
↓ 2 callers
Method
decrementRemainingIterations
()
adk/react.go:187
↓ 2 callers
Method
deepCopy
()
compose/graph_call_options.go:109
↓ 2 callers
Function
deepCopyMap
(in map[string]interface{})
flow/indexer/parent/parent_test.go:115
↓ 2 callers
Function
deepCopyState
deepCopyState creates a deep copy of the state using serialization
compose/graph_run.go:572
↓ 2 callers
Function
defaultNewPlan
(ctx context.Context)
adk/prebuilt/planexecute/plan_execute.go:287
↓ 2 callers
Function
defaultStreamConvertPair
()
compose/generic_helper.go:168
↓ 2 callers
Function
deprecatedInterruptAndRerunErr
(extra any)
compose/interrupt.go:55
↓ 2 callers
Function
drainAndAssertCancelError
(t *testing.T, iter *AsyncIterator[*AgentEvent])
adk/cancel_test.go:156
↓ 2 callers
Function
drainEventsAndAssertCancelError
(t *testing.T, iter *AsyncIterator[*AgentEvent])
adk/cancel_test.go:171
↓ 2 callers
Method
execute
(currentTask *task)
compose/graph_manager.go:285
↓ 2 callers
Function
extractAndDeriveAgentToolCancelCtx
(ctx context.Context, agentName string, opts []tool.Option)
adk/agent_tool.go:325
↓ 2 callers
Method
extractDynamicTools
(tools []*schema.ToolInfo)
adk/middlewares/dynamictool/toolsearch/toolsearch.go:239
↓ 2 callers
Function
fieldMap
(mappings []*FieldMapping, allowMapKeyNotFound bool, uncheckedSourcePaths map[string]FieldPath)
compose/field_mapping.go:484
↓ 2 callers
Function
filterCallbackHandlersForNestedAgents
filterCallbackHandlersForNestedAgents removes callback handlers that have already been applied to the current agent before passing opts to nested inne
adk/call_option.go:130
↓ 2 callers
Function
findLoops
(startNodes []string, chanCalls map[string]*chanCall)
compose/graph.go:1131
↓ 2 callers
Method
findMatches
(filePath, content string, re *regexp.Regexp, req *GrepRequest)
adk/filesystem/backend_inmemory.go:720
↓ 2 callers
Method
finish
()
adk/agentic_react_test.go:141
↓ 2 callers
Method
finishStopCommit
()
adk/turn_loop.go:1554
↓ 2 callers
Method
forMapInput
()
compose/generic_helper.go:71
↓ 2 callers
Method
forMapOutput
()
compose/generic_helper.go:95
↓ 2 callers
Method
forSuccessorPassthrough
()
compose/generic_helper.go:136
↓ 2 callers
Function
formatExecutedSteps
(results []ExecutedStep)
adk/prebuilt/planexecute/plan_execute.go:629
↓ 2 callers
Function
formatFileMatches
(matches []filesystem.GrepMatch, offset, headLimit int)
adk/middlewares/filesystem/filesystem.go:1146
↓ 2 callers
Function
formatInput
formatInput formats the input messages into a string.
adk/prebuilt/planexecute/plan_execute.go:619
↓ 2 callers
Function
formatLineNumbers
formatLineNumbers prefixes each line of content with a 1-based line number starting at startLine (e.g. " 1\tfoo"). startLine corresponds to the li
adk/middlewares/filesystem/filesystem.go:638
↓ 2 callers
Function
formatToolMessage
(s string)
adk/middlewares/filesystem/large_tool_result.go:155
↓ 2 callers
Function
formatToolMessage
(s string)
adk/middlewares/reduction/internal/large_tool_result.go:188
↓ 2 callers
Function
forwardCheckPoint
(ctx context.Context, nodeKey string)
compose/checkpoint.go:158
↓ 2 callers
Method
genToolCallTasks
(ctx context.Context, tuple *toolsTuple, input *schema.Message, executedTools map[string]string, executedEnha
compose/tool_node.go:777
↓ 2 callers
Function
genToolInfos
(ctx context.Context, config *compose.ToolsNodeConfig)
adk/react.go:312
↓ 2 callers
Method
getAgent
(ctx context.Context, name string)
adk/flow.go:174
↓ 2 callers
Function
getAgenticReturnDirectlyToolCallID
(ctx context.Context)
adk/react.go:569
↓ 2 callers
Function
getCheckPointFromCtx
(ctx context.Context)
compose/checkpoint.go:151
↓ 2 callers
Method
getChunkType
()
compose/stream_reader.go:29
↓ 2 callers
Function
getComposeOptions
(opts []AgentRunOption)
adk/chatmodel.go:1642
↓ 2 callers
Function
getContinueInstruction
()
adk/middlewares/summarization/prompt.go:48
↓ 2 callers
Method
getDelay
()
adk/cancel_test.go:45
↓ 2 callers
Method
getFailoverModel
(ctx context.Context, failoverCtx *FailoverContext[M])
adk/failover_chatmodel.go:214
↓ 2 callers
Method
getMessagesFromState
(ctx context.Context)
adk/middlewares/skill/skill.go:673
↓ 2 callers
Method
getModelInstructions
()
adk/middlewares/summarization/summarization.go:625
↓ 2 callers
Function
getMsgContentG
(msg M)
adk/middlewares/reduction/reduction_generic_test.go:130
↓ 2 callers
Function
getNextResumeAgent
(ctx context.Context, _ *ResumeInfo)
adk/interrupt.go:349
↓ 2 callers
Method
getNodeInputType
(name string)
compose/graph.go:648
↓ 2 callers
Function
getResumeInfo
(ctx context.Context)
internal/core/address.go:323
↓ 2 callers
Method
getReturnDirectlyEvent
()
adk/react.go:106
↓ 2 callers
Function
getReturnDirectlyToolCallID
(ctx context.Context)
adk/react.go:328
↓ 2 callers
Method
getRunFunc
(ctx context.Context)
adk/chatmodel.go:1401
↓ 2 callers
Method
getToolGenActions
()
adk/react.go:131
↓ 2 callers
Function
getToolsNodeOptions
(opts ...ToolsNodeOption)
compose/tool_node.go:1278
↓ 2 callers
Method
getType
()
compose/stream_reader.go:28
↓ 2 callers
Function
getTypeName
(rt reflect.Type)
schema/serialization.go:92
↓ 2 callers
Function
getTypedAgentType
(agent TypedAgent[M])
adk/flow.go:638
↓ 2 callers
Function
getUserMessagesReplacedNote
()
adk/middlewares/summarization/prompt.go:69
↓ 2 callers
Function
handleFlowAgentEvents
(ctx context.Context, iter *AsyncIterator[*AgentEvent], generator *AsyncGenerator[*AgentEvent], isolatedSessi
adk/deterministic_transfer.go:234
↓ 2 callers
Method
handleInterrupt
( ctx context.Context, tempInfo *interruptTempInfo, nextTasks []*task, channels map[string]channel, isStr
compose/graph_run.go:502
↓ 2 callers
Method
handleInterruptWithSubGraphAndRerunNodes
( ctx context.Context, tempInfo *interruptTempInfo, completeTasks []*task, checkPointID *string, isSubGra
compose/graph_run.go:598
↓ 2 callers
Method
handleResult
(ctx context.Context, result string, input *compose.ToolInput)
adk/middlewares/filesystem/large_tool_result.go:103
↓ 2 callers
Method
handleResult
(ctx context.Context, result string, input *compose.ToolInput)
adk/middlewares/reduction/internal/large_tool_result.go:135
↓ 2 callers
Function
hasCyclicDependency
(taskMap map[string]*task, blockerID, blockedID string)
adk/middlewares/plantask/task.go:93
↓ 2 callers
Method
hasUserEventSender
()
adk/wrappers.go:1008
↓ 2 callers
Function
initAgentCallbacks
(ctx context.Context, agentName, agentType string, opts ...AgentRunOption)
adk/callback.go:116
↓ 2 callers
Function
invokableToStreamable
(e InvokableToolEndpoint)
compose/tool_node.go:714
↓ 2 callers
Function
invokeWithCallbacks
(i Invoke[I, O, TOption])
compose/utils.go:118
↓ 2 callers
Function
isBase64MessageOutputAudioPart
(part MessageOutputPart)
schema/message.go:1572
↓ 2 callers
Function
isChain
(cmp component)
compose/graph.go:151
↓ 2 callers
Function
isInterruptError
(err error)
compose/interrupt.go:351
↓ 2 callers
Function
isSubGraphInterrupt
(err error)
compose/interrupt.go:329
↓ 2 callers
Function
isToAll
(mappings []*FieldMapping)
compose/field_mapping.go:622
↓ 2 callers
Method
list
(ctx context.Context)
adk/middlewares/skill/filesystem_backend.go:95
↓ 2 callers
Method
loadFile
loadFile reads a file via Backend and collects @imported files as separate entries. Returns a slice where the first element is this file itself, follo
adk/middlewares/agentsmd/loader.go:138
↓ 2 callers
Function
makeAssistantMsgWithToolCalls
(content string, toolCalls []testToolCall)
adk/middlewares/patchtoolcalls/patchtoolcalls_test.go:57
↓ 2 callers
Function
makeToolMap
--------------------------------------------------------------------------- helpers ------------------------------------------------------------------
adk/middlewares/dynamictool/toolsearch/toolsearch_test.go:42
↓ 2 callers
Function
markAgenticMessageStreamingMeta
(msg *schema.AgenticMessage, index int)
adk/wrappers.go:597
↓ 2 callers
Function
marshalTurnLoopCheckpoint
(c *turnLoopCheckpoint[T])
adk/turn_loop.go:952
↓ 2 callers
Function
matchFileType
matchFileType checks if the file extension matches the given file type.
adk/filesystem/backend_inmemory.go:410
↓ 2 callers
Function
messageInputPartsToFunctionToolBlocks
(parts []schema.MessageInputPart)
compose/agentic_tools_node.go:177
↓ 2 callers
Function
messageUserTextContent
(m *schema.Message)
adk/middlewares/summarization/summarization.go:984
↓ 2 callers
Function
newAgenticRunnerWithStore
(t *testing.T, ctx context.Context, mdl model.BaseModel[*schema.AgenticMessage], tools []tool.BaseTool, store
adk/agentic_react_test.go:185
↓ 2 callers
Function
newCheckPointer
( inputPairs, outputPairs map[string]streamConvertPair, store CheckPointStore, serializer Serializer, )
compose/checkpoint.go:171
↓ 2 callers
Function
newCheckpointStore
()
adk/prebuilt/supervisor/supervisor_test.go:254
↓ 2 callers
Function
newDefaultGenModelInput
()
adk/chatmodel.go:195
↓ 2 callers
Function
newGraphFromGeneric
( cmp component, stateGenerator func(ctx context.Context) any, stateType reflect.Type, opts []NewGraphOpti
compose/graph.go:100
↓ 2 callers
Function
newGrepCollector
()
adk/filesystem/backend_inmemory.go:707
← previous
next →
1,001–1,100 of 3,994, ranked by callers