MCPcopy Create free account

hub / github.com/cloudwego/eino / functions

Functions3,994 in github.com/cloudwego/eino

⨍ Functions 3,994◇ Types & classes 1,204
↓ 1 callersMethodprepareExecContext
(ctx context.Context)
adk/chatmodel.go:855
↓ 1 callersMethodprocessFile
(filePath, content string, re *regexp.Regexp, req *GrepRequest)
adk/filesystem/backend_inmemory.go:713
↓ 1 callersMethodpushWithConfig
(item T, cfg *pushConfig[T, M])
adk/turn_loop.go:1457
↓ 1 callersMethodpushWithStrategy
pushWithStrategy snapshots the current target turn while the strategy decides how to enqueue the item. If it requests preempt, that request is bound t
adk/turn_loop.go:1397
↓ 1 callersFunctionreadTestdataBytes
(t *testing.T, filename string)
adk/prebuilt/deep/checkpoint_compat_resume_test.go:78
↓ 1 callersMethodreceive
(recv func() (*task, bool))
compose/graph_manager.go:434
↓ 1 callersFunctionreceiveN
(chosenList []int, ss []*stream[T])
schema/select.go:21
↓ 1 callersFunctionreceiveWithDeadline
(recv func() (*task, bool), deadline time.Time)
compose/graph_manager.go:454
↓ 1 callersFunctionreceiveWithListening
(recv func() (*task, bool), cancel chan *time.Duration)
compose/graph_manager.go:479
↓ 1 callersFunctionrecvAll
(t *testing.T, sr *schema.StreamReader[string])
schema/stream_oneof_test.go:28
↓ 1 callersMethodrecvAny
()
schema/stream.go:366
↓ 1 callersMethodremoveTaskFromDependencies
(ctx context.Context, deletedTaskID string)
adk/middlewares/plantask/task_update.go:286
↓ 1 callersFunctionrenderToolDescription
(matters []FrontMatter)
adk/middlewares/skill/skill.go:698
↓ 1 callersMethodreportBranch
(from string, skippedNodes []string)
compose/graph_manager.go:219
↓ 1 callersMethodreportDependencies
([]string)
compose/graph_manager.go:31
↓ 1 callersMethodreportValues
(map[string]any)
compose/graph_manager.go:30
↓ 1 callersMethodrequireNoPendingLocked
(op string)
adk/turn_loop.go:277
↓ 1 callersFunctionrequirePreemptPhase
(t *testing.T, c *preemptController, phase preemptTurnPhase)
adk/turn_loop_test.go:3000
↓ 1 callersMethodresolveMaxSteps
(maxSteps int, opts []Option)
compose/graph_run.go:362
↓ 1 callersMethodrestoreCheckPoint
convertCheckPoint convert values in checkpoint to streamReader if needed
compose/checkpoint.go:321
↓ 1 callersMethodrestoreInputs
(isStream bool, values map[string]any)
compose/checkpoint.go:354
↓ 1 callersMethodrestoreOutputs
(isStream bool, values map[string]any)
compose/checkpoint.go:362
↓ 1 callersFunctionresumeFlowAgentWithIsolatedSession
(ctx context.Context, fa *flowAgent, info *ResumeInfo, toAgentNames []string, opts ...AgentRunOption)
adk/deterministic_transfer.go:197
↓ 1 callersMethodrun
(ctx context.Context)
adk/turn_loop.go:1570
↓ 1 callersMethodrunAgentAndHandleEvents
( ctx context.Context, agent TypedAgent[M], spec *turnRunSpec[T, M], )
adk/turn_loop.go:1809
↓ 1 callersFunctionrunDeepAgentCheckpointCompat
(t *testing.T, checkpointID string, filename string)
adk/prebuilt/deep/checkpoint_compat_resume_test.go:89
↓ 1 callersMethodrunFailover
(ctx context.Context, originalMsgs, defaultInput []M, lastResp M, lastErr error)
adk/middlewares/summarization/summarization.go:519
↓ 1 callersFunctionrunPostHandler
(ta *task, runWrapper runnableCallWrapper)
compose/graph_manager.go:543
↓ 1 callersFunctionrunPreHandler
(ta *task, runWrapper runnableCallWrapper)
compose/graph_manager.go:527
↓ 1 callersMethodsetActiveModel
(ctx context.Context, modelName string)
adk/middlewares/skill/skill.go:443
↓ 1 callersFunctionsetCheckPointToCtx
(ctx context.Context, cp *checkpoint)
compose/checkpoint.go:146
↓ 1 callersMethodsetMergeConfig
(FanInMergeConfig)
compose/graph_manager.go:37
↓ 1 callersFunctionsetStateModifier
(ctx context.Context, modifier StateModifier)
compose/checkpoint.go:130
↓ 1 callersFunctionsetStructField
(t reflect.Type, s reflect.Value, fieldName string, val any)
internal/serialization/serialization.go:622
↓ 1 callersFunctionsplitToolName
splitToolName splits a tool name into parts by underscores, double underscores (MCP separator), and camelCase boundaries.
adk/middlewares/dynamictool/toolsearch/toolsearch.go:603
↓ 1 callersMethodstart
(ctx context.Context)
adk/turn_loop.go:1335
↓ 1 callersFunctionstreamByCollect
(c Collect[I, O, TOption])
compose/runnable.go:254
↓ 1 callersFunctionstreamByInvoke
(i Invoke[I, O, TOption])
compose/runnable.go:243
↓ 1 callersFunctionstreamByTransform
(t Transform[I, O, TOption])
compose/runnable.go:235
↓ 1 callersFunctionstreamChunkConvertForCBInput
(i I)
compose/utils.go:213
↓ 1 callersFunctionstreamChunkConvertForCBOutput
(o O)
compose/utils.go:209
↓ 1 callersFunctionstreamConvertPostHandler
(handler StreamStatePostHandler[O, S])
compose/state.go:99
↓ 1 callersFunctionstreamConvertPreHandler
(handler StreamStatePreHandler[I, S])
compose/state.go:84
↓ 1 callersFunctionstreamEnhancedWithCallbacks
(s func(ctx context.Context, toolArgument *schema.ToolArgument, opts ...tool.Option) (*schema.StreamReader[*sc
compose/tool_node.go:752
↓ 1 callersFunctionstreamFieldMap
(mappings []*FieldMapping, uncheckedSourcePaths map[string]FieldPath)
compose/field_mapping.go:568
↓ 1 callersMethodstreamLegacy
(ctx context.Context, input []M, opts ...model.Option)
adk/retry_chatmodel.go:687
↓ 1 callersFunctionstreamWithMidErrorAgentic
(chunks []*schema.AgenticMessage, err error)
adk/failover_chatmodel_test.go:723
↓ 1 callersFunctionstreamWithMidErrorControlled
(chunks []*schema.Message, err error, firstSent chan struct{}, release chan struct{})
adk/failover_chatmodel_test.go:78
↓ 1 callersFunctionstreamWithShouldRetry
(r *typedRetryModelWrapper[M], ctx context.Context, input []M, opts ...model.Option)
adk/retry_chatmodel.go:488
↓ 1 callersFunctionstreamableToInvokable
(e StreamableToolEndpoint)
compose/tool_node.go:700
↓ 1 callersFunctionstripLineNumbers
(data string)
adk/middlewares/skill/filesystem_backend.go:152
↓ 1 callersMethodsubmit
(tasks []*task)
compose/graph_manager.go:300
↓ 1 callersMethodsummarize
(ctx context.Context, originalMsgs []M)
adk/middlewares/summarization/summarization.go:484
↓ 1 callersFunctiontakeOne
(inputValue reflect.Value, inputType reflect.Type, from string)
compose/field_mapping.go:574
↓ 1 callersFunctiontestStreamN
(cap, n int)
schema/stream_test.go:392
↓ 1 callersFunctiontestStreamToolMessageTextOnly
(t *testing.T)
compose/agentic_tools_node_test.go:346
↓ 1 callersFunctiontestToolOption
(value string)
adk/chatmodel_test.go:1935
↓ 1 callersMethodtoComposableRunnable
()
compose/graph_run.go:994
↓ 1 callersMethodtoComposableRunnable
()
compose/runnable.go:109
↓ 1 callersMethodtoGraphInfo
(opt *graphCompileOptions, key2SubGraphs map[string]*GraphInfo)
compose/graph.go:948
↓ 1 callersFunctiontoSliceValue
(vs []any)
internal/concat.go:207
↓ 1 callersFunctiontoolSearchResultAgenticMessage
(callID, name string, tr *schema.ToolResult)
adk/wrappers.go:609
↓ 1 callersFunctiontransferTask
(script [][]string, invertedEdges map[string][]string)
compose/graph.go:1035
↓ 1 callersFunctiontransformByCollect
(c Collect[I, O, TOption])
compose/runnable.go:316
↓ 1 callersFunctiontransformByInvoke
(i Invoke[I, O, TOption])
compose/runnable.go:328
↓ 1 callersFunctiontransformByStream
(s Stream[I, O, TOption])
compose/runnable.go:304
↓ 1 callersFunctiontransformWithCallbacks
(t Transform[I, O, TOption])
compose/utils.go:148
↓ 1 callersMethodtryLoadCheckpoint
(ctx context.Context)
adk/turn_loop.go:989
↓ 1 callersMethodtrySend
(v T)
adk/utils.go:47
↓ 1 callersFunctiontypedInsertBeforeFirstUser
typedInsertBeforeFirstUser inserts a user message with agentsmd content before the first User message.
adk/middlewares/agentsmd/agentsmd.go:138
↓ 1 callersFunctiontypedRunnerResumeInternalImpl
(a TypedAgent[M], store CheckPointStore, ctx context.Context, checkPointID string, resumeData map[string]any,
adk/runner.go:205
↓ 1 callersFunctiontypedRunnerRunImpl
(a TypedAgent[M], enableStreaming bool, store CheckPointStore, ctx context.Context, messages []M, opts ...Agen
adk/runner.go:156
↓ 1 callersFunctiontypedSetMessageID
typedSetMessageID sets a specific message ID in Extra.
adk/wrappers.go:486
↓ 1 callersFunctiontypedTaskToolMiddleware
( ctx context.Context, taskToolDescriptionGenerator func(ctx context.Context, subAgents []adk.TypedAgent[M])
adk/prebuilt/deep/task_tool.go:35
↓ 1 callersFunctiontypedToolEnhancedInvokeEvent
typedToolEnhancedInvokeEvent constructs the tool result event for the enhanced invoke path. For *schema.Message it builds a multimodal tool message; f
adk/wrappers.go:778
↓ 1 callersFunctiontypedToolStreamEvent
typedToolStreamEvent constructs the tool result event for the stream path, dispatching on M to create the correct message stream and event types.
adk/wrappers.go:740
↓ 1 callersFunctionunmarshal
(data []byte, t reflect.Type)
internal/serialization/serialization.go:145
↓ 1 callersMethodupdateAndGet
(ctx context.Context, values map[string]map[string]any, dependencies map[string][]string)
compose/graph_manager.go:207
↓ 1 callersMethodvalidate
()
adk/middlewares/agentsmd/agentsmd.go:199
↓ 1 callersFunctionvalidateDAG
(chanSubscribeTo map[string]*chanCall, controlPredecessors map[string][]string)
compose/graph.go:1077
↓ 1 callersFunctionvalidateFieldMapping
(predecessorType reflect.Type, successorType reflect.Type, mappings []*FieldMapping)
compose/field_mapping.go:645
↓ 1 callersMethodwakeTimeoutController
()
adk/cancel.go:458
↓ 1 callersMethodwatchPreempt
watchPreempt runs for the lifetime of a single active turn. It consumes pending preempt requests exactly once and submits cancel for that turn.
adk/turn_loop.go:1759
↓ 1 callersMethodwatchStop
watchStop runs for the lifetime of a single active turn. It consumes pending Stop cancel requests exactly once and submits them to that turn.
adk/turn_loop.go:1784
↓ 1 callersFunctionwithAgentToolEventGenerator
(gen *AsyncGenerator[*AgentEvent])
adk/agent_tool.go:304
↓ 1 callersFunctionwithAgentToolOptions
(agentName string, opts []AgentRunOption)
adk/agent_tool.go:297
↓ 1 callersMethodwithKey
(string)
compose/stream_reader.go:31
↓ 1 callersMethodwithRunInfo
(runInfo *RunInfo)
internal/callbacks/manager.go:51
↓ 1 callersFunctionwithTypedAgentToolEventGenerator
(gen *AsyncGenerator[*TypedAgentEvent[M]])
adk/agent_tool.go:308
↓ 1 callersFunctionwrapEnhancedInvokableToolCall
(eiTool tool.EnhancedInvokableTool, middlewares []EnhancedInvokableToolMiddleware, needCallback bool)
compose/tool_node.go:614
↓ 1 callersFunctionwrapEnhancedStreamableToolCall
(est tool.EnhancedStreamableTool, middlewares []EnhancedStreamableToolMiddleware, needCallback bool)
compose/tool_node.go:633
↓ 1 callersMethodwrapGenerateEndpoint
(endpoint typedGenerateEndpoint[M])
adk/wrappers.go:1017
↓ 1 callersFunctionwrapGraphNodeError
(nodeKey string, err error)
compose/error.go:62
↓ 1 callersMethodwrapRunnableCtx
(ctxWrapper func(ctx context.Context, opts ...TOption) context.Context)
compose/runnable.go:88
↓ 1 callersMethodwrapStreamEndpoint
(endpoint typedStreamEndpoint[M])
adk/wrappers.go:1098
↓ 1 callersFunctionwrapStreamToolCall
(st tool.StreamableTool, middlewares []StreamableToolMiddleware, needCallback bool)
compose/tool_node.go:595
↓ 1 callersFunctionwrapToolCall
(it tool.InvokableTool, middlewares []InvokableToolMiddleware, needCallback bool)
compose/tool_node.go:576
MethodA
()
compose/graph_test.go:417
MethodA
()
compose/checkpoint_test.go:1277
MethodAddAgenticChatTemplate
AddAgenticChatTemplate adds a prompt.AgenticChatTemplate to the parallel. eg. chatTemplate01, err := prompt.FromAgenticMessages(schema.FString, &sch
compose/chain_parallel.go:111
← previousnext →1,601–1,700 of 3,994, ranked by callers