MCPcopy Create free account

hub / github.com/cloudwego/eino / functions

Functions3,994 in github.com/cloudwego/eino

⨍ Functions 3,994◇ Types & classes 1,204
↓ 1 callersFunctionconcatAssistantGenTexts
(texts []*AssistantGenText)
schema/agentic_message.go:1404
↓ 1 callersFunctionconcatAssistantMultiContent
(parts []MessageOutputPart)
schema/message.go:1368
↓ 1 callersFunctionconcatChunksOfSameContentBlock
(blocks []*ContentBlock)
schema/agentic_message.go:1137
↓ 1 callersFunctionconcatFunctionToolResults
(results []*FunctionToolResult)
schema/agentic_message.go:1618
↓ 1 callersFunctionconcatMaps
(ms reflect.Value)
internal/concat.go:113
↓ 1 callersFunctionconcatTokenUsage
(usages []*TokenUsage)
schema/agentic_message.go:1105
↓ 1 callersFunctionconcatToolOutputParts
(parts []ToolOutputPart)
schema/message.go:1213
↓ 1 callersFunctionconcatUserMultiContent
(parts []MessageInputPart)
schema/message.go:1579
↓ 1 callersMethodconsumeStream
consumeStream drains the typed message stream, setting concatenatedMessage on success or StreamErr on failure. The stream is replaced with a materiali
adk/runctx.go:125
↓ 1 callersFunctionconsumeStreamForError
(stream *schema.StreamReader[M])
adk/retry_chatmodel.go:295
↓ 1 callersFunctionconvAgenticToolsNodeCallbackInput
(src callbacks.CallbackInput)
utils/callbacks/template.go:777
↓ 1 callersFunctionconvToolsNodeCallbackInput
(src callbacks.CallbackInput)
utils/callbacks/template.go:644
↓ 1 callersMethodconvertInputs
(isStream bool, values map[string]any)
compose/checkpoint.go:350
↓ 1 callersMethodconvertOutputs
(isStream bool, values map[string]any)
compose/checkpoint.go:358
↓ 1 callersFunctionconvertPostHandler
(handler StatePostHandler[O, S])
compose/state.go:69
↓ 1 callersFunctionconvertPreHandler
(handler StatePreHandler[I, S])
compose/state.go:54
↓ 1 callersFunctioncopyAgenticMessages
(msgs []*schema.AgenticMessage)
adk/middlewares/reduction/reduction.go:1120
↓ 1 callersFunctioncountRemindersGeneric
(msgs []M)
adk/middlewares/dynamictool/toolsearch/toolsearch_generic_test.go:192
↓ 1 callersFunctioncreatePatchedAgenticToolMessage
(ctx context.Context, gen func(ctx context.Context, toolName, toolCallID string) (string, error), toolName, ca
adk/middlewares/patchtoolcalls/patchtoolcalls.go:230
↓ 1 callersFunctioncreatePatchedToolMessage
(ctx context.Context, gen func(ctx context.Context, toolName, toolCallID string) (string, error), tc schema.To
adk/middlewares/patchtoolcalls/patchtoolcalls.go:214
↓ 1 callersMethodcreateTasks
(ctx context.Context, nodeMap map[string]any, optMap map[string][]any)
compose/graph_run.go:735
↓ 1 callersFunctioncreateToolFromSpec
createToolFromSpec creates a tool instance based on the provided toolSpec. It handles configuration merging (ToolConfig + legacy Desc), checks if the
adk/middlewares/filesystem/filesystem.go:537
↓ 1 callersFunctionctxWithFusionRunInfo
(ctx context.Context)
flow/retriever/multiquery/multi_query.go:202
↓ 1 callersFunctionctxWithFusionRunInfo
(ctx context.Context)
flow/retriever/router/router.go:186
↓ 1 callersFunctionctxWithRetrieverRunInfo
(ctx context.Context, r retriever.Retriever)
flow/retriever/utils/utils.go:74
↓ 1 callersFunctionctxWithRouterRunInfo
(ctx context.Context)
flow/retriever/router/router.go:175
↓ 1 callersMethoddeepCopy
()
adk/flow.go:54
↓ 1 callersFunctiondeepCopyAgentInput
(ai *AgentInput)
adk/flow.go:264
↓ 1 callersFunctiondefaultAgenticTokenCounter
(_ context.Context, msgs []*schema.AgenticMessage, tools []*schema.ToolInfo)
adk/middlewares/reduction/reduction.go:381
↓ 1 callersMethoddefaultSkillContent
(skill Skill)
adk/middlewares/skill/skill.go:497
↓ 1 callersFunctiondefaultToolParams
()
adk/middlewares/skill/skill.go:447
↓ 1 callersMethoddeleteTurnLoopCheckpoint
(ctx context.Context, checkPointID string)
adk/turn_loop.go:979
↓ 1 callersFunctionderefPointerNum
(t reflect.Type)
internal/serialization/serialization.go:646
↓ 1 callersFunctionencapsulateContextAddresses
(ctx *InterruptCtx, allowedSet map[AddressSegmentType]bool)
internal/core/interrupt.go:314
↓ 1 callersMethodencode
(data []byte)
adk/middlewares/filesystem/filesystem.go:1120
↓ 1 callersFunctionenhancedInvokableToEnhancedStreamable
(e EnhancedInvokableToolEndpoint)
compose/tool_node.go:738
↓ 1 callersFunctionenhancedStreamableToEnhancedInvokable
(e EnhancedStreamableToolEndpoint)
compose/tool_node.go:724
↓ 1 callersFunctionestimateTokenBytes
(tokens int)
adk/middlewares/summarization/summarization.go:480
↓ 1 callersFunctionexcluded
(name string, exclude []string)
adk/middlewares/reduction/internal/clear_tool_result.go:158
↓ 1 callersMethodextractData
extractData extracts data from a string using the parse key path.
schema/message_parser.go:105
↓ 1 callersFunctionextractOption
(nodes map[string]*chanCall, opts ...Option)
compose/utils.go:255
↓ 1 callersFunctionextractSkillInfos
(messages []M, skillTool string)
adk/middlewares/summarization/finalizer_builder.go:240
↓ 1 callersFunctionextractToolSearchResult
extractToolSearchResult checks if the given message is a tool result from the tool_search tool, and if so returns the content string. Returns ("", fal
adk/middlewares/dynamictool/toolsearch/toolsearch.go:326
↓ 1 callersMethodfilterByFileType
(files []string, fileType string)
adk/filesystem/backend_inmemory.go:396
↓ 1 callersMethodfilterByGlob
(files []string, searchPath string, globPattern string)
adk/filesystem/backend_inmemory.go:369
↓ 1 callersMethodfilterFiles
(searchPath string, req *GrepRequest)
adk/filesystem/backend_inmemory.go:341
↓ 1 callersFunctionfilterParentChain
(ctx *InterruptCtx, allowedSet map[AddressSegmentType]bool)
internal/core/interrupt.go:296
↓ 1 callersFunctionfindLastMatch
(re *regexp.Regexp, s string)
adk/middlewares/summarization/summarization.go:802
↓ 1 callersMethodfindMultilineMatches
(filePath, content string, re *regexp.Regexp)
adk/filesystem/backend_inmemory.go:727
↓ 1 callersMethodfindSingleLineMatches
(filePath, content string, re *regexp.Regexp)
adk/filesystem/backend_inmemory.go:749
↓ 1 callersFunctionformatAgentEventIntegration
(event *adk.AgentEvent)
adk/prebuilt/integration_test.go:172
↓ 1 callersFunctionformatChatMessagePart
(part ChatMessagePart)
schema/message.go:1075
↓ 1 callersFunctionformatContentMatches
(matches []filesystem.GrepMatch, showLineNum bool)
adk/middlewares/filesystem/filesystem.go:1168
↓ 1 callersFunctionformatCountMatches
(matches []filesystem.GrepMatch, offset, headLimit int)
adk/middlewares/filesystem/filesystem.go:1186
↓ 1 callersFunctionformatInputPart
(part MessageInputPart)
schema/message.go:910
↓ 1 callersFunctionformatLoops
(loops [][]string)
compose/graph.go:1184
↓ 1 callersFunctionformatMessageInputFile
(file *MessageInputFile)
schema/message.go:982
↓ 1 callersFunctionformatOutputPart
(part MessageOutputPart)
schema/message.go:1008
↓ 1 callersFunctionformatRunPath
(runPath []adk.RunStep)
adk/prebuilt/integration_test.go:161
↓ 1 callersFunctionformatUserInputAudio
(uia *UserInputAudio, vs map[string]any, formatType FormatType)
schema/agentic_message.go:831
↓ 1 callersFunctionformatUserInputFile
(uif *UserInputFile, vs map[string]any, formatType FormatType)
schema/agentic_message.go:869
↓ 1 callersFunctionformatUserInputImage
(uii *UserInputImage, vs map[string]any, formatType FormatType)
schema/agentic_message.go:812
↓ 1 callersFunctionformatUserInputText
(uit *UserInputText, vs map[string]any, formatType FormatType)
schema/agentic_message.go:802
↓ 1 callersFunctionformatUserInputVideo
(uiv *UserInputVideo, vs map[string]any, formatType FormatType)
schema/agentic_message.go:850
↓ 1 callersFunctionfromFields
(mappings []*FieldMapping)
compose/field_mapping.go:612
↓ 1 callersMethodgenAgentInput
(ctx context.Context, runCtx *runContext, skipTransferMessages bool)
adk/flow.go:275
↓ 1 callersFunctiongenAgenticErrorIter
(err error)
adk/flow.go:795
↓ 1 callersFunctiongenAgenticReactState
(config *agenticReactConfig)
adk/react.go:578
↓ 1 callersFunctiongenAnonymousFunc
()
internal/generic/type_name_test.go:82
↓ 1 callersFunctiongenErrWrapper
(ctx context.Context, maxRetries, attempt int, isRetryAbleFunc func(ctx context.Context, err error) bool)
adk/retry_chatmodel.go:283
↓ 1 callersMethodgenInput
(ctx context.Context)
adk/prebuilt/planexecute/plan_execute.go:646
↓ 1 callersFunctiongenMsg
(entry *HistoryEntry, agentName string)
adk/flow.go:255
↓ 1 callersFunctiongenReactState
(config *reactConfig)
adk/react.go:340
↓ 1 callersFunctiongenStruct
()
internal/generic/type_name_test.go:76
↓ 1 callersFunctiongenToolInfos
(ctx context.Context, config compose.ToolsNodeConfig)
flow/agent/react/react.go:451
↓ 1 callersFunctiongenTransferToAgentInstruction
(ctx context.Context, agents []TypedAgent[M])
adk/instruction.go:48
↓ 1 callersMethodgenerateLegacy
(ctx context.Context, input []M, opts ...model.Option)
adk/retry_chatmodel.go:339
↓ 1 callersFunctiongenerateWithShouldRetry
(r *typedRetryModelWrapper[M], ctx context.Context, input []M, opts ...model.Option)
adk/retry_chatmodel.go:379
↓ 1 callersFunctiongenericGetTFromContentBlocks
(blocks []*ContentBlock, checkAndGetter func(block *ContentBlock) (T, error))
schema/agentic_message.go:1298
↓ 1 callersFunctiongenericOnEndWithStreamOutput
(ctx context.Context, output streamReader)
compose/utils.go:92
↓ 1 callersFunctiongenericOnStartWithStreamInput
(ctx context.Context, input streamReader)
compose/utils.go:65
↓ 1 callersFunctiongetAddInputOpts
(opts []WorkflowAddInputOpt)
compose/workflow.go:215
↓ 1 callersFunctiongetCheckPointFromStore
(ctx context.Context, id string, cpr *checkPointer)
compose/checkpoint.go:134
↓ 1 callersFunctiongetCheckPointInfo
(opts ...Option)
compose/graph_run.go:758
↓ 1 callersFunctiongetClearWithOffloadingFmt
()
adk/middlewares/reduction/consts.go:64
↓ 1 callersFunctiongetClearWithoutOffloadingFmt
()
adk/middlewares/reduction/consts.go:71
↓ 1 callersFunctiongetDefaultTokenCounter
getDefaultTokenCounter returns a default token counter function that operates on []M. For *schema.Message it delegates to defaultTokenCounter. For *sc
adk/middlewares/reduction/reduction.go:366
↓ 1 callersMethodgetEventsReceived
()
adk/callback_integration_test.go:55
↓ 1 callersFunctiongetFailoverHasMoreAttempts
getFailoverHasMoreAttempts returns true if the current failover attempt has more attempts after it, false otherwise (including when no failover contex
adk/failover_chatmodel.go:54
↓ 1 callersMethodgetFromReadyChannels
(_ context.Context)
compose/graph_manager.go:189
↓ 1 callersFunctiongetGraphAddNodeOpts
(opts ...GraphAddNodeOpt)
compose/graph_add_node_options.go:151
↓ 1 callersFunctiongetGraphCancel
(ctx context.Context)
compose/graph_call_options.go:87
↓ 1 callersFunctiongetJinjaEnv
()
schema/message.go:1876
↓ 1 callersFunctiongetLambdaOpt
(opts ...LambdaOpt)
compose/types_lambda.go:203
↓ 1 callersFunctiongetLanguage
GetLanguage returns the current language setting for the ADK built-in prompts. Returns LanguageEnglish if no language has been set.
adk/internal/config.go:50
↓ 1 callersFunctiongetMsgExtra
(msg M)
adk/middlewares/agentsmd/agentsmd_generic_test.go:102
↓ 1 callersFunctiongetNextResumeAgents
(ctx context.Context, _ *ResumeInfo)
adk/interrupt.go:374
↓ 1 callersFunctiongetNodePath
(ctx context.Context)
compose/resume.go:123
↓ 1 callersMethodgetOnEndCalled
()
adk/callback_integration_test.go:49
↓ 1 callersMethodgetOnStartCalled
()
adk/callback_integration_test.go:43
← previousnext →1,401–1,500 of 3,994, ranked by callers