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
↓ 4 callers
Function
newExecuteTool
(sb filesystem.Shell, name string, desc string)
adk/middlewares/filesystem/filesystem.go:1003
↓ 4 callers
Function
newGenericHelper
()
compose/generic_helper.go:28
↓ 4 callers
Function
newGraphBranch
(r *runnablePacker[T, []string, any], endNodes map[string]bool)
compose/branch.go:57
↓ 4 callers
Function
newGraphCompileOptions
(opts ...GraphCompileOption)
compose/graph_compile_options.go:38
↓ 4 callers
Function
newMockAgentForTool
(name, description string, responses []*AgentEvent)
adk/agent_tool_test.go:88
↓ 4 callers
Function
newMockAgentWithInputCapture
(name, description string, responses []*AgentEvent)
adk/agent_tool_test.go:370
↓ 4 callers
Function
newMockRunnerAgent
(name, description string, responses []*AgentEvent)
adk/runner_test.go:72
↓ 4 callers
Function
newPreemptTestLoop
(t *testing.T, agent *turnLoopCancellableMockAgent)
adk/turn_loop_test.go:211
↓ 4 callers
Function
newResumeBridgeStore
(checkPointID string, data []byte)
adk/interrupt.go:319
↓ 4 callers
Function
newTaskCreateTool
(backend Backend, baseDir string, lock *sync.Mutex)
adk/middlewares/plantask/task_create.go:32
↓ 4 callers
Function
newTaskGetTool
(backend Backend, baseDir string, lock *sync.Mutex)
adk/middlewares/plantask/task_get.go:33
↓ 4 callers
Function
newTestModelWrapperFn
(beforeFn, afterFn func())
adk/handler_test.go:1073
↓ 4 callers
Function
onGraphStart
(ctx context.Context, input any, isStream bool)
compose/utils.go:122
↓ 4 callers
Method
popToolMsgID
(toolName, callID string)
adk/react.go:163
↓ 4 callers
Function
postProcessSummary
(ctx context.Context, p *postProcessSummaryParams[M])
adk/middlewares/summarization/summarization.go:689
↓ 4 callers
Function
printTask
(ts []*task)
compose/graph_run.go:1042
↓ 4 callers
Function
ptrStr
ptrStr safely dereferences a *string, returning "" if nil.
adk/middlewares/reduction/reduction.go:1672
↓ 4 callers
Method
requirePhaseLocked
(expected preemptTurnPhase, op string)
adk/turn_loop.go:271
↓ 4 callers
Method
setDelay
(d time.Duration)
adk/cancel_test.go:49
↓ 4 callers
Function
setMsgClearedFlag
(msg *schema.Message)
adk/middlewares/reduction/reduction.go:1520
↓ 4 callers
Function
setToolResultContent
setToolResultContent updates the tool result content in a message. For *schema.Message: sets msg.Content or msg.UserInputMultiContent. For *schema.Age
adk/middlewares/reduction/reduction.go:1080
↓ 4 callers
Function
splitSystemAndContextMsgs
(msgs []M)
adk/middlewares/summarization/summarization.go:506
↓ 4 callers
Function
strPtr
strPtr returns a pointer to s, or nil if s is empty.
adk/middlewares/reduction/reduction.go:1664
↓ 4 callers
Function
streamToolMessageToAgenticMessage
(input *schema.StreamReader[[]*schema.Message])
compose/agentic_tools_node.go:114
↓ 4 callers
Function
toAgenticChatTemplateNode
(node prompt.AgenticChatTemplate, opts ...GraphAddNodeOpt)
compose/component_to_graph_node.go:126
↓ 4 callers
Function
toAgenticModelNode
(node model.AgenticModel, opts ...GraphAddNodeOpt)
compose/component_to_graph_node.go:104
↓ 4 callers
Function
toAgenticToolsNode
(node *AgenticToolsNode, opts ...GraphAddNodeOpt)
compose/component_to_graph_node.go:158
↓ 4 callers
Function
toAnyGraphNode
(node AnyGraph, opts ...GraphAddNodeOpt)
compose/component_to_graph_node.go:177
↓ 4 callers
Function
toChatModelNode
(node model.BaseChatModel, opts ...GraphAddNodeOpt)
compose/component_to_graph_node.go:93
↓ 4 callers
Function
toChatTemplateNode
(node prompt.ChatTemplate, opts ...GraphAddNodeOpt)
compose/component_to_graph_node.go:115
↓ 4 callers
Function
toDocumentTransformerNode
(node document.Transformer, opts ...GraphAddNodeOpt)
compose/component_to_graph_node.go:136
↓ 4 callers
Function
toEmbeddingNode
(node embedding.Embedder, opts ...GraphAddNodeOpt)
compose/component_to_graph_node.go:49
↓ 4 callers
Function
toIndexerNode
(node indexer.Indexer, opts ...GraphAddNodeOpt)
compose/component_to_graph_node.go:82
↓ 4 callers
Function
toLambdaNode
(node *Lambda, opts ...GraphAddNodeOpt)
compose/component_to_graph_node.go:169
↓ 4 callers
Function
toLoaderNode
(node document.Loader, opts ...GraphAddNodeOpt)
compose/component_to_graph_node.go:71
↓ 4 callers
Function
toNode
(nodeInfo *nodeInfo, executor *composableRunnable, graph AnyGraph, meta *executorMeta, instance any, opts ...
compose/component_to_graph_node.go:193
↓ 4 callers
Function
toPassthroughNode
(opts ...GraphAddNodeOpt)
compose/component_to_graph_node.go:186
↓ 4 callers
Function
toRetrieverNode
(node retriever.Retriever, opts ...GraphAddNodeOpt)
compose/component_to_graph_node.go:60
↓ 4 callers
Function
toToolsNode
(node *ToolsNode, opts ...GraphAddNodeOpt)
compose/component_to_graph_node.go:147
↓ 4 callers
Function
toolResultFromMessage
(msg *schema.Message)
adk/middlewares/reduction/reduction.go:1527
↓ 4 callers
Method
transform
(ctx context.Context, input streamReader, opts ...Option)
compose/graph_run.go:90
↓ 4 callers
Function
typedRunnerHandleIterImpl
(enableStreaming bool, store CheckPointStore, ctx context.Context, aIter *AsyncIterator[*TypedAgentEvent[M]],
adk/runner.go:271
↓ 4 callers
Method
waitForPushes
()
adk/turn_loop.go:307
↓ 4 callers
Function
withFailoverHasMoreAttempts
withFailoverHasMoreAttempts sets a flag in context indicating whether additional failover attempts remain after the current one. This is read by build
adk/failover_chatmodel.go:48
↓ 4 callers
Function
withValue
(value string)
adk/interrupt_test.go:1290
↓ 3 callers
Function
AgenticMessagesPlaceholder
AgenticMessagesPlaceholder can render a placeholder to a list of agentic messages in params. e.g. placeholder := AgenticMessagesPlaceholder("history
schema/agentic_message.go:705
↓ 3 callers
Method
AgenticPrompt
AgenticPrompt sets the agentic prompt handler for the handler helper, which will be called when the agentic prompt component is executed.
utils/callbacks/template.go:135
↓ 3 callers
Method
AgenticToolsNode
AgenticToolsNode sets the agentic tools node handler for the handler helper, which will be called when the agentic tools node is executed.
utils/callbacks/template.go:147
↓ 3 callers
Function
AnyLambda
AnyLambda creates a Lambda with any lambda function. you can only implement one or more of the four lambda functions, and the rest use nil. eg. invo
compose/types_lambda.go:174
↓ 3 callers
Method
AppendPassthrough
AppendPassthrough add a Passthrough node to the chain. Could be used to connect multiple ChainBranch or Parallel. e.g. chain.AppendPassthrough()
compose/chain.go:533
↓ 3 callers
Function
BatchResumeWithData
BatchResumeWithData is the core function for preparing a resume context. It injects a map of resume targets and their corresponding data into the cont
compose/resume.go:119
↓ 3 callers
Function
ConcatResponseMetaExtensions
ConcatResponseMetaExtensions concatenates multiple ResponseMetaExtension chunks into a single one.
schema/gemini/extension.go:92
↓ 3 callers
Function
ConcatResponseMetaExtensions
ConcatResponseMetaExtensions concatenates multiple ResponseMetaExtension chunks into a single one.
schema/openai/extension.go:242
↓ 3 callers
Function
ConvAgenticCallbackInput
ConvAgenticCallbackInput converts the callback input to the agentic prompt callback input.
components/prompt/agentic_callback_extra.go:45
↓ 3 callers
Method
Delete
Delete removes a file from storage.
adk/middlewares/plantask/task.go:72
↓ 3 callers
Method
EXPECT
EXPECT returns an object that allows the caller to indicate expected use.
internal/mock/components/document/document_mock.go:51
↓ 3 callers
Method
Error
()
adk/chatmodel_retry_test.go:766
↓ 3 callers
Method
Error
()
internal/core/interrupt.go:51
↓ 3 callers
Function
FromAgenticMessages
FromAgenticMessages creates a new DefaultAgenticChatTemplate from the given templates and format type. eg. template := prompt.FromAgenticMessages(sc
components/prompt/agentic_chat_template.go:34
↓ 3 callers
Method
Generate
Generate runs the multi-agent synchronously and returns the final message.
flow/agent/multiagent/host/types.go:42
↓ 3 callers
Method
HostNodeKey
HostNodeKey returns the graph node key used for the host agent.
flow/agent/multiagent/host/types.go:71
↓ 3 callers
Function
InferStreamTool
InferStreamTool creates a [tool.StreamableTool] by inferring the parameter JSON schema from type T. The function returns a [schema.StreamReader] of D
components/tool/utils/streamable_func.go:39
↓ 3 callers
Function
IsCallbacksEnabled
IsCallbacksEnabled reports whether a component implements Checker and enables callbacks.
components/types.go:55
↓ 3 callers
Method
LsInfo
LsInfo lists file information under the given path. Returns: - []FileInfo: List of matching file information - error: Error if the operation fails
adk/filesystem/backend.go:249
↓ 3 callers
Function
Map
Map applies function f to each key and value of map m. Results of f are returned as a new map. 🚀 EXAMPLE: f := func(k, v int) (string, string) { re
internal/gmap/gmap.go:72
↓ 3 callers
Function
MergeStreamReaders
MergeStreamReaders fans in multiple StreamReaders into a single StreamReader. Elements from all source streams are interleaved in arrival order (non-d
schema/stream.go:912
↓ 3 callers
Method
Name
(_ context.Context)
adk/workflow.go:49
↓ 3 callers
Function
New
New creates a summarization middleware that automatically summarizes conversation history when trigger conditions are met.
adk/middlewares/summarization/summarization.go:272
↓ 3 callers
Function
NewBreakLoopAction
NewBreakLoopAction creates a new BreakLoopAction, signaling a request to terminate the current loop. NOT RECOMMENDED: Workflow agents are built on ag
adk/workflow.go:315
↓ 3 callers
Function
NewExtParser
NewExtParser creates a new ExtParser.
components/document/parser/ext_parser.go:62
↓ 3 callers
Function
NewInterruptAndRerunErr
NewInterruptAndRerunErr creates a legacy interrupt-and-rerun error. Deprecated: prefer Interrupt(ctx, info) or StatefulInterrupt(ctx, info, state). If
compose/interrupt.go:52
↓ 3 callers
Function
NewMockEmbedder
NewMockEmbedder creates a new mock instance.
internal/mock/components/embedding/Embedding_mock.go:48
↓ 3 callers
Function
NewMockRetriever
NewMockRetriever creates a new mock instance.
internal/mock/components/retriever/retriever_mock.go:49
↓ 3 callers
Function
NewParamsOneOfByJSONSchema
NewParamsOneOfByJSONSchema creates a ParamsOneOf with *jsonschema.Schema.
schema/tool.go:297
↓ 3 callers
Method
OnEndWithStreamOutputFn
OnEndWithStreamOutputFn sets the callback invoked when a component produces streaming output. Like OnStartWithStreamInputFn, the handler receives a pr
callbacks/handler_builder.go:153
↓ 3 callers
Method
PreserveSkills
PreserveSkills preserves skill contents loaded by the ADK skill middleware. It scans the conversation for matching skill tool calls and returns the pr
adk/middlewares/summarization/finalizer_builder.go:186
↓ 3 callers
Method
RejectReason
RejectReason returns the user-defined rejection reason set by the ShouldRetry callback via RetryDecision.RejectReason. Returns nil if not set or after
adk/retry_chatmodel.go:98
↓ 3 callers
Function
Resume
Resume prepares a context for an "Explicit Targeted Resume" operation by targeting one or more components without providing data. It is a convenience
compose/resume.go:94
↓ 3 callers
Function
SendEvent
SendEvent sends a custom AgentEvent to the event stream during agent execution. This allows ChatModelAgentMiddleware implementations to emit custom ev
adk/handler.go:425
↓ 3 callers
Method
String
()
adk/prebuilt/supervisor/supervisor_test.go:186
↓ 3 callers
Method
String
()
schema/agentic_message.go:338
↓ 3 callers
Method
String
String returns the string representation of AgenticMessage.
schema/agentic_message.go:1931
↓ 3 callers
Method
Tool
Tool sets the tool handler for the handler helper, which will be called when the tool component is executed.
utils/callbacks/template.go:123
↓ 3 callers
Function
TypedStatefulInterrupt
TypedStatefulInterrupt creates a typed interrupt event that also saves the agent's internal state. It is the generic counterpart of StatefulInterrupt;
adk/interrupt.go:94
↓ 3 callers
Method
Wakeup
()
adk/turn_buffer.go:121
↓ 3 callers
Function
WithGraceful
WithGraceful requests a graceful stop that waits at the nearest safe point (after tool calls or after a chat-model call) and propagates recursively to
adk/turn_loop.go:1097
↓ 3 callers
Function
WithModel
WithModel is the option to set the model name.
components/model/option.go:89
↓ 3 callers
Function
WithRuntimeMaxSteps
WithRuntimeMaxSteps sets the maximum number of steps for the graph runtime. e.g. runnable.Invoke(ctx, "input", compose.WithRuntimeMaxSteps(20))
compose/graph_call_options.go:234
↓ 3 callers
Function
WithSerializer
WithSerializer sets the serializer used to persist checkpoint state.
compose/checkpoint.go:67
↓ 3 callers
Function
WithSessionValues
WithSessionValues sets session-scoped values for the agent run.
adk/call_option.go:52
↓ 3 callers
Function
WithToolChoice
WithToolChoice sets the tool choice for the model. It also allows for providing a list of tool names to constrain the model to a specific subset of th
components/model/option.go:157
↓ 3 callers
Function
WithTools
WithTools is a convenience function that configures a React agent with a list of tools. It performs two essential operations: 1. Extracts tool informa
flow/agent/react/option.go:92
↓ 3 callers
Method
WrapEnhancedStreamableToolCall
(next compose.EnhancedStreamableToolEndpoint)
adk/cancel.go:960
↓ 3 callers
Method
addDependencyRelation
(fromNodeKey string, inputs []*FieldMapping, options *workflowAddInputOpts)
compose/workflow.go:316
↓ 3 callers
Function
agenticMessageToToolCallMessage
(input *schema.AgenticMessage)
compose/agentic_tools_node.go:61
↓ 3 callers
Method
applyAfterAgent
(ctx context.Context)
adk/chatmodel.go:832
↓ 3 callers
Function
applyDecisionForRetry
(currentInput *[]M, currentOpts *[]model.Option, ctx context.Context, decision *TypedRetryDecision[M])
adk/retry_chatmodel.go:659
↓ 3 callers
Method
buildParamsOneOf
(ctx context.Context)
adk/middlewares/skill/skill.go:461
↓ 3 callers
Method
calculateNextTasks
(ctx context.Context, completedTasks []*task, isStream bool, cm *channelManager, optMap map[string][]any)
compose/graph_run.go:710
↓ 3 callers
Function
cancelAtTransition
(ctx context.Context, info string, state any)
adk/workflow.go:599
← previous
next →
701–800 of 3,994, ranked by callers