MCPcopy Create free account

hub / github.com/cloudwego/eino / functions

Functions3,994 in github.com/cloudwego/eino

↓ 4 callersFunctionnewExecuteTool
(sb filesystem.Shell, name string, desc string)
adk/middlewares/filesystem/filesystem.go:1003
↓ 4 callersFunctionnewGenericHelper
()
compose/generic_helper.go:28
↓ 4 callersFunctionnewGraphBranch
(r *runnablePacker[T, []string, any], endNodes map[string]bool)
compose/branch.go:57
↓ 4 callersFunctionnewGraphCompileOptions
(opts ...GraphCompileOption)
compose/graph_compile_options.go:38
↓ 4 callersFunctionnewMockAgentForTool
(name, description string, responses []*AgentEvent)
adk/agent_tool_test.go:88
↓ 4 callersFunctionnewMockAgentWithInputCapture
(name, description string, responses []*AgentEvent)
adk/agent_tool_test.go:370
↓ 4 callersFunctionnewMockRunnerAgent
(name, description string, responses []*AgentEvent)
adk/runner_test.go:72
↓ 4 callersFunctionnewPreemptTestLoop
(t *testing.T, agent *turnLoopCancellableMockAgent)
adk/turn_loop_test.go:211
↓ 4 callersFunctionnewResumeBridgeStore
(checkPointID string, data []byte)
adk/interrupt.go:319
↓ 4 callersFunctionnewTaskCreateTool
(backend Backend, baseDir string, lock *sync.Mutex)
adk/middlewares/plantask/task_create.go:32
↓ 4 callersFunctionnewTaskGetTool
(backend Backend, baseDir string, lock *sync.Mutex)
adk/middlewares/plantask/task_get.go:33
↓ 4 callersFunctionnewTestModelWrapperFn
(beforeFn, afterFn func())
adk/handler_test.go:1073
↓ 4 callersFunctiononGraphStart
(ctx context.Context, input any, isStream bool)
compose/utils.go:122
↓ 4 callersMethodpopToolMsgID
(toolName, callID string)
adk/react.go:163
↓ 4 callersFunctionpostProcessSummary
(ctx context.Context, p *postProcessSummaryParams[M])
adk/middlewares/summarization/summarization.go:689
↓ 4 callersFunctionprintTask
(ts []*task)
compose/graph_run.go:1042
↓ 4 callersFunctionptrStr
ptrStr safely dereferences a *string, returning "" if nil.
adk/middlewares/reduction/reduction.go:1672
↓ 4 callersMethodrequirePhaseLocked
(expected preemptTurnPhase, op string)
adk/turn_loop.go:271
↓ 4 callersMethodsetDelay
(d time.Duration)
adk/cancel_test.go:49
↓ 4 callersFunctionsetMsgClearedFlag
(msg *schema.Message)
adk/middlewares/reduction/reduction.go:1520
↓ 4 callersFunctionsetToolResultContent
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 callersFunctionsplitSystemAndContextMsgs
(msgs []M)
adk/middlewares/summarization/summarization.go:506
↓ 4 callersFunctionstrPtr
strPtr returns a pointer to s, or nil if s is empty.
adk/middlewares/reduction/reduction.go:1664
↓ 4 callersFunctionstreamToolMessageToAgenticMessage
(input *schema.StreamReader[[]*schema.Message])
compose/agentic_tools_node.go:114
↓ 4 callersFunctiontoAgenticChatTemplateNode
(node prompt.AgenticChatTemplate, opts ...GraphAddNodeOpt)
compose/component_to_graph_node.go:126
↓ 4 callersFunctiontoAgenticModelNode
(node model.AgenticModel, opts ...GraphAddNodeOpt)
compose/component_to_graph_node.go:104
↓ 4 callersFunctiontoAgenticToolsNode
(node *AgenticToolsNode, opts ...GraphAddNodeOpt)
compose/component_to_graph_node.go:158
↓ 4 callersFunctiontoAnyGraphNode
(node AnyGraph, opts ...GraphAddNodeOpt)
compose/component_to_graph_node.go:177
↓ 4 callersFunctiontoChatModelNode
(node model.BaseChatModel, opts ...GraphAddNodeOpt)
compose/component_to_graph_node.go:93
↓ 4 callersFunctiontoChatTemplateNode
(node prompt.ChatTemplate, opts ...GraphAddNodeOpt)
compose/component_to_graph_node.go:115
↓ 4 callersFunctiontoDocumentTransformerNode
(node document.Transformer, opts ...GraphAddNodeOpt)
compose/component_to_graph_node.go:136
↓ 4 callersFunctiontoEmbeddingNode
(node embedding.Embedder, opts ...GraphAddNodeOpt)
compose/component_to_graph_node.go:49
↓ 4 callersFunctiontoIndexerNode
(node indexer.Indexer, opts ...GraphAddNodeOpt)
compose/component_to_graph_node.go:82
↓ 4 callersFunctiontoLambdaNode
(node *Lambda, opts ...GraphAddNodeOpt)
compose/component_to_graph_node.go:169
↓ 4 callersFunctiontoLoaderNode
(node document.Loader, opts ...GraphAddNodeOpt)
compose/component_to_graph_node.go:71
↓ 4 callersFunctiontoNode
(nodeInfo *nodeInfo, executor *composableRunnable, graph AnyGraph, meta *executorMeta, instance any, opts ...
compose/component_to_graph_node.go:193
↓ 4 callersFunctiontoPassthroughNode
(opts ...GraphAddNodeOpt)
compose/component_to_graph_node.go:186
↓ 4 callersFunctiontoRetrieverNode
(node retriever.Retriever, opts ...GraphAddNodeOpt)
compose/component_to_graph_node.go:60
↓ 4 callersFunctiontoToolsNode
(node *ToolsNode, opts ...GraphAddNodeOpt)
compose/component_to_graph_node.go:147
↓ 4 callersFunctiontoolResultFromMessage
(msg *schema.Message)
adk/middlewares/reduction/reduction.go:1527
↓ 4 callersMethodtransform
(ctx context.Context, input streamReader, opts ...Option)
compose/graph_run.go:90
↓ 4 callersFunctiontypedRunnerHandleIterImpl
(enableStreaming bool, store CheckPointStore, ctx context.Context, aIter *AsyncIterator[*TypedAgentEvent[M]],
adk/runner.go:271
↓ 4 callersMethodwaitForPushes
()
adk/turn_loop.go:307
↓ 4 callersFunctionwithFailoverHasMoreAttempts
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 callersFunctionwithValue
(value string)
adk/interrupt_test.go:1290
↓ 3 callersFunctionAgenticMessagesPlaceholder
AgenticMessagesPlaceholder can render a placeholder to a list of agentic messages in params. e.g. placeholder := AgenticMessagesPlaceholder("history
schema/agentic_message.go:705
↓ 3 callersMethodAgenticPrompt
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 callersMethodAgenticToolsNode
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 callersFunctionAnyLambda
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 callersMethodAppendPassthrough
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 callersFunctionBatchResumeWithData
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 callersFunctionConcatResponseMetaExtensions
ConcatResponseMetaExtensions concatenates multiple ResponseMetaExtension chunks into a single one.
schema/gemini/extension.go:92
↓ 3 callersFunctionConcatResponseMetaExtensions
ConcatResponseMetaExtensions concatenates multiple ResponseMetaExtension chunks into a single one.
schema/openai/extension.go:242
↓ 3 callersFunctionConvAgenticCallbackInput
ConvAgenticCallbackInput converts the callback input to the agentic prompt callback input.
components/prompt/agentic_callback_extra.go:45
↓ 3 callersMethodDelete
Delete removes a file from storage.
adk/middlewares/plantask/task.go:72
↓ 3 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
internal/mock/components/document/document_mock.go:51
↓ 3 callersMethodError
()
adk/chatmodel_retry_test.go:766
↓ 3 callersMethodError
()
internal/core/interrupt.go:51
↓ 3 callersFunctionFromAgenticMessages
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 callersMethodGenerate
Generate runs the multi-agent synchronously and returns the final message.
flow/agent/multiagent/host/types.go:42
↓ 3 callersMethodHostNodeKey
HostNodeKey returns the graph node key used for the host agent.
flow/agent/multiagent/host/types.go:71
↓ 3 callersFunctionInferStreamTool
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 callersFunctionIsCallbacksEnabled
IsCallbacksEnabled reports whether a component implements Checker and enables callbacks.
components/types.go:55
↓ 3 callersMethodLsInfo
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 callersFunctionMap
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 callersFunctionMergeStreamReaders
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 callersMethodName
(_ context.Context)
adk/workflow.go:49
↓ 3 callersFunctionNew
New creates a summarization middleware that automatically summarizes conversation history when trigger conditions are met.
adk/middlewares/summarization/summarization.go:272
↓ 3 callersFunctionNewBreakLoopAction
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 callersFunctionNewExtParser
NewExtParser creates a new ExtParser.
components/document/parser/ext_parser.go:62
↓ 3 callersFunctionNewInterruptAndRerunErr
NewInterruptAndRerunErr creates a legacy interrupt-and-rerun error. Deprecated: prefer Interrupt(ctx, info) or StatefulInterrupt(ctx, info, state). If
compose/interrupt.go:52
↓ 3 callersFunctionNewMockEmbedder
NewMockEmbedder creates a new mock instance.
internal/mock/components/embedding/Embedding_mock.go:48
↓ 3 callersFunctionNewMockRetriever
NewMockRetriever creates a new mock instance.
internal/mock/components/retriever/retriever_mock.go:49
↓ 3 callersFunctionNewParamsOneOfByJSONSchema
NewParamsOneOfByJSONSchema creates a ParamsOneOf with *jsonschema.Schema.
schema/tool.go:297
↓ 3 callersMethodOnEndWithStreamOutputFn
OnEndWithStreamOutputFn sets the callback invoked when a component produces streaming output. Like OnStartWithStreamInputFn, the handler receives a pr
callbacks/handler_builder.go:153
↓ 3 callersMethodPreserveSkills
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 callersMethodRejectReason
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 callersFunctionResume
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 callersFunctionSendEvent
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 callersMethodString
()
adk/prebuilt/supervisor/supervisor_test.go:186
↓ 3 callersMethodString
()
schema/agentic_message.go:338
↓ 3 callersMethodString
String returns the string representation of AgenticMessage.
schema/agentic_message.go:1931
↓ 3 callersMethodTool
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 callersFunctionTypedStatefulInterrupt
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 callersMethodWakeup
()
adk/turn_buffer.go:121
↓ 3 callersFunctionWithGraceful
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 callersFunctionWithModel
WithModel is the option to set the model name.
components/model/option.go:89
↓ 3 callersFunctionWithRuntimeMaxSteps
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 callersFunctionWithSerializer
WithSerializer sets the serializer used to persist checkpoint state.
compose/checkpoint.go:67
↓ 3 callersFunctionWithSessionValues
WithSessionValues sets session-scoped values for the agent run.
adk/call_option.go:52
↓ 3 callersFunctionWithToolChoice
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 callersFunctionWithTools
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 callersMethodWrapEnhancedStreamableToolCall
(next compose.EnhancedStreamableToolEndpoint)
adk/cancel.go:960
↓ 3 callersMethodaddDependencyRelation
(fromNodeKey string, inputs []*FieldMapping, options *workflowAddInputOpts)
compose/workflow.go:316
↓ 3 callersFunctionagenticMessageToToolCallMessage
(input *schema.AgenticMessage)
compose/agentic_tools_node.go:61
↓ 3 callersMethodapplyAfterAgent
(ctx context.Context)
adk/chatmodel.go:832
↓ 3 callersFunctionapplyDecisionForRetry
(currentInput *[]M, currentOpts *[]model.Option, ctx context.Context, decision *TypedRetryDecision[M])
adk/retry_chatmodel.go:659
↓ 3 callersMethodbuildParamsOneOf
(ctx context.Context)
adk/middlewares/skill/skill.go:461
↓ 3 callersMethodcalculateNextTasks
(ctx context.Context, completedTasks []*task, isStream bool, cm *channelManager, optMap map[string][]any)
compose/graph_run.go:710
↓ 3 callersFunctioncancelAtTransition
(ctx context.Context, info string, state any)
adk/workflow.go:599
← previousnext →701–800 of 3,994, ranked by callers