Functions — github.com/cloudwego/eino

hub / github.com/cloudwego/eino / functions

Functions3,994 in github.com/cloudwego/eino

⨍ Functions 3,994◇ Types & classes 1,204

↓ 2 callersFunctionnewInputModifyingWrapperFn

(inputPrefix string)

adk/handler_test.go:1285

↓ 2 callersFunctionnewInterruptTempInfo

()

compose/graph_run.go:424

↓ 2 callersFunctionnewOptionableEnhancedStreamTool

(desc *schema.ToolInfo, s OptionableEnhancedStreamFunc[T], opts ...Option)

components/tool/utils/streamable_func.go:199

↓ 2 callersFunctionnewOptionableEnhancedTool

(desc *schema.ToolInfo, i OptionableEnhancedInvokeFunc[T], opts ...Option)

components/tool/utils/invokable_func.go:254

↓ 2 callersFunctionnewOptionableStreamTool

(desc *schema.ToolInfo, s OptionableStreamFunc[T, D], opts ...Option)

components/tool/utils/streamable_func.go:69

↓ 2 callersFunctionnewOptionableTool

(desc *schema.ToolInfo, i OptionableInvokeFunc[T, D], opts ...Option)

components/tool/utils/invokable_func.go:149

↓ 2 callersFunctionnewPreemptRequest

(ack chan struct{}, opts []AgentCancelOption, now time.Time)

adk/turn_loop.go:147

↓ 2 callersFunctionnewTestEnhancedInvokableToolCallWrapper

(beforeFn, afterFn func())

adk/wrappers_test.go:55

↓ 2 callersFunctionnewTestEnhancedStreamableToolCallWrapper

(beforeFn, afterFn func())

adk/wrappers_test.go:70

↓ 2 callersFunctionnewTestInvokableToolCallWrapper

(beforeFn, afterFn func())

adk/handler_test.go:144

↓ 2 callersFunctionnewTestStreamableToolCallWrapper

(beforeFn, afterFn func())

adk/handler_test.go:171

↓ 2 callersFunctionnewTypedInvokableAgentToolRunner

(agent TypedAgent[M], store compose.CheckPointStore, enableStreaming bool)

adk/agent_tool.go:411

↓ 2 callersMethodnonClosedStreams

()

schema/stream.go:576

↓ 2 callersFunctionnormalizeLoops

(loops [][]string)

compose/graph_test.go:1934

↓ 2 callersMethodnotifyWatcherLocked

()

adk/turn_loop.go:368

↓ 2 callersMethodnotifyWatcherLocked

()

adk/turn_loop.go:554

↓ 2 callersFunctiononEnd

(ctx context.Context, output T)

compose/utils.go:36

↓ 2 callersFunctiononError

(ctx context.Context, err error)

compose/utils.go:96

↓ 2 callersFunctiononStart

(ctx context.Context, input T)

compose/utils.go:32

↓ 2 callersFunctionparallelRunToolCall

(ctx context.Context, run func(ctx2 context.Context, callTask *toolCallTask, opts ...tool.Option), tasks []t

compose/tool_node.go:985

↓ 2 callersMethodparse

parse parses a string into an object T.

schema/message_parser.go:130

↓ 2 callersMethodpopToolGenAction

(key string)

adk/react.go:142

↓ 2 callersMethodprepareTarget

(ctx context.Context)

adk/failover_chatmodel.go:62

↓ 2 callersFunctionpreprocessComposeCheckpoint

preprocessComposeCheckpoint migrates legacy compose checkpoints to the current format. It handles the v0.8.0-v0.8.3 format: - gob name "_eino_adk_stat

adk/chatmodel.go:1696

↓ 2 callersFunctionprintAny

(a any)

schema/agentic_message.go:2271

↓ 2 callersFunctionreadAgenticText

(msg *schema.AgenticMessage)

adk/prebuilt/deep/deep_test.go:77

↓ 2 callersFunctionreduceByTokens

reduceByTokens reduces context based on tool result token threshold and recent message protection. It clears old tool results when: 1. The total token

adk/middlewares/reduction/internal/clear_tool_result.go:113

↓ 2 callersFunctionremoveTool

(tools []*schema.ToolInfo, name string)

adk/middlewares/dynamictool/toolsearch/toolsearch.go:259

↓ 2 callersMethodreportSkip

([]string)

compose/graph_manager.go:32

↓ 2 callersMethodresolveCompletedTasks

(ctx context.Context, completedTasks []*task, isStream bool, cm *channelManager)

compose/graph_run.go:828

↓ 2 callersFunctionresolveRunCancelContext

(ctx context.Context, o *options)

adk/chatmodel.go:475

↓ 2 callersFunctionrestore

(values map[string]any, convPairs map[string]streamConvertPair, isStream bool)

compose/checkpoint.go:388

↓ 2 callersMethodrestoreCheckPointState

( ctx context.Context, path NodePath, sm StateModifier, cp *checkpoint, isStream bool, cm *channelManage

compose/graph_run.go:382

↓ 2 callersMethodrestoreTasks

( ctx context.Context, inputs map[string]any, skipPreHandler map[string]bool, rerunNodes []string, isStre

compose/graph_run.go:777

↓ 2 callersMethodresumeInternal

(ctx context.Context, checkPointID string, resumeData map[string]any, opts ...AgentRunOption)

adk/runner.go:151

↓ 2 callersMethodrun

( ctx context.Context, ctxForSubAgents context.Context, runCtx *runContext, aIter *AsyncIterator[*AgentEve

adk/flow.go:478

↓ 2 callersMethodrun

( ctx context.Context, _ context.Context, runCtx *runContext, aIter *AsyncIterator[*TypedAgentEvent[M]],

adk/flow.go:723

↓ 2 callersMethodrun

(ctx context.Context, isStream bool, input any, opts ...Option)

compose/graph_run.go:109

↓ 2 callersMethodrunAgentMode

(ctx context.Context, skill Skill, forkHistory bool, rawArguments string)

adk/middlewares/skill/skill.go:510

↓ 2 callersFunctionrunFlowAgentWithIsolatedSession

(ctx context.Context, fa *flowAgent, input *AgentInput, toAgentNames []string, options ...AgentRunOption)

adk/deterministic_transfer.go:166

↓ 2 callersMethodrunLoop

(ctx context.Context, generator *AsyncGenerator[*AgentEvent], loopState *loopWorkflowState, resumeInfo *Resum

adk/workflow.go:321

↓ 2 callersMethodrunParallel

(ctx context.Context, generator *AsyncGenerator[*AgentEvent], parState *parallelWorkflowState, resumeInfo *Re

adk/workflow.go:462

↓ 2 callersMethodrunSequential

(ctx context.Context, generator *AsyncGenerator[*AgentEvent], seqState *sequentialWorkflowState, info *Resume

adk/workflow.go:177

↓ 2 callersFunctionrunnerLoadCheckPointImpl

(store CheckPointStore, ctx context.Context, checkpointID string)

adk/interrupt.go:219

↓ 2 callersFunctionrunnerSaveCheckPointImpl

( enableStreaming bool, store CheckPointStore, ctx context.Context, key string, info *InterruptInfo, is

adk/interrupt.go:283

↓ 2 callersMethodsaveTurnLoopCheckpoint

(ctx context.Context, checkPointID string, c *turnLoopCheckpoint[T])

adk/turn_loop.go:968

↓ 2 callersFunctionsendTransferEvents

(generator *AsyncGenerator[*AgentEvent], toAgentNames []string)

adk/deterministic_transfer.go:286

↓ 2 callersFunctionsequentialRunToolCall

(ctx context.Context, run func(ctx2 context.Context, callTask *toolCallTask, opts ...tool.Option), tasks []t

compose/tool_node.go:973

↓ 2 callersMethodsetDeadlineUnixNano

(v int64)

adk/cancel.go:454

↓ 2 callersFunctionsetMapKVs

(dResult reflect.Value, values map[string]*internalStruct)

internal/serialization/serialization.go:581

↓ 2 callersFunctionsetMsgClearedFlagGeneric

setMsgClearedFlagGeneric sets the cleared flag on a message.

adk/middlewares/reduction/reduction.go:986

↓ 2 callersMethodsetRemainingIterations

(iterations int)

adk/react.go:183

↓ 2 callersFunctionsetSliceElems

(dResult reflect.Value, values []*internalStruct)

internal/serialization/serialization.go:542

↓ 2 callersFunctionsetStructFields

(dResult reflect.Value, values map[string]*internalStruct)

internal/serialization/serialization.go:603

↓ 2 callersFunctionsetSubAgents

(ctx context.Context, agent Agent, subAgents []Agent)

adk/flow.go:132

↓ 2 callersFunctionsetToolCallInfo

(ctx context.Context, toolCallInfo *toolCallInfo)

compose/tool_node.go:1293

↓ 2 callersMethodsetToolGenAction

(key string, action *AgentAction)

adk/react.go:135

↓ 2 callersFunctionsetToolResultSendersToCtx

(ctx context.Context, senders *toolResultSenders)

flow/agent/react/react.go:44

↓ 2 callersMethodsetupBridgeStore

(spec *turnRunSpec[T, M], runOpts []AgentRunOption)

adk/turn_loop.go:1739

↓ 2 callersFunctionsplitCamelCase

splitCamelCase splits a camelCase or PascalCase string into its constituent words.

adk/middlewares/dynamictool/toolsearch/toolsearch.go:624

↓ 2 callersFunctionsplitStrings

(s string, n int)

adk/middlewares/reduction/reduction_test.go:1199

↓ 2 callersFunctionstateV080ToState

stateV080ToState converts a legacy *stateV080 (v0.8.0-v0.8.3) to a current *State.

adk/react.go:232

↓ 2 callersMethodstream

(endpoint compose.StreamableToolEndpoint)

adk/middlewares/filesystem/large_tool_result.go:85

↓ 2 callersFunctionstreamWithCallbacks

(s Stream[I, O, TOption])

compose/utils.go:140

↓ 2 callersMethodtargetPath

()

compose/field_mapping.go:208

↓ 2 callersFunctiontextToFunctionToolResultBlocks

textToFunctionToolResultBlocks wraps a plain text string into FunctionToolResultBlocks.

adk/wrappers.go:574

↓ 2 callersFunctiontoAnyList

(in []T)

compose/utils.go:217

↓ 2 callersFunctiontoJson

(v any)

adk/middlewares/reduction/reduction_test.go:1228

↓ 2 callersMethodtoStreamReaders

(srs []streamReader)

compose/stream_reader.go:64

↓ 2 callersFunctiontoTypedFlowAgent

(agent TypedAgent[M])

adk/flow.go:631

↓ 2 callersFunctiontoolNameSet

(tools []*schema.ToolInfo)

adk/middlewares/dynamictool/toolsearch/toolsearch.go:269

↓ 2 callersFunctiontoolResultAgenticMessage

(callID, name string, tr *schema.ToolResult)

adk/wrappers.go:631

↓ 2 callersFunctiontoolSearchResultMessageToAgenticMessage

(m *schema.Message, meta *schema.StreamingMeta)

compose/agentic_tools_node.go:152

↓ 2 callersFunctiontransferToAgentToolOutput

(destName string)

adk/chatmodel.go:634

↓ 2 callersFunctiontypedEventFromMessage

typedEventFromMessage creates a TypedAgentEvent containing the given message and optional stream.

adk/interface.go:247

↓ 2 callersFunctiontypedGenModelInput

(_ context.Context, instruction string, input *adk.TypedAgentInput[M])

adk/prebuilt/deep/deep.go:175

↓ 2 callersFunctiontypedModelOutputEvent

typedModelOutputEvent creates a model-output event for the generic path. For *schema.Message, Role is set to schema.Assistant. For *schema.AgenticMess

adk/interface.go:265

↓ 2 callersFunctiontypedNewTaskTool

( ctx context.Context, taskToolDescriptionGenerator func(ctx context.Context, subAgents []adk.TypedAgent[M])

adk/prebuilt/deep/task_tool.go:61

↓ 2 callersFunctiontypedSetFailoverLastSuccessModel

(ctx context.Context, m model.BaseModel[M])

adk/failover_chatmodel.go:177

↓ 2 callersFunctiontypedToolEnhancedStreamEvent

typedToolEnhancedStreamEvent constructs the tool result event for the enhanced stream path. For *schema.Message it builds multimodal tool messages; fo

adk/wrappers.go:804

↓ 2 callersFunctiontypedWrapIterWithOnEnd

(ctx context.Context, iter *AsyncIterator[*TypedAgentEvent[M]])

adk/flow.go:802

↓ 2 callersFunctionunwindLaneEvents

unwindLaneEvents traverses the LaneEvents of the given contexts and collects all events from the leaf nodes.

adk/runctx.go:467

↓ 2 callersMethodupdateDependencies

(_ context.Context, dependenciesMap map[string][]string)

compose/graph_manager.go:167

↓ 2 callersMethodupdateToValidateMap

updateToValidateMap after update node, check validate map check again if nodes in toValidateMap have been updated. because when there are multiple lin

compose/graph.go:561

↓ 2 callersMethodupdateValues

(_ context.Context, values map[string] /*to*/ map[string] /*from*/ any)

compose/graph_manager.go:138

↓ 2 callersMethodvalidate

()

flow/agent/multiagent/host/types.go:136

↓ 2 callersFunctionvalidatePages

(pages string)

adk/middlewares/filesystem/filesystem.go:653

↓ 2 callersFunctionvalidateStructOrMap

(t reflect.Type)

compose/field_mapping.go:631

↓ 2 callersMethodwait

()

compose/graph_manager.go:353

↓ 2 callersMethodwaitOne

()

compose/graph_manager.go:381

↓ 2 callersMethodwasCalled

()

adk/middlewares/dynamictool/toolsearch/toolsearch_test.go:214

↓ 2 callersFunctionwithAgentToolEnableStreaming

(enabled bool)

adk/agent_tool.go:63

↓ 2 callersFunctionwithSharedParentSession

()

adk/call_option.go:69

↓ 2 callersFunctionwrapAgenticIterWithOnEnd

(ctx context.Context, iter *AsyncIterator[*TypedAgentEvent[*schema.AgenticMessage]])

adk/flow.go:771

↓ 2 callersFunctionwrapIterWithMarkDone

(iter *AsyncIterator[*AgentEvent], cc *cancelContext)

adk/cancel_test.go:1735

↓ 2 callersMethodwrapModel

(m model.BaseModel[M])

adk/wrappers.go:83

↓ 1 callersMethodAddAgenticModelNode

AddAgenticModelNode adds an agentic model node and returns it.

compose/workflow.go:93

↓ 1 callersMethodAddAgenticToolsNode

AddAgenticToolsNode adds an agentic tools node and returns it.

compose/workflow.go:117

↓ 1 callersMethodAddChatModel

AddChatModel adds a chat model to the parallel. eg. chatModel01, err := openai.NewChatModel(ctx, &openai.ChatModelConfig{ Model: "gpt-4o", }) c

compose/chain_parallel.go:68

↓ 1 callersMethodAddDocumentTransformer

AddDocumentTransformer adds an Document Transformer node to the parallel. eg. markdownSplitter, err := markdown.NewHeaderSplitter(ctx, &markdown.Hea

compose/chain_parallel.go:209

← previous next →1,101–1,200 of 3,994, ranked by callers