MCPcopy Create free account

hub / github.com/cloudwego/eino / functions

Functions3,994 in github.com/cloudwego/eino

↓ 2 callersFunctioncloneWithoutNilCheck
(m M)
internal/gmap/gmap.go:115
↓ 2 callersMethodclose
()
compose/stream_reader.go:32
↓ 2 callersFunctioncommitEvents
commitEvents appends a slice of new events to the correct parent lane or main event log.
adk/runctx.go:447
↓ 2 callersMethodcommitLocked
()
adk/turn_loop.go:474
↓ 2 callersFunctioncompileAnyGraph
(ctx context.Context, g AnyGraph, opts ...GraphCompileOption)
compose/generic_graph.go:127
↓ 2 callersFunctionconcatInstructions
(instructions ...string)
adk/utils.go:79
↓ 2 callersFunctionconvAgenticToolsNodeCallbackOutput
(src callbacks.CallbackInput)
utils/callbacks/template.go:786
↓ 2 callersFunctionconvTools
(ctx context.Context, params convToolsParams)
compose/tool_node.go:489
↓ 2 callersFunctionconvToolsNodeCallbackOutput
(src callbacks.CallbackInput)
utils/callbacks/template.go:653
↓ 2 callersFunctionconvertCallbacks
convertCallbacks reads graph call options, extract host.MultiAgentCallback and convert it to callbacks.Handler.
flow/agent/multiagent/host/callback.go:92
↓ 2 callersMethodconvertCheckPoint
convertCheckPoint if value in checkpoint is streamReader, convert it to non-stream
compose/checkpoint.go:302
↓ 2 callersFunctionconvertTo
(mappings map[string]any, typ reflect.Type)
compose/field_mapping.go:237
↓ 2 callersMethodconvertValues
(fn func(map[string]any) error)
compose/graph_manager.go:34
↓ 2 callersFunctioncopyItem
(item any, n int)
compose/graph_run.go:1020
↓ 2 callersFunctioncopyMap
(m map[K]V)
adk/utils.go:62
↓ 2 callersFunctioncopyMessage
(msg M)
adk/wrappers.go:472
↓ 2 callersFunctionctxWithNewTypedRunCtx
(ctx context.Context, input *TypedAgentInput[M], sharedParentSession bool)
adk/runctx.go:537
↓ 2 callersMethoddecrementRemainingIterations
()
adk/react.go:187
↓ 2 callersMethoddeepCopy
()
compose/graph_call_options.go:109
↓ 2 callersFunctiondeepCopyMap
(in map[string]interface{})
flow/indexer/parent/parent_test.go:115
↓ 2 callersFunctiondeepCopyState
deepCopyState creates a deep copy of the state using serialization
compose/graph_run.go:572
↓ 2 callersFunctiondefaultNewPlan
(ctx context.Context)
adk/prebuilt/planexecute/plan_execute.go:287
↓ 2 callersFunctiondefaultStreamConvertPair
()
compose/generic_helper.go:168
↓ 2 callersFunctiondeprecatedInterruptAndRerunErr
(extra any)
compose/interrupt.go:55
↓ 2 callersFunctiondrainAndAssertCancelError
(t *testing.T, iter *AsyncIterator[*AgentEvent])
adk/cancel_test.go:156
↓ 2 callersFunctiondrainEventsAndAssertCancelError
(t *testing.T, iter *AsyncIterator[*AgentEvent])
adk/cancel_test.go:171
↓ 2 callersMethodexecute
(currentTask *task)
compose/graph_manager.go:285
↓ 2 callersFunctionextractAndDeriveAgentToolCancelCtx
(ctx context.Context, agentName string, opts []tool.Option)
adk/agent_tool.go:325
↓ 2 callersMethodextractDynamicTools
(tools []*schema.ToolInfo)
adk/middlewares/dynamictool/toolsearch/toolsearch.go:239
↓ 2 callersFunctionfieldMap
(mappings []*FieldMapping, allowMapKeyNotFound bool, uncheckedSourcePaths map[string]FieldPath)
compose/field_mapping.go:484
↓ 2 callersFunctionfilterCallbackHandlersForNestedAgents
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 callersFunctionfindLoops
(startNodes []string, chanCalls map[string]*chanCall)
compose/graph.go:1131
↓ 2 callersMethodfindMatches
(filePath, content string, re *regexp.Regexp, req *GrepRequest)
adk/filesystem/backend_inmemory.go:720
↓ 2 callersMethodfinish
()
adk/agentic_react_test.go:141
↓ 2 callersMethodfinishStopCommit
()
adk/turn_loop.go:1554
↓ 2 callersMethodforMapInput
()
compose/generic_helper.go:71
↓ 2 callersMethodforMapOutput
()
compose/generic_helper.go:95
↓ 2 callersMethodforSuccessorPassthrough
()
compose/generic_helper.go:136
↓ 2 callersFunctionformatExecutedSteps
(results []ExecutedStep)
adk/prebuilt/planexecute/plan_execute.go:629
↓ 2 callersFunctionformatFileMatches
(matches []filesystem.GrepMatch, offset, headLimit int)
adk/middlewares/filesystem/filesystem.go:1146
↓ 2 callersFunctionformatInput
formatInput formats the input messages into a string.
adk/prebuilt/planexecute/plan_execute.go:619
↓ 2 callersFunctionformatLineNumbers
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 callersFunctionformatToolMessage
(s string)
adk/middlewares/filesystem/large_tool_result.go:155
↓ 2 callersFunctionformatToolMessage
(s string)
adk/middlewares/reduction/internal/large_tool_result.go:188
↓ 2 callersFunctionforwardCheckPoint
(ctx context.Context, nodeKey string)
compose/checkpoint.go:158
↓ 2 callersMethodgenToolCallTasks
(ctx context.Context, tuple *toolsTuple, input *schema.Message, executedTools map[string]string, executedEnha
compose/tool_node.go:777
↓ 2 callersFunctiongenToolInfos
(ctx context.Context, config *compose.ToolsNodeConfig)
adk/react.go:312
↓ 2 callersMethodgetAgent
(ctx context.Context, name string)
adk/flow.go:174
↓ 2 callersFunctiongetAgenticReturnDirectlyToolCallID
(ctx context.Context)
adk/react.go:569
↓ 2 callersFunctiongetCheckPointFromCtx
(ctx context.Context)
compose/checkpoint.go:151
↓ 2 callersMethodgetChunkType
()
compose/stream_reader.go:29
↓ 2 callersFunctiongetComposeOptions
(opts []AgentRunOption)
adk/chatmodel.go:1642
↓ 2 callersFunctiongetContinueInstruction
()
adk/middlewares/summarization/prompt.go:48
↓ 2 callersMethodgetDelay
()
adk/cancel_test.go:45
↓ 2 callersMethodgetFailoverModel
(ctx context.Context, failoverCtx *FailoverContext[M])
adk/failover_chatmodel.go:214
↓ 2 callersMethodgetMessagesFromState
(ctx context.Context)
adk/middlewares/skill/skill.go:673
↓ 2 callersMethodgetModelInstructions
()
adk/middlewares/summarization/summarization.go:625
↓ 2 callersFunctiongetMsgContentG
(msg M)
adk/middlewares/reduction/reduction_generic_test.go:130
↓ 2 callersFunctiongetNextResumeAgent
(ctx context.Context, _ *ResumeInfo)
adk/interrupt.go:349
↓ 2 callersMethodgetNodeInputType
(name string)
compose/graph.go:648
↓ 2 callersFunctiongetResumeInfo
(ctx context.Context)
internal/core/address.go:323
↓ 2 callersMethodgetReturnDirectlyEvent
()
adk/react.go:106
↓ 2 callersFunctiongetReturnDirectlyToolCallID
(ctx context.Context)
adk/react.go:328
↓ 2 callersMethodgetRunFunc
(ctx context.Context)
adk/chatmodel.go:1401
↓ 2 callersMethodgetToolGenActions
()
adk/react.go:131
↓ 2 callersFunctiongetToolsNodeOptions
(opts ...ToolsNodeOption)
compose/tool_node.go:1278
↓ 2 callersMethodgetType
()
compose/stream_reader.go:28
↓ 2 callersFunctiongetTypeName
(rt reflect.Type)
schema/serialization.go:92
↓ 2 callersFunctiongetTypedAgentType
(agent TypedAgent[M])
adk/flow.go:638
↓ 2 callersFunctiongetUserMessagesReplacedNote
()
adk/middlewares/summarization/prompt.go:69
↓ 2 callersFunctionhandleFlowAgentEvents
(ctx context.Context, iter *AsyncIterator[*AgentEvent], generator *AsyncGenerator[*AgentEvent], isolatedSessi
adk/deterministic_transfer.go:234
↓ 2 callersMethodhandleInterrupt
( ctx context.Context, tempInfo *interruptTempInfo, nextTasks []*task, channels map[string]channel, isStr
compose/graph_run.go:502
↓ 2 callersMethodhandleInterruptWithSubGraphAndRerunNodes
( ctx context.Context, tempInfo *interruptTempInfo, completeTasks []*task, checkPointID *string, isSubGra
compose/graph_run.go:598
↓ 2 callersMethodhandleResult
(ctx context.Context, result string, input *compose.ToolInput)
adk/middlewares/filesystem/large_tool_result.go:103
↓ 2 callersMethodhandleResult
(ctx context.Context, result string, input *compose.ToolInput)
adk/middlewares/reduction/internal/large_tool_result.go:135
↓ 2 callersFunctionhasCyclicDependency
(taskMap map[string]*task, blockerID, blockedID string)
adk/middlewares/plantask/task.go:93
↓ 2 callersMethodhasUserEventSender
()
adk/wrappers.go:1008
↓ 2 callersFunctioninitAgentCallbacks
(ctx context.Context, agentName, agentType string, opts ...AgentRunOption)
adk/callback.go:116
↓ 2 callersFunctioninvokableToStreamable
(e InvokableToolEndpoint)
compose/tool_node.go:714
↓ 2 callersFunctioninvokeWithCallbacks
(i Invoke[I, O, TOption])
compose/utils.go:118
↓ 2 callersFunctionisBase64MessageOutputAudioPart
(part MessageOutputPart)
schema/message.go:1572
↓ 2 callersFunctionisChain
(cmp component)
compose/graph.go:151
↓ 2 callersFunctionisInterruptError
(err error)
compose/interrupt.go:351
↓ 2 callersFunctionisSubGraphInterrupt
(err error)
compose/interrupt.go:329
↓ 2 callersFunctionisToAll
(mappings []*FieldMapping)
compose/field_mapping.go:622
↓ 2 callersMethodlist
(ctx context.Context)
adk/middlewares/skill/filesystem_backend.go:95
↓ 2 callersMethodloadFile
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 callersFunctionmakeAssistantMsgWithToolCalls
(content string, toolCalls []testToolCall)
adk/middlewares/patchtoolcalls/patchtoolcalls_test.go:57
↓ 2 callersFunctionmakeToolMap
--------------------------------------------------------------------------- helpers ------------------------------------------------------------------
adk/middlewares/dynamictool/toolsearch/toolsearch_test.go:42
↓ 2 callersFunctionmarkAgenticMessageStreamingMeta
(msg *schema.AgenticMessage, index int)
adk/wrappers.go:597
↓ 2 callersFunctionmarshalTurnLoopCheckpoint
(c *turnLoopCheckpoint[T])
adk/turn_loop.go:952
↓ 2 callersFunctionmatchFileType
matchFileType checks if the file extension matches the given file type.
adk/filesystem/backend_inmemory.go:410
↓ 2 callersFunctionmessageInputPartsToFunctionToolBlocks
(parts []schema.MessageInputPart)
compose/agentic_tools_node.go:177
↓ 2 callersFunctionmessageUserTextContent
(m *schema.Message)
adk/middlewares/summarization/summarization.go:984
↓ 2 callersFunctionnewAgenticRunnerWithStore
(t *testing.T, ctx context.Context, mdl model.BaseModel[*schema.AgenticMessage], tools []tool.BaseTool, store
adk/agentic_react_test.go:185
↓ 2 callersFunctionnewCheckPointer
( inputPairs, outputPairs map[string]streamConvertPair, store CheckPointStore, serializer Serializer, )
compose/checkpoint.go:171
↓ 2 callersFunctionnewCheckpointStore
()
adk/prebuilt/supervisor/supervisor_test.go:254
↓ 2 callersFunctionnewDefaultGenModelInput
()
adk/chatmodel.go:195
↓ 2 callersFunctionnewGraphFromGeneric
( cmp component, stateGenerator func(ctx context.Context) any, stateType reflect.Type, opts []NewGraphOpti
compose/graph.go:100
↓ 2 callersFunctionnewGrepCollector
()
adk/filesystem/backend_inmemory.go:707
← previousnext →1,001–1,100 of 3,994, ranked by callers