MCPcopy Create free account

hub / github.com/cloudwego/eino / functions

Functions3,994 in github.com/cloudwego/eino

⨍ Functions 3,994◇ Types & classes 1,204
FunctionconcatUserInputTexts
(texts []*UserInputText)
schema/agentic_message.go:1344
FunctionconcatUserInputVideos
(videos []*UserInputVideo)
schema/agentic_message.go:1374
FunctionconvertOption
(opts ...any)
compose/graph_call_options.go:251
MethodconvertValues
(fn func(map[string]any) error)
compose/pregel.go:44
MethodconvertValues
(fn func(map[string]any) error)
compose/dag.go:193
Methodcopy
(n int)
schema/stream.go:482
Methodcopy
(n int)
compose/stream_reader.go:45
MethodcopyAny
(n int)
schema/stream.go:316
MethodcopyAny
(int)
schema/stream.go:367
FunctioncopyStreamReaders
copyStreamReaders creates multiple independent StreamReaders from a single StreamReader. Each child StreamReader can read from the original stream ind
schema/stream.go:792
FunctiondagChannelBuilder
(controlDependencies []string, dataDependencies []string, zeroValue func() any, emptyStream func() streamReade
compose/dag.go:23
FunctiondefaultGenExecutorInputFn
(ctx context.Context, in *ExecutionContext)
adk/prebuilt/planexecute/plan_execute.go:566
FunctiondefaultGenModelInput
(ctx context.Context, instruction string, input *AgentInput)
adk/chatmodel.go:167
FunctiondefaultGenPlannerInputFn
(ctx context.Context, userInput []adk.Message)
adk/prebuilt/planexecute/plan_execute.go:291
FunctiondefaultIsRetryAble
(_ context.Context, err error)
adk/retry_chatmodel.go:258
FunctiondefaultStreamConverter
(reader streamReader)
compose/generic_helper.go:225
FunctiondefaultStreamMapFilter
(key string, isr streamReader)
compose/generic_helper.go:198
FunctiondefaultTokenCounter
defaultTokenCounter estimates token count using character count / 4 This is a simple heuristic that works reasonably well for most languages
adk/middlewares/reduction/internal/clear_tool_result.go:97
FunctiondefaultTurnLoopOnAgentEvents
(_ context.Context, _ *TurnContext[T, M], events *AsyncIterator[*TypedAgentEvent[M]])
adk/turn_loop.go:1293
FunctiondefaultTypedBackoffFunc
(_ context.Context, attempt int, _ M, _ error)
adk/middlewares/summarization/summarization.go:1244
FunctiondefaultTypedShouldRetry
(_ context.Context, _ M, err error)
adk/middlewares/summarization/summarization.go:1240
FunctiondefaultValueChecker
(v any)
compose/generic_helper.go:236
FunctionemptyStreamFromGeneric
()
compose/generic_helper.go:250
MethodendActiveTurn
()
adk/turn_loop.go:257
FunctionerrorIterator
(err error)
adk/runner.go:31
FunctionfakeEnhancedStreamFunc
(ctx context.Context, input EnhancedStreamInput)
components/tool/utils/streamable_func_test.go:248
FunctionfakeOptionableEnhancedStreamFunc
(ctx context.Context, input EnhancedStreamInput, opts ...tool.Option)
components/tool/utils/streamable_func_test.go:258
FunctionfakeStreamFunc
(ctx context.Context, input FakeStreamInferToolInput, opts ...tool.Option)
components/tool/utils/streamable_func_test.go:135
FunctionfirstChunkStreamToolCallChecker
(_ context.Context, sr *schema.StreamReader[*schema.Message])
flow/agent/react/react.go:218
FunctionfirstChunkStreamToolCallChecker
(_ context.Context, sr *schema.StreamReader[*schema.Message])
flow/agent/multiagent/host/types.go:182
FunctiongenInputConsumeAll
(_ context.Context, _ *TurnLoop[string, *schema.Message], items []string)
adk/turn_loop_test.go:169
FunctiongenInputConsumeAllWithMsg
(_ context.Context, _ *TurnLoop[string, *schema.Message], items []string)
adk/turn_loop_test.go:173
FunctiongenInputConsumeFirst
(_ context.Context, _ *TurnLoop[string, *schema.Message], items []string)
adk/turn_loop_test.go:180
FunctiongenOpenAI
()
internal/generic/type_name_test.go:80
FunctiongenericOnEndWithStreamOutputHandle
(ctx context.Context, output streamReader, runInfo *icb.RunInfo, handlers []icb.Handler)
compose/utils.go:75
FunctiongenericOnStartWithStreamInputHandle
(ctx context.Context, input streamReader, runInfo *icb.RunInfo, handlers []icb.Handler)
compose/utils.go:46
Methodget
(isStream bool, name string, edgeHandler *edgeHandlerManager)
compose/pregel.go:55
Methodget
(isStream bool, name string, edgeHandler *edgeHandlerManager)
compose/dag.go:128
Methodget
(ctx context.Context, id string)
compose/checkpoint.go:192
MethodgetChunkType
()
compose/stream_reader.go:60
FunctiongetEmitGeneratorAndEnableStreaming
(opts []tool.Option)
adk/agent_tool.go:342
MethodgetGenericHelper
()
compose/workflow.go:531
MethodgetGenericHelper
()
compose/chain.go:123
MethodgetGenericHelper
()
compose/graph.go:1027
MethodgetGenericHelper
()
compose/graph_node.go:72
FunctiongetState
(ctx context.Context)
compose/state.go:175
MethodgetType
()
compose/stream_reader.go:56
FunctiongetTypedChatModelAgentExecCtx
(ctx context.Context)
adk/chatmodel.go:79
FunctiongoStruct2ParamsOneOf
(opts ...Option)
components/tool/utils/invokable_func.go:120
FunctiongoStruct2ToolInfo
(toolName, toolDesc string, opts ...Option)
components/tool/utils/invokable_func.go:108
Methodhandle
(nodeKey string, value any, isStream bool)
compose/graph_manager.go:71
Methodhandle
(nodeKey string, idx int, value any, isStream bool)
compose/graph_manager.go:95
Functioninit
()
flow/agent/react/react.go:61
Functioninit
()
adk/interrupt.go:198
Functioninit
()
adk/workflow.go:117
Functioninit
()
adk/interrupt_test.go:1528
Functioninit
()
adk/retry_chatmodel.go:102
Functioninit
()
adk/interface.go:381
Functioninit
()
adk/deterministic_transfer.go:30
Functioninit
()
adk/cancel.go:33
Functioninit
()
adk/react.go:77
Functioninit
()
adk/chatmodel.go:729
Functioninit
()
adk/prebuilt/integration_test.go:54
Functioninit
()
adk/prebuilt/planexecute/plan_execute.go:37
Functioninit
()
adk/prebuilt/supervisor/supervisor_test.go:196
Functioninit
()
adk/prebuilt/deep/deep.go:35
Functioninit
()
adk/middlewares/summarization/summarization.go:37
Functioninit
()
internal/serialization/serialization.go:30
Functioninit
()
internal/serialization/serialization_test.go:211
Functioninit
()
schema/serialization.go:27
Functioninit
()
schema/message.go:40
Functioninit
()
compose/interrupt.go:268
Functioninit
()
compose/state_test.go:347
Functioninit
()
compose/checkpoint_test.go:115
Functioninit
()
compose/tool_node.go:304
Functioninit
()
compose/checkpoint.go:29
Functioninit
()
compose/resume_test.go:48
MethodinputType
()
compose/workflow.go:535
MethodinputType
inputType returns the input type of the chain. implements AnyGraph.
compose/chain.go:129
MethodinputType
()
compose/graph_node.go:93
Methodinvoke
(endpoint compose.InvokableToolEndpoint)
adk/middlewares/filesystem/large_tool_result.go:71
Methodinvoke
(endpoint compose.InvokableToolEndpoint)
adk/middlewares/reduction/internal/large_tool_result.go:103
MethodisEventSenderToolWrapper
()
adk/wrappers.go:545
MethodisEventSenderToolWrapper
()
adk/wrappers.go:552
Methodload
load reads all agents.md files and returns the formatted content. Each top-level file and its @imported files appear as separate sections.
adk/middlewares/agentsmd/loader.go:108
Methodload
(c channel)
compose/pregel.go:35
Methodload
(c channel)
compose/dag.go:66
FunctionmakeAssistantMsg
(content string)
adk/middlewares/agentsmd/agentsmd_generic_test.go:54
FunctionmakeAssistantMsgG
(content string)
adk/middlewares/reduction/reduction_generic_test.go:62
FunctionmakeAssistantMsgWithToolCalls
(toolCalls []testToolCall)
adk/middlewares/dynamictool/toolsearch/toolsearch_generic_test.go:68
FunctionmakeAssistantMsgWithToolCallsG
(toolCalls []testToolCall)
adk/middlewares/reduction/reduction_generic_test.go:76
FunctionmakeReminderMsg
(content string)
adk/middlewares/dynamictool/toolsearch/toolsearch.go:202
FunctionmakeSystemMsg
(content string)
adk/middlewares/dynamictool/toolsearch/toolsearch_generic_test.go:50
FunctionmakeSystemMsg
(content string)
adk/middlewares/agentsmd/agentsmd_generic_test.go:42
FunctionmakeSystemMsg
(text string)
adk/middlewares/summarization/summarization.go:1180
FunctionmakeSystemMsgG
(content string)
adk/middlewares/reduction/reduction_generic_test.go:51
FunctionmakeToolResultMsg
(content string, callID string, toolName string)
adk/middlewares/dynamictool/toolsearch/toolsearch_generic_test.go:98
FunctionmakeToolResultMsg
(content string, callID string, toolName string)
adk/middlewares/patchtoolcalls/patchtoolcalls_test.go:82
FunctionmakeToolResultMsgG
(content string, callID string, toolName string)
adk/middlewares/reduction/reduction_generic_test.go:106
FunctionmakeUserMsg
--------------------------------------------------------------------------- Generic table-driven tests covering both *schema.Message and *schema.Agent
adk/middlewares/dynamictool/toolsearch/toolsearch_generic_test.go:38
← previousnext →3,801–3,900 of 3,994, ranked by callers