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 callersFunctiongetOptionsByAgentName
(agentName string, opts []tool.Option)
adk/agent_tool.go:314
↓ 1 callersMethodgetRetryAttempt
()
adk/react.go:114
↓ 1 callersFunctiongetReturnDirectlyToolCallID
(input *schema.Message, toolReturnDirectly map[string]struct{})
flow/agent/react/react.go:465
↓ 1 callersFunctiongetSkillPreamble
()
adk/middlewares/summarization/prompt.go:324
↓ 1 callersFunctiongetSkillTruncationMarker
()
adk/middlewares/summarization/prompt.go:335
↓ 1 callersFunctiongetStateModifier
*checkpoint
compose/checkpoint.go:123
↓ 1 callersFunctiongetSuccessors
(c *chanCall)
compose/graph.go:894
↓ 1 callersFunctiongetSummaryPreamble
()
adk/middlewares/summarization/prompt.go:41
↓ 1 callersFunctiongetSystemInstruction
()
adk/middlewares/summarization/prompt.go:27
↓ 1 callersMethodgetToolsPerCall
()
adk/middlewares/dynamictool/toolsearch/toolsearch_test.go:284
↓ 1 callersFunctiongetTranscriptPathInstruction
()
adk/middlewares/summarization/prompt.go:55
↓ 1 callersMethodgetTriggerContextTokens
()
adk/middlewares/summarization/summarization.go:373
↓ 1 callersFunctiongetTruncFmt
()
adk/middlewares/reduction/consts.go:57
↓ 1 callersFunctiongetTruncatedMarkerFormat
()
adk/middlewares/summarization/prompt.go:62
↓ 1 callersFunctiongetUserSummaryInstruction
()
adk/middlewares/summarization/prompt.go:34
↓ 1 callersMethodgetValue
(key string)
adk/runctx.go:338
↓ 1 callersMethodgetValues
()
adk/runctx.go:313
↓ 1 callersFunctiongobDecodeAgenticMessageVariant
(mv *TypedMessageVariant[*schema.AgenticMessage], b []byte)
adk/interface.go:229
↓ 1 callersFunctiongobDecodeMessageVariant
(mv *TypedMessageVariant[*schema.Message], b []byte)
adk/interface.go:179
↓ 1 callersFunctiongobEncodeAgenticMessageVariant
(mv *TypedMessageVariant[*schema.AgenticMessage])
adk/interface.go:195
↓ 1 callersFunctiongobEncodeMessageVariant
(mv *TypedMessageVariant[*schema.Message])
adk/interface.go:146
↓ 1 callersMethodgrepFilesInParallel
(filteredFiles []string, re *regexp.Regexp, req *GrepRequest)
adk/filesystem/backend_inmemory.go:247
↓ 1 callersFunctiongroupOutputParts
(parts []MessageOutputPart)
schema/message.go:1387
↓ 1 callersFunctiongroupToolOutputParts
(parts []ToolOutputPart)
schema/message.go:1241
↓ 1 callersFunctionhasAgentsMDExtra
hasAgentsMDExtra checks whether a message has the agentsmd extra key set.
adk/middlewares/agentsmd/agentsmd.go:119
↓ 1 callersFunctionhasCorrespondingAgenticToolResult
(messages []*schema.AgenticMessage, toolCallID string)
adk/middlewares/patchtoolcalls/patchtoolcalls.go:183
↓ 1 callersFunctionhasCorrespondingToolMessage
(messages []*schema.Message, toolCallID string)
adk/middlewares/patchtoolcalls/patchtoolcalls.go:170
↓ 1 callersFunctionhasToolSearchReminderExtra
(msg M)
adk/middlewares/dynamictool/toolsearch/toolsearch.go:217
↓ 1 callersFunctionhasUserEventSenderToolWrapper
(handlers []TypedChatModelAgentMiddleware[M])
adk/wrappers.go:975
↓ 1 callersFunctioninList
(elem string, list []string)
flow/retriever/parent/parent.go:106
↓ 1 callersMethodinitChannelManager
(isStream bool)
compose/graph_run.go:948
↓ 1 callersFunctioninitGraphCallbacks
(ctx context.Context, info *nodeInfo, meta *executorMeta, opts ...Option)
compose/utils.go:152
↓ 1 callersFunctioninitNodeCallbacks
(ctx context.Context, key string, info *nodeInfo, meta *executorMeta, opts ...Option)
compose/utils.go:177
↓ 1 callersMethodinitTaskManager
(runWrapper runnableCallWrapper, cancelVal *graphCancelChanVal, opts ...Option)
compose/graph_run.go:933
↓ 1 callersFunctioninputKeyedComposableRunnable
(key string, r *composableRunnable)
compose/runnable.go:457
↓ 1 callersFunctioninstantiateIfNeeded
(field reflect.Value)
compose/field_mapping.go:366
↓ 1 callersFunctionintMin
(a, b int)
adk/middlewares/dynamictool/toolsearch/toolsearch.go:493
↓ 1 callersFunctionintPtr
(v int)
adk/middlewares/dynamictool/toolsearch/toolsearch_test.go:69
↓ 1 callersFunctioninternalMarshal
(v any, fieldType reflect.Type)
internal/serialization/serialization.go:248
↓ 1 callersFunctioninternalSpecificTypeUnmarshal
(is *internalStruct, typ reflect.Type)
internal/serialization/serialization.go:510
↓ 1 callersFunctioninvokeByCollect
(c Collect[I, O, TOption])
compose/runnable.go:214
↓ 1 callersFunctioninvokeByStream
(s Stream[I, O, TOption])
compose/runnable.go:203
↓ 1 callersFunctioninvokeByTransform
(t Transform[I, O, TOption])
compose/runnable.go:222
↓ 1 callersFunctioninvokeEnhancedWithCallbacks
(i func(ctx context.Context, toolArgument *schema.ToolArgument, opts ...tool.Option) (*schema.ToolResult, erro
compose/tool_node.go:748
↓ 1 callersFunctionisFromAll
(mappings []*FieldMapping)
compose/field_mapping.go:603
↓ 1 callersMethodisInitialized
(ctx context.Context)
adk/middlewares/dynamictool/toolsearch/toolsearch.go:156
↓ 1 callersFunctionisInterruptRerunError
(err error)
compose/interrupt.go:246
↓ 1 callersFunctionisMergeableOutputPartType
(part MessageOutputPart)
schema/message.go:1424
↓ 1 callersFunctionisNilAssignableType
(t reflect.Type)
compose/runnable.go:72
↓ 1 callersFunctionisNilMessage
(msg M)
adk/middlewares/skill/skill.go:668
↓ 1 callersMethodisRoot
()
adk/cancel.go:343
↓ 1 callersFunctionisSystemRoleTS
(msg M)
adk/middlewares/dynamictool/toolsearch/toolsearch.go:192
↓ 1 callersFunctionisTypedNil
(v any)
compose/checkpoint.go:232
↓ 1 callersFunctionisUserRole
(msg M)
adk/middlewares/agentsmd/agentsmd.go:153
↓ 1 callersFunctionkeywordSearch
keywordSearch scores all tools against the query keywords and returns the top N.
adk/middlewares/dynamictool/toolsearch/toolsearch.go:507
↓ 1 callersMethodloadChannels
(channels map[string]channel)
compose/graph_manager.go:127
↓ 1 callersMethodloadContent
loadContent retrieves the Agents.md content, using a per-Run cache to avoid reloading on every model call within the same Run().
adk/middlewares/agentsmd/agentsmd.go:180
↓ 1 callersMethodmarkInitialized
(ctx context.Context)
adk/middlewares/dynamictool/toolsearch/toolsearch.go:165
↓ 1 callersFunctionmergeAudioParts
(group []MessageOutputPart)
schema/message.go:1518
↓ 1 callersFunctionmergeMap
(typ reflect.Type, vs []any)
internal/merge.go:62
↓ 1 callersFunctionmergeOutputPartGroup
(group []MessageOutputPart)
schema/message.go:1435
↓ 1 callersFunctionmergeReasoningParts
(group []MessageOutputPart)
schema/message.go:1484
↓ 1 callersFunctionmergeTextParts
(group []MessageOutputPart)
schema/message.go:1459
↓ 1 callersFunctionmergeToolTextParts
(group []ToolOutputPart)
schema/message.go:1260
↓ 1 callersMethodmergeWithNames
([]streamReader, []string)
compose/stream_reader.go:34
↓ 1 callersFunctionmessageOutputContent
(event *AgentEvent)
adk/cancel_edge_test.go:2066
↓ 1 callersFunctionmigrateCheckpoint
migrateCheckpoint recursively applies migrate to cp.State and all SubGraphs.
compose/checkpoint.go:277
↓ 1 callersFunctionmockStreamableToolWithError
()
adk/middlewares/reduction/reduction_test.go:1180
↓ 1 callersFunctionmustParseTime
(s string)
adk/filesystem/backend_inmemory.go:130
↓ 1 callersFunctionnewAgenticReact
(ctx context.Context, config *agenticReactConfig)
adk/react.go:604
↓ 1 callersFunctionnewCheckpointStore
()
adk/prebuilt/planexecute/plan_execute_test.go:771
↓ 1 callersFunctionnewCheckpointTestTool
(info *schema.ToolInfo, f func(ctx context.Context, in I) (O, error))
compose/checkpoint_test.go:2037
↓ 1 callersFunctionnewCompatCheckpointStore
()
adk/prebuilt/deep/checkpoint_compat_resume_test.go:42
↓ 1 callersFunctionnewGraph
(cfg *newGraphConfig)
compose/graph.go:117
↓ 1 callersFunctionnewIntegrationCheckpointStore
()
adk/prebuilt/integration_test.go:112
↓ 1 callersMethodnewLoader
()
adk/middlewares/agentsmd/loader.go:102
↓ 1 callersFunctionnewManager
(runInfo *RunInfo, handlers ...Handler)
internal/callbacks/manager.go:32
↓ 1 callersFunctionnewResultModifyingInvokableToolCallWrapper
(modifyFn func(string) string)
adk/handler_test.go:159
↓ 1 callersFunctionnewStopCancelRequest
(opts []AgentCancelOption, now time.Time)
adk/turn_loop.go:384
↓ 1 callersFunctionnewStreamConverter
(inputPairs, outputPairs map[string]streamConvertPair)
compose/checkpoint.go:339
↓ 1 callersFunctionnewStreamReadError
(err error)
compose/error.go:50
↓ 1 callersFunctionnewStreamReaderWithConvert
(origin iStreamReader, convert func(any) (T, error), opts ...ConvertOption)
schema/stream.go:606
↓ 1 callersFunctionnewStreamableTool
(info *schema.ToolInfo, f func(ctx context.Context, in I) (*schema.StreamReader[O], error))
compose/tool_node_test.go:994
↓ 1 callersFunctionnewToolResultCollectorMiddleware
()
flow/agent/react/react.go:65
↓ 1 callersFunctionnewToolSearchTool
(tools map[string]*schema.ToolInfo, useModelToolSearch bool)
adk/middlewares/dynamictool/toolsearch/toolsearch.go:347
↓ 1 callersFunctionnewTypedEventSenderToolWrapper
newTypedEventSenderToolWrapper creates a typed event sender wrapper for the given message type. This is used internally to ensure the default event se
adk/wrappers.go:567
↓ 1 callersFunctionnewUnknownToolTask
(name, arg, callID string, unknownToolHandler func(ctx context.Context, name, input string) (string, error))
compose/tool_node.go:868
↓ 1 callersFunctionnormalizeCheckpointTypedNilInputs
(cp *checkpoint)
compose/checkpoint.go:218
↓ 1 callersMethodonCompileFinish
(ctx context.Context, opt *graphCompileOptions, key2SubGraphs map[string]*GraphInfo)
compose/graph.go:1011
↓ 1 callersFunctiononGraphEnd
(ctx context.Context, output any, isStream bool)
compose/utils.go:129
↓ 1 callersFunctiononGraphError
(ctx context.Context, err error)
compose/utils.go:136
↓ 1 callersMethodonGraphStart
(ctx context.Context, _ *callbacks.RunInfo, _ callbacks.CallbackInput)
flow/agent/react/option.go:352
↓ 1 callersMethodonGraphStartWithStreamInput
(ctx context.Context, _ *callbacks.RunInfo, input *schema.StreamReader[callbacks.CallbackInput])
flow/agent/react/option.go:365
↓ 1 callersFunctionoutputKeyedComposableRunnable
(key string, r *composableRunnable)
compose/runnable.go:492
↓ 1 callersFunctionparamInfoToJSONSchema
(paramInfo *ParameterInfo)
schema/tool.go:336
↓ 1 callersFunctionparseKeywords
parseKeywords splits a query string into keywords, handling the '+' required prefix.
adk/middlewares/dynamictool/toolsearch/toolsearch.go:586
↓ 1 callersFunctionpatchToolCallsForAgenticMessage
(ctx context.Context, gen func(ctx context.Context, toolName, toolCallID string) (string, error), state *adk
adk/middlewares/patchtoolcalls/patchtoolcalls.go:121
↓ 1 callersFunctionpatchToolCallsForMessage
(ctx context.Context, gen func(ctx context.Context, toolName, toolCallID string) (string, error), state *adk
adk/middlewares/patchtoolcalls/patchtoolcalls.go:89
↓ 1 callersMethodpeek
peek is not safe for concurrent use with the same idx but is safe for different idx. Ensure that each child StreamReader uses a for-loop in a single g
schema/stream.go:837
↓ 1 callersMethodplanTurn
( ctx context.Context, isResume bool, items []T, pr *turnLoopPendingResume[T], )
adk/turn_loop.go:711
← previousnext →1,501–1,600 of 3,994, ranked by callers