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
Function
makeUserMsg
--- generic table-driven test helpers ---
adk/middlewares/agentsmd/agentsmd_generic_test.go:30
Function
makeUserMsg
(content string)
adk/middlewares/patchtoolcalls/patchtoolcalls_test.go:46
Function
makeUserMsg
(text string)
adk/middlewares/summarization/summarization.go:1192
Function
makeUserMsgG
(content string)
adk/middlewares/reduction/reduction_generic_test.go:40
Function
makeUserMsgWithExtra
(content string)
adk/middlewares/agentsmd/agentsmd.go:163
Function
mapToList
(m map[string]any)
compose/utils.go:318
Method
merge
(opts []AgentCancelOption, now time.Time)
adk/turn_loop.go:102
Method
merge
(ack chan struct{}, opts []AgentCancelOption, now time.Time)
adk/turn_loop.go:165
Method
merge
(opts []AgentCancelOption, now time.Time)
adk/turn_loop.go:388
Method
merge
(isrs []streamReader)
compose/stream_reader.go:79
Method
mergeWithNames
(isrs []streamReader, names []string)
compose/stream_reader.go:87
Function
newStream
(cap int)
schema/stream.go:389
Function
newTestMiddlewareTyped
(t *testing.T, tools []tool.BaseTool)
adk/middlewares/dynamictool/toolsearch/toolsearch_generic_test.go:181
Function
newTurnBuffer
()
adk/turn_buffer.go:29
Function
newTypedRetryModelWrapper
(inner model.BaseModel[M], config *TypedModelRetryConfig[M])
adk/retry_chatmodel.go:328
Function
newTypedSummaryMessage
(content string)
adk/middlewares/summarization/summarization.go:1204
Function
newTypedUserMessages
(text string)
adk/agent_tool.go:399
Function
newUserMessage
(query string)
adk/runner.go:38
Method
onChatModelEnd
(ctx context.Context, _ *callbacks.RunInfo, input *model.CallbackOutput)
flow/agent/react/option.go:287
Method
onChatModelEndWithStreamOutput
(ctx context.Context, _ *callbacks.RunInfo, input *schema.StreamReader[*model.CallbackOutput])
flow/agent/react/option.go:295
Function
onEndWithStreamOutput
(ctx context.Context, output *schema.StreamReader[T])
compose/utils.go:69
Method
onGraphEnd
(ctx context.Context, _ *callbacks.RunInfo, _ callbacks.CallbackOutput)
flow/agent/react/option.go:324
Method
onGraphEndWithStreamOutput
(ctx context.Context, _ *callbacks.RunInfo, _ *schema.StreamReader[callbacks.CallbackOutput])
flow/agent/react/option.go:338
Method
onGraphError
(ctx context.Context, _ *callbacks.RunInfo, err error)
flow/agent/react/option.go:308
Function
onStartWithStreamInput
(ctx context.Context, input *schema.StreamReader[T])
compose/utils.go:40
Method
outputType
()
compose/workflow.go:539
Method
outputType
outputType returns the output type of the chain. implements AnyGraph.
compose/chain.go:135
Method
outputType
()
compose/graph_node.go:107
Function
pregelChannelBuilder
(_ []string, _ []string, _ func() any, _ func() streamReader)
compose/pregel.go:21
Function
ptrOf
(v T)
schema/agentic_message_test.go:1222
Function
queryUserCompany
(ctx context.Context, req *userCompanyRequest)
compose/tool_node_test.go:330
Function
queryUserSalary
(ctx context.Context, req *userSalaryRequest)
compose/tool_node_test.go:354
Method
recv
()
schema/stream.go:400
Method
recv
()
schema/stream.go:470
Method
recv
()
schema/stream.go:538
Method
recv
()
schema/stream.go:699
Method
recv
()
schema/stream.go:888
Method
recvAny
()
schema/stream.go:312
Method
reportDependencies
(_ []string)
compose/pregel.go:93
Method
reportDependencies
(dependencies []string)
compose/dag.go:93
Method
reportSkip
(_ []string)
compose/pregel.go:90
Method
reportSkip
(keys []string)
compose/dag.go:106
Method
reportValues
(ins map[string]any)
compose/pregel.go:48
Method
reportValues
(ins map[string]any)
compose/dag.go:78
Function
runToolCallTaskByInvoke
(ctx context.Context, task *toolCallTask, opts ...tool.Option)
compose/tool_node.go:892
Function
runToolCallTaskByStream
(ctx context.Context, task *toolCallTask, opts ...tool.Option)
compose/tool_node.go:934
Function
runnableInvoke
(ctx context.Context, r *composableRunnable, input any, opts ...any)
compose/graph_run.go:101
Function
runnableTransform
(ctx context.Context, r *composableRunnable, input any, opts ...any)
compose/graph_run.go:105
Method
setMergeConfig
(cfg FanInMergeConfig)
compose/pregel.go:31
Method
setMergeConfig
(cfg FanInMergeConfig)
compose/dag.go:62
Function
smakeAssistantMsg
(content string)
adk/middlewares/summarization/summarization_test.go:1889
Function
smakeSystemMsg
(content string)
adk/middlewares/summarization/summarization_test.go:1878
Function
smakeUserMsg
============================================================================ Generic message helpers (prefixed with 's' to avoid conflicts) ==========
adk/middlewares/summarization/summarization_test.go:1867
Method
stream
(endpoint compose.StreamableToolEndpoint)
adk/middlewares/reduction/internal/large_tool_result.go:117
Function
testAgentMode
--- Part 2: Agent mode tests ---
adk/middlewares/skill/skill_generic_test.go:156
Function
testAgentsMDGeneric
(t *testing.T)
adk/middlewares/agentsmd/agentsmd_generic_test.go:120
Function
testClearFlowGeneric
--------------------------------------------------------------------------- Part 2: Clear rewrite flow -----------------------------------------------
adk/middlewares/reduction/reduction_generic_test.go:305
Function
testClearPostProcessGeneric
--------------------------------------------------------------------------- Part 4: ClearPostProcess callback ----------------------------------------
adk/middlewares/reduction/reduction_generic_test.go:418
Function
testCopyNilMessage
testCopyNilMessage verifies that copyMessagesGeneric does not panic when the input slice contains nil message elements (regression test).
adk/middlewares/reduction/reduction_generic_test.go:889
Function
testEnsureReminderGeneric
--- Generic test functions ---
adk/middlewares/dynamictool/toolsearch/toolsearch_generic_test.go:207
Function
testHelperFunctions
--------------------------------------------------------------------------- Part 1: Helper function tests --------------------------------------------
adk/middlewares/reduction/reduction_generic_test.go:162
Function
testMalformedJSONGeneric
(t *testing.T)
adk/middlewares/dynamictool/toolsearch/toolsearch_generic_test.go:354
Function
testMode1ForwardSelectionGeneric
(t *testing.T)
adk/middlewares/dynamictool/toolsearch/toolsearch_generic_test.go:308
Function
testMode1InitializationGeneric
(t *testing.T)
adk/middlewares/dynamictool/toolsearch/toolsearch_generic_test.go:275
Function
testPatchToolCallsGeneric
(t *testing.T)
adk/middlewares/patchtoolcalls/patchtoolcalls_test.go:156
Function
testSummarizationFlow
(t *testing.T)
adk/middlewares/summarization/summarization_test.go:2055
Function
testSummarizationHelpers
(t *testing.T)
adk/middlewares/summarization/summarization_test.go:1975
Function
testTokenCounterReceivesStateToolInfos
(t *testing.T)
adk/middlewares/summarization/summarization_test.go:2118
Function
testTruncationGeneric
--------------------------------------------------------------------------- Part 3: Truncation flow --------------------------------------------------
adk/middlewares/reduction/reduction_generic_test.go:373
Function
testWrapModel
--- Part 1: WrapModel test ---
adk/middlewares/skill/skill_generic_test.go:125
Method
toAnyStreamReader
()
compose/stream_reader.go:105
Function
toStream
(r Reader)
schema/stream.go:747
Method
toStream
()
schema/stream.go:338
Method
toStream
()
schema/stream.go:592
Method
toStream
()
schema/stream.go:780
Method
toStream
()
schema/stream.go:892
Function
typedBuildAppendPromptTool
(prompt string, t tool.BaseTool)
adk/prebuilt/deep/types.go:44
Function
typedDefaultTaskToolDescription
(ctx context.Context, subAgents []adk.TypedAgent[M])
adk/prebuilt/deep/task_tool.go:177
Function
typedErrFunc
(err error)
adk/chatmodel.go:765
Function
typedErrorIter
(err error)
adk/utils.go:304
Function
typedErrorIterWithOnEnd
(ctx context.Context, err error)
adk/flow.go:807
Function
typedGetFailoverCurrentModel
(ctx context.Context)
adk/failover_chatmodel.go:38
Function
typedGetFailoverLastSuccessModel
(ctx context.Context)
adk/failover_chatmodel.go:169
Function
typedNewWriteTodos
()
adk/prebuilt/deep/deep.go:244
Function
typedPopToolGenAction
(ctx context.Context, toolName string)
adk/wrappers.go:519
Function
typedToolInvokeEvent
typedToolInvokeEvent constructs the tool result event for the invoke path, dispatching on M to create the correct message and event types.
adk/wrappers.go:720
Function
unmarshalTurnLoopCheckpoint
(data []byte)
adk/turn_loop.go:960
Function
unpackStreamReader
(isr streamReader)
compose/stream_reader.go:115
Function
updateUserInfo
(ctx context.Context, input *User)
components/tool/utils/invokable_func_test.go:194
Function
updateUserInfoWithOption
(_ context.Context, input *User, opts ...tool.Option)
components/tool/utils/invokable_func_test.go:211
Function
useLast
(s []T)
internal/concat.go:49
Method
validate
()
flow/agent/multiagent/host/types.go:104
Method
withKey
(key string)
compose/stream_reader.go:95
Function
zeroValueFromGeneric
()
compose/generic_helper.go:245
← previous
3,901–3,994 of 3,994, ranked by callers