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
↓ 1 callers
Function
StreamableLambdaWithOption
StreamableLambdaWithOption creates a Lambda with streamable lambda function and options.
compose/types_lambda.go:114
↓ 1 callers
Method
String
String returns the string representation of the FieldMapping.
compose/field_mapping.go:40
↓ 1 callers
Method
SubIndexes
SubIndexes returns the sub indexes of the document. can use doc.WithSubIndexes() to set the sub indexes.
schema/document.go:70
↓ 1 callers
Function
ToList
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 callers
Method
Transform
Transform works like `stream input => stream output`.
compose/runnable.go:186
↓ 1 callers
Function
TransformableLambdaWithOption
TransformableLambdaWithOption creates a Lambda with transformable lambda function and options.
compose/types_lambda.go:146
↓ 1 callers
Function
TypedCompositeInterrupt
TypedCompositeInterrupt creates a typed interrupt event that aggregates sub-interrupt signals. It is the generic counterpart of CompositeInterrupt; se
adk/interrupt.go:129
↓ 1 callers
Method
Unwrap
()
compose/interrupt.go:71
↓ 1 callers
Method
Unwrap
()
compose/error.go:109
↓ 1 callers
Function
WithAgenticToolChoice
WithAgenticToolChoice is the option to set tool choice for the agentic model. Only available for AgenticModel.
components/model/option.go:168
↓ 1 callers
Function
WithDSLInfo
WithDSLInfo wraps the dsl info option.
components/retriever/option.go:85
↓ 1 callers
Method
WithDSLInfo
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 callers
Method
WithDenseVector
WithDenseVector sets the dense vector of the document. can use doc.DenseVector() to get the dense vector.
schema/document.go:170
↓ 1 callers
Function
WithDisallowTransferToParent
WithDisallowTransferToParent prevents a sub-agent from transferring to its parent. NOT RECOMMENDED: Agent transfer with full context sharing between
adk/flow.go:86
↓ 1 callers
Function
WithEmbedding
WithEmbedding is the option to set the embedder for the indexer, which convert document to embeddings.
components/indexer/option.go:50
↓ 1 callers
Function
WithEmbedding
WithEmbedding wraps the embedder option.
components/retriever/option.go:76
↓ 1 callers
Function
WithEmbeddingOption
WithEmbeddingOption is a functional option type for embedding component. e.g. embeddingOption := compose.WithEmbeddingOption(embedding.WithModel("te
compose/graph_call_options.go:157
↓ 1 callers
Method
WithExtraInfo
WithExtraInfo sets the extra info of the document. can use doc.ExtraInfo() to get the extra info.
schema/document.go:114
↓ 1 callers
Function
WithForceNewRun
WithForceNewRun forces the graph to run from the beginning, ignoring any checkpoints.
compose/checkpoint.go:91
↓ 1 callers
Function
WithIndex
WithIndex wraps the index option.
components/indexer/option.go:32
↓ 1 callers
Function
WithIndex
WithIndex wraps the index option.
components/retriever/option.go:40
↓ 1 callers
Function
WithLoaderOption
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 callers
Function
WithMaxTokens
WithMaxTokens is the option to set the max tokens for the model.
components/model/option.go:80
↓ 1 callers
Function
WithModel
WithModel is the option to set the model for the embedding.
components/embedding/option.go:33
↓ 1 callers
Function
WithName
(n string)
components/prompt/option_test.go:36
↓ 1 callers
Function
WithName
(n string)
components/model/option_test.go:121
↓ 1 callers
Function
WithParserOptions
WithParserOptions attaches parser options to a loader request.
components/document/option.go:102
↓ 1 callers
Function
WithRetrieverOption
WithRetrieverOption is a functional option type for retriever component. e.g. retrieverOption := compose.WithRetrieverOption(retriever.WithIndex("my
compose/graph_call_options.go:166
↓ 1 callers
Method
WithScore
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 callers
Function
WithScoreThreshold
WithScoreThreshold wraps the score threshold option.
components/retriever/option.go:67
↓ 1 callers
Function
WithStop
WithStop is the option to set the stop words for the model.
components/model/option.go:107
↓ 1 callers
Function
WithSubIndex
WithSubIndex wraps the sub index option.
components/retriever/option.go:49
↓ 1 callers
Function
WithSubIndexes
WithSubIndexes is the option to set the sub indexes for the indexer.
components/indexer/option.go:41
↓ 1 callers
Method
WithSubIndexes
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 callers
Function
WithToolOptions
WithToolOptions sets options for tools used by the chat model agent.
adk/chatmodel.go:104
↓ 1 callers
Function
WithTopK
WithTopK wraps the top k option.
components/retriever/option.go:58
↓ 1 callers
Function
WithUserID
(uid int64)
components/prompt/option_test.go:30
↓ 1 callers
Function
WithUserID
(uid int64)
components/model/option_test.go:115
↓ 1 callers
Function
WithUserInfoOption
(s string)
components/tool/utils/invokable_func_test.go:205
↓ 1 callers
Function
WrapImplSpecificOptFn
WrapImplSpecificOptFn returns an agent option that specifies a function to modify the implementation-specific options.
flow/agent/agent_option.go:48
↓ 1 callers
Function
WrapToolWithErrorHandler
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 callers
Function
addAfterSpecialistsBranch
(g *compose.Graph[[]*schema.Message, *schema.Message])
flow/agent/multiagent/host/compose.go:263
↓ 1 callers
Method
addBlockedByToTask
(ctx context.Context, targetTaskID, blockerTaskID string)
adk/middlewares/plantask/task_update.go:335
↓ 1 callers
Method
addBlocksToTask
(ctx context.Context, targetTaskID, blockedTaskID string)
adk/middlewares/plantask/task_update.go:362
↓ 1 callers
Function
addDirectAnswerBranch
(convertorName string, g *compose.Graph[[]*schema.Message, *schema.Message], toolCallChecker func(ctx context
flow/agent/multiagent/host/compose.go:205
↓ 1 callers
Function
addHostAgent
(model model.BaseChatModel, prompt string, g *compose.Graph[[]*schema.Message, *schema.Message], hostNodeName
flow/agent/multiagent/host/compose.go:187
↓ 1 callers
Function
addMultiIntentsSummarizeNode
(summarizer *Summarizer, g *compose.Graph[[]*schema.Message, *schema.Message])
flow/agent/multiagent/host/compose.go:286
↓ 1 callers
Function
addMultiSpecialistsBranch
(convertorName string, agentMap map[string]bool, g *compose.Graph[[]*schema.Message, *schema.Message])
flow/agent/multiagent/host/compose.go:222
↓ 1 callers
Function
addSingleIntentAnswerNode
(g *compose.Graph[[]*schema.Message, *schema.Message])
flow/agent/multiagent/host/compose.go:246
↓ 1 callers
Function
addSpecialistAgent
(specialist *Specialist, g *compose.Graph[[]*schema.Message, *schema.Message])
flow/agent/multiagent/host/compose.go:154
↓ 1 callers
Function
addTypedEvent
(session *runSession, event *TypedAgentEvent[M])
adk/runctx.go:295
↓ 1 callers
Method
addValue
(key string, value any)
adk/runctx.go:324
↓ 1 callers
Method
addValues
(kvs map[string]any)
adk/runctx.go:330
↓ 1 callers
Function
agentOutputSessionKVs
(_ context.Context, agent adk.Agent)
adk/prebuilt/planexecute/utils_test.go:56
↓ 1 callers
Function
appendIfNotExist
(s []string, elem string)
compose/graph_manager.go:248
↓ 1 callers
Function
appendModelToChain
(chain *compose.Chain[I, O], m model.BaseModel[M])
adk/chatmodel.go:966
↓ 1 callers
Method
applyAliasConfigs
(aliasConfigs map[string]ToolAliasConfig)
compose/tool_node.go:382
↓ 1 callers
Method
applyArgsAliases
applyArgsAliases validates argument aliases against the tool schema and builds a reverse alias map for a single tool.
compose/tool_node.go:435
↓ 1 callers
Method
applyBeforeAgent
(ctx context.Context, ec *execContext)
adk/chatmodel.go:793
↓ 1 callers
Method
applyClearRewriteGeneric
(ctx context.Context, state *adk.TypedChatModelAgentState[M], start, end int, clearAtLeastTokens int64)
adk/middlewares/reduction/reduction.go:785
↓ 1 callers
Method
applyNameAliases
applyNameAliases validates and registers name aliases for a single tool into the indexes map.
compose/tool_node.go:414
↓ 1 callers
Function
assertMsgContent
(t *testing.T, msg M, expectedContent string)
adk/middlewares/patchtoolcalls/patchtoolcalls_test.go:104
↓ 1 callers
Function
assertToolResultID
(t *testing.T, msg M, expectedID string)
adk/middlewares/patchtoolcalls/patchtoolcalls_test.go:124
↓ 1 callers
Function
assertToolResultName
(t *testing.T, msg M, expectedName string)
adk/middlewares/patchtoolcalls/patchtoolcalls_test.go:140
↓ 1 callers
Function
assignOne
(destValue reflect.Value, taken any, to string)
compose/field_mapping.go:250
↓ 1 callers
Method
beforeChildGraphCompile
(nodeKey string, key2SubGraphs map[string]*GraphInfo)
compose/graph.go:936
↓ 1 callers
Method
beforeChildGraphsCompile
(opt *graphCompileOptions)
compose/graph.go:928
↓ 1 callers
Method
beforeModelRewriteStateGeneric
(ctx context.Context, state *adk.TypedChatModelAgentState[M], _ *adk.TypedModelContext[M])
adk/middlewares/reduction/reduction.go:623
↓ 1 callers
Method
buildAgenticReActRunFunc
(_ context.Context, bc *execContext)
adk/chatmodel.go:1236
↓ 1 callers
Method
buildContentResult
(b *InMemoryBackend, req *GrepRequest)
adk/filesystem/backend_inmemory.go:768
↓ 1 callers
Function
buildDefaultHistoryRewriter
(agentName string)
adk/flow.go:330
↓ 1 callers
Function
buildGenReplannerInputFn
(planToolName, respondToolName string)
adk/prebuilt/planexecute/plan_execute.go:784
↓ 1 callers
Function
buildInternalFinalizer
(cfg *TypedConfig[M])
adk/middlewares/summarization/summarization.go:634
↓ 1 callers
Method
buildMessageReActRunFunc
(_ context.Context, bc *execContext)
adk/chatmodel.go:1097
↓ 1 callers
Function
buildModelWrappersImpl
(m model.BaseModel[M], config *typedModelWrapperConfig[M])
adk/wrappers.go:56
↓ 1 callers
Method
buildResults
(b *InMemoryBackend, req *GrepRequest)
adk/filesystem/backend_inmemory.go:764
↓ 1 callers
Function
buildReturnDirectly
(graph *compose.Graph[[]*schema.Message, *schema.Message])
flow/agent/react/react.go:399
↓ 1 callers
Method
buildRunFunc
(ctx context.Context)
adk/chatmodel.go:1366
↓ 1 callers
Method
buildStreamConvertOptions
buildStreamConvertOptions constructs ConvertOption hooks that gate stream termination behind the retry verdict signal protocol. Verdict signal lifecy
adk/wrappers.go:366
↓ 1 callers
Method
calculateBranch
(ctx context.Context, curNodeKey string, startChan *chanCall, input []any, isStream bool, cm *channelManager)
compose/graph_run.go:866
↓ 1 callers
Function
canMergeOutputParts
(current, next MessageOutputPart)
schema/message.go:1408
↓ 1 callers
Function
canReach
(taskMap map[string]*task, fromID, toID string, visited map[string]bool)
adk/middlewares/plantask/task.go:102
↓ 1 callers
Function
checkAndExtractFromField
(fromField string, input reflect.Value)
compose/field_mapping.go:398
↓ 1 callers
Function
checkAndExtractFromMapKey
(fromMapKey string, input reflect.Value)
compose/field_mapping.go:428
↓ 1 callers
Method
checkIfNeedDeleteAllTasks
checkIfNeedDeleteAllTasks checks if all tasks are completed, if so, it deletes all tasks
adk/middlewares/plantask/task_update.go:390
↓ 1 callers
Method
cleanup
(ctx context.Context)
adk/turn_loop.go:1998
↓ 1 callers
Function
collectByInvoke
(i Invoke[I, O, TOption])
compose/runnable.go:277
↓ 1 callers
Function
collectByStream
(s Stream[I, O, TOption])
compose/runnable.go:288
↓ 1 callers
Function
collectByTransform
(t Transform[I, O, TOption])
compose/runnable.go:266
↓ 1 callers
Method
collectCanceledInfo
(canceled bool, canceledTasks, completedTasks []*task)
compose/graph_run.go:441
↓ 1 callers
Method
collectImports
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 callers
Function
collectToolMiddlewaresFromMiddlewares
(mws []AgentMiddleware)
adk/chatmodel.go:553
↓ 1 callers
Function
collectWithCallbacks
(c Collect[I, O, TOption])
compose/utils.go:144
↓ 1 callers
Method
commit
()
adk/turn_loop.go:468
↓ 1 callers
Method
commitStop
()
adk/turn_loop.go:1547
↓ 1 callers
Method
compileIfNeeded
(ctx context.Context)
compose/graph_node.go:121
↓ 1 callers
Method
compilePattern
(req *GrepRequest)
adk/filesystem/backend_inmemory.go:329
↓ 1 callers
Function
composablePassthrough
composablePassthrough special runnable that passthrough input to output
compose/runnable.go:521
↓ 1 callers
Function
compositeInterruptFromLast
(ctx context.Context, ms *bridgeStore, lastEvent *AgentEvent)
adk/agent_tool_test.go:878
↓ 1 callers
Function
concatAgenticResponseMeta
(metas []*AgenticResponseMeta)
schema/agentic_message.go:1006
← previous
next →
1,301–1,400 of 3,994, ranked by callers