MCPcopy Create free account

hub / github.com/cloudwego/eino / functions

Functions3,994 in github.com/cloudwego/eino

↓ 1 callersFunctionStreamableLambdaWithOption
StreamableLambdaWithOption creates a Lambda with streamable lambda function and options.
compose/types_lambda.go:114
↓ 1 callersMethodString
String returns the string representation of the FieldMapping.
compose/field_mapping.go:40
↓ 1 callersMethodSubIndexes
SubIndexes returns the sub indexes of the document. can use doc.WithSubIndexes() to set the sub indexes.
schema/document.go:70
↓ 1 callersFunctionToList
ToList creates a Lambda that converts input I to a []I. It's useful when you want to convert a single input to a list of inputs. eg. lambda := compo
compose/types_lambda.go:224
↓ 1 callersMethodTransform
Transform works like `stream input => stream output`.
compose/runnable.go:186
↓ 1 callersFunctionTransformableLambdaWithOption
TransformableLambdaWithOption creates a Lambda with transformable lambda function and options.
compose/types_lambda.go:146
↓ 1 callersFunctionTypedCompositeInterrupt
TypedCompositeInterrupt creates a typed interrupt event that aggregates sub-interrupt signals. It is the generic counterpart of CompositeInterrupt; se
adk/interrupt.go:129
↓ 1 callersMethodUnwrap
()
compose/interrupt.go:71
↓ 1 callersMethodUnwrap
()
compose/error.go:109
↓ 1 callersFunctionWithAgenticToolChoice
WithAgenticToolChoice is the option to set tool choice for the agentic model. Only available for AgenticModel.
components/model/option.go:168
↓ 1 callersFunctionWithDSLInfo
WithDSLInfo wraps the dsl info option.
components/retriever/option.go:85
↓ 1 callersMethodWithDSLInfo
WithDSLInfo attaches a domain-specific-language query description to the document. This is consumed by Retriever implementations that support structur
schema/document.go:143
↓ 1 callersMethodWithDenseVector
WithDenseVector sets the dense vector of the document. can use doc.DenseVector() to get the dense vector.
schema/document.go:170
↓ 1 callersFunctionWithDisallowTransferToParent
WithDisallowTransferToParent prevents a sub-agent from transferring to its parent. NOT RECOMMENDED: Agent transfer with full context sharing between
adk/flow.go:86
↓ 1 callersFunctionWithEmbedding
WithEmbedding is the option to set the embedder for the indexer, which convert document to embeddings.
components/indexer/option.go:50
↓ 1 callersFunctionWithEmbedding
WithEmbedding wraps the embedder option.
components/retriever/option.go:76
↓ 1 callersFunctionWithEmbeddingOption
WithEmbeddingOption is a functional option type for embedding component. e.g. embeddingOption := compose.WithEmbeddingOption(embedding.WithModel("te
compose/graph_call_options.go:157
↓ 1 callersMethodWithExtraInfo
WithExtraInfo sets the extra info of the document. can use doc.ExtraInfo() to get the extra info.
schema/document.go:114
↓ 1 callersFunctionWithForceNewRun
WithForceNewRun forces the graph to run from the beginning, ignoring any checkpoints.
compose/checkpoint.go:91
↓ 1 callersFunctionWithIndex
WithIndex wraps the index option.
components/indexer/option.go:32
↓ 1 callersFunctionWithIndex
WithIndex wraps the index option.
components/retriever/option.go:40
↓ 1 callersFunctionWithLoaderOption
WithLoaderOption is a functional option type for loader component. e.g. loaderOption := compose.WithLoaderOption(document.WithCollection("my_collect
compose/graph_call_options.go:175
↓ 1 callersFunctionWithMaxTokens
WithMaxTokens is the option to set the max tokens for the model.
components/model/option.go:80
↓ 1 callersFunctionWithModel
WithModel is the option to set the model for the embedding.
components/embedding/option.go:33
↓ 1 callersFunctionWithName
(n string)
components/prompt/option_test.go:36
↓ 1 callersFunctionWithName
(n string)
components/model/option_test.go:121
↓ 1 callersFunctionWithParserOptions
WithParserOptions attaches parser options to a loader request.
components/document/option.go:102
↓ 1 callersFunctionWithRetrieverOption
WithRetrieverOption is a functional option type for retriever component. e.g. retrieverOption := compose.WithRetrieverOption(retriever.WithIndex("my
compose/graph_call_options.go:166
↓ 1 callersMethodWithScore
WithScore sets the relevance score on the document, typically written by a Retriever after ranking results. A higher score means higher relevance. Not
schema/document.go:87
↓ 1 callersFunctionWithScoreThreshold
WithScoreThreshold wraps the score threshold option.
components/retriever/option.go:67
↓ 1 callersFunctionWithStop
WithStop is the option to set the stop words for the model.
components/model/option.go:107
↓ 1 callersFunctionWithSubIndex
WithSubIndex wraps the sub index option.
components/retriever/option.go:49
↓ 1 callersFunctionWithSubIndexes
WithSubIndexes is the option to set the sub indexes for the indexer.
components/indexer/option.go:41
↓ 1 callersMethodWithSubIndexes
WithSubIndexes sets the sub-indexes on the document metadata and returns the document for chaining. Sub-indexes let an Indexer route a document into m
schema/document.go:58
↓ 1 callersFunctionWithToolOptions
WithToolOptions sets options for tools used by the chat model agent.
adk/chatmodel.go:104
↓ 1 callersFunctionWithTopK
WithTopK wraps the top k option.
components/retriever/option.go:58
↓ 1 callersFunctionWithUserID
(uid int64)
components/prompt/option_test.go:30
↓ 1 callersFunctionWithUserID
(uid int64)
components/model/option_test.go:115
↓ 1 callersFunctionWithUserInfoOption
(s string)
components/tool/utils/invokable_func_test.go:205
↓ 1 callersFunctionWrapImplSpecificOptFn
WrapImplSpecificOptFn returns an agent option that specifies a function to modify the implementation-specific options.
flow/agent/agent_option.go:48
↓ 1 callersFunctionWrapToolWithErrorHandler
WrapToolWithErrorHandler wraps any BaseTool with custom error handling. This function detects the tool type (InvokableTool, StreamableTool, or both) a
components/tool/utils/error_handler.go:42
↓ 1 callersFunctionaddAfterSpecialistsBranch
(g *compose.Graph[[]*schema.Message, *schema.Message])
flow/agent/multiagent/host/compose.go:263
↓ 1 callersMethodaddBlockedByToTask
(ctx context.Context, targetTaskID, blockerTaskID string)
adk/middlewares/plantask/task_update.go:335
↓ 1 callersMethodaddBlocksToTask
(ctx context.Context, targetTaskID, blockedTaskID string)
adk/middlewares/plantask/task_update.go:362
↓ 1 callersFunctionaddDirectAnswerBranch
(convertorName string, g *compose.Graph[[]*schema.Message, *schema.Message], toolCallChecker func(ctx context
flow/agent/multiagent/host/compose.go:205
↓ 1 callersFunctionaddHostAgent
(model model.BaseChatModel, prompt string, g *compose.Graph[[]*schema.Message, *schema.Message], hostNodeName
flow/agent/multiagent/host/compose.go:187
↓ 1 callersFunctionaddMultiIntentsSummarizeNode
(summarizer *Summarizer, g *compose.Graph[[]*schema.Message, *schema.Message])
flow/agent/multiagent/host/compose.go:286
↓ 1 callersFunctionaddMultiSpecialistsBranch
(convertorName string, agentMap map[string]bool, g *compose.Graph[[]*schema.Message, *schema.Message])
flow/agent/multiagent/host/compose.go:222
↓ 1 callersFunctionaddSingleIntentAnswerNode
(g *compose.Graph[[]*schema.Message, *schema.Message])
flow/agent/multiagent/host/compose.go:246
↓ 1 callersFunctionaddSpecialistAgent
(specialist *Specialist, g *compose.Graph[[]*schema.Message, *schema.Message])
flow/agent/multiagent/host/compose.go:154
↓ 1 callersFunctionaddTypedEvent
(session *runSession, event *TypedAgentEvent[M])
adk/runctx.go:295
↓ 1 callersMethodaddValue
(key string, value any)
adk/runctx.go:324
↓ 1 callersMethodaddValues
(kvs map[string]any)
adk/runctx.go:330
↓ 1 callersFunctionagentOutputSessionKVs
(_ context.Context, agent adk.Agent)
adk/prebuilt/planexecute/utils_test.go:56
↓ 1 callersFunctionappendIfNotExist
(s []string, elem string)
compose/graph_manager.go:248
↓ 1 callersFunctionappendModelToChain
(chain *compose.Chain[I, O], m model.BaseModel[M])
adk/chatmodel.go:966
↓ 1 callersMethodapplyAliasConfigs
(aliasConfigs map[string]ToolAliasConfig)
compose/tool_node.go:382
↓ 1 callersMethodapplyArgsAliases
applyArgsAliases validates argument aliases against the tool schema and builds a reverse alias map for a single tool.
compose/tool_node.go:435
↓ 1 callersMethodapplyBeforeAgent
(ctx context.Context, ec *execContext)
adk/chatmodel.go:793
↓ 1 callersMethodapplyClearRewriteGeneric
(ctx context.Context, state *adk.TypedChatModelAgentState[M], start, end int, clearAtLeastTokens int64)
adk/middlewares/reduction/reduction.go:785
↓ 1 callersMethodapplyNameAliases
applyNameAliases validates and registers name aliases for a single tool into the indexes map.
compose/tool_node.go:414
↓ 1 callersFunctionassertMsgContent
(t *testing.T, msg M, expectedContent string)
adk/middlewares/patchtoolcalls/patchtoolcalls_test.go:104
↓ 1 callersFunctionassertToolResultID
(t *testing.T, msg M, expectedID string)
adk/middlewares/patchtoolcalls/patchtoolcalls_test.go:124
↓ 1 callersFunctionassertToolResultName
(t *testing.T, msg M, expectedName string)
adk/middlewares/patchtoolcalls/patchtoolcalls_test.go:140
↓ 1 callersFunctionassignOne
(destValue reflect.Value, taken any, to string)
compose/field_mapping.go:250
↓ 1 callersMethodbeforeChildGraphCompile
(nodeKey string, key2SubGraphs map[string]*GraphInfo)
compose/graph.go:936
↓ 1 callersMethodbeforeChildGraphsCompile
(opt *graphCompileOptions)
compose/graph.go:928
↓ 1 callersMethodbeforeModelRewriteStateGeneric
(ctx context.Context, state *adk.TypedChatModelAgentState[M], _ *adk.TypedModelContext[M])
adk/middlewares/reduction/reduction.go:623
↓ 1 callersMethodbuildAgenticReActRunFunc
(_ context.Context, bc *execContext)
adk/chatmodel.go:1236
↓ 1 callersMethodbuildContentResult
(b *InMemoryBackend, req *GrepRequest)
adk/filesystem/backend_inmemory.go:768
↓ 1 callersFunctionbuildDefaultHistoryRewriter
(agentName string)
adk/flow.go:330
↓ 1 callersFunctionbuildGenReplannerInputFn
(planToolName, respondToolName string)
adk/prebuilt/planexecute/plan_execute.go:784
↓ 1 callersFunctionbuildInternalFinalizer
(cfg *TypedConfig[M])
adk/middlewares/summarization/summarization.go:634
↓ 1 callersMethodbuildMessageReActRunFunc
(_ context.Context, bc *execContext)
adk/chatmodel.go:1097
↓ 1 callersFunctionbuildModelWrappersImpl
(m model.BaseModel[M], config *typedModelWrapperConfig[M])
adk/wrappers.go:56
↓ 1 callersMethodbuildResults
(b *InMemoryBackend, req *GrepRequest)
adk/filesystem/backend_inmemory.go:764
↓ 1 callersFunctionbuildReturnDirectly
(graph *compose.Graph[[]*schema.Message, *schema.Message])
flow/agent/react/react.go:399
↓ 1 callersMethodbuildRunFunc
(ctx context.Context)
adk/chatmodel.go:1366
↓ 1 callersMethodbuildStreamConvertOptions
buildStreamConvertOptions constructs ConvertOption hooks that gate stream termination behind the retry verdict signal protocol. Verdict signal lifecy
adk/wrappers.go:366
↓ 1 callersMethodcalculateBranch
(ctx context.Context, curNodeKey string, startChan *chanCall, input []any, isStream bool, cm *channelManager)
compose/graph_run.go:866
↓ 1 callersFunctioncanMergeOutputParts
(current, next MessageOutputPart)
schema/message.go:1408
↓ 1 callersFunctioncanReach
(taskMap map[string]*task, fromID, toID string, visited map[string]bool)
adk/middlewares/plantask/task.go:102
↓ 1 callersFunctioncheckAndExtractFromField
(fromField string, input reflect.Value)
compose/field_mapping.go:398
↓ 1 callersFunctioncheckAndExtractFromMapKey
(fromMapKey string, input reflect.Value)
compose/field_mapping.go:428
↓ 1 callersMethodcheckIfNeedDeleteAllTasks
checkIfNeedDeleteAllTasks checks if all tasks are completed, if so, it deletes all tasks
adk/middlewares/plantask/task_update.go:390
↓ 1 callersMethodcleanup
(ctx context.Context)
adk/turn_loop.go:1998
↓ 1 callersFunctioncollectByInvoke
(i Invoke[I, O, TOption])
compose/runnable.go:277
↓ 1 callersFunctioncollectByStream
(s Stream[I, O, TOption])
compose/runnable.go:288
↓ 1 callersFunctioncollectByTransform
(t Transform[I, O, TOption])
compose/runnable.go:266
↓ 1 callersMethodcollectCanceledInfo
(canceled bool, canceledTasks, completedTasks []*task)
compose/graph_run.go:441
↓ 1 callersMethodcollectImports
collectImports scans content for @path/to/file references and loads each imported file (plus its transitive imports). The original content is NOT modi
adk/middlewares/agentsmd/loader.go:197
↓ 1 callersFunctioncollectToolMiddlewaresFromMiddlewares
(mws []AgentMiddleware)
adk/chatmodel.go:553
↓ 1 callersFunctioncollectWithCallbacks
(c Collect[I, O, TOption])
compose/utils.go:144
↓ 1 callersMethodcommit
()
adk/turn_loop.go:468
↓ 1 callersMethodcommitStop
()
adk/turn_loop.go:1547
↓ 1 callersMethodcompileIfNeeded
(ctx context.Context)
compose/graph_node.go:121
↓ 1 callersMethodcompilePattern
(req *GrepRequest)
adk/filesystem/backend_inmemory.go:329
↓ 1 callersFunctioncomposablePassthrough
composablePassthrough special runnable that passthrough input to output
compose/runnable.go:521
↓ 1 callersFunctioncompositeInterruptFromLast
(ctx context.Context, ms *bridgeStore, lastEvent *AgentEvent)
adk/agent_tool_test.go:878
↓ 1 callersFunctionconcatAgenticResponseMeta
(metas []*AgenticResponseMeta)
schema/agentic_message.go:1006
← previousnext →1,301–1,400 of 3,994, ranked by callers