MCPcopy Index your code

hub / github.com/cloudwego/eino-ext / functions

Functions4,194 in github.com/cloudwego/eino-ext

⨍ Functions 4,194◇ Types & classes 1,041
↓ 16 callersFunctiontoArkContent
(msg *schema.Message)
components/model/arkbot/chatmodel.go:727
↓ 15 callersMethodClose
(ctx context.Context)
components/indexer/es8/indexer_test.go:283
↓ 15 callersFunctionNewHybrid
NewHybrid creates a new Hybrid search mode with the given reranker and sub-requests.
components/retriever/milvus2/search_mode/hybrid.go:71
↓ 15 callersMethodRetrieve
Retrieve searches for documents matching the given query. It returns the matching documents or an error.
components/retriever/milvus2/retriever.go:154
↓ 15 callersMethodgenRequest
(ctx context.Context, in []*schema.Message, opts ...model.Option)
libs/acl/openai/chat_model.go:565
↓ 15 callersMethoditemDoneEventToContentBlocks
(ev responses.ResponseOutputItemDoneEvent)
components/model/agenticopenai/responses_event_convertor.go:461
↓ 15 callersMethodsendRequestWithRetry
sendRequestWithRetry sends the request with retry logic.
components/tool/searxng/searxng.go:326
↓ 14 callersMethodBuildHybridSearchOption
BuildHybridSearchOption creates a HybridSearchOption for multi-vector search with reranking. It is internal to the hybrid implementation now/helper bu
components/retriever/milvus2/search_mode/hybrid.go:113
↓ 14 callersMethodStore
Store adds the provided documents to the Milvus collection. It returns the list of IDs for the stored documents or an error.
components/indexer/milvus2/indexer.go:232
↓ 14 callersMethodbuildRequestModifier
(option *openrouterOption)
components/model/openrouter/chatmodel.go:226
↓ 14 callersMethodbulkAdd
(ctx context.Context, docs []*schema.Document, options *indexer.Options)
components/indexer/opensearch2/indexer.go:177
↓ 14 callersMethodbulkAdd
(ctx context.Context, docs []*schema.Document, options *indexer.Options)
components/indexer/opensearch3/indexer.go:183
↓ 14 callersFunctioncoalesce
(x, y T)
components/model/agenticark/utils.go:35
↓ 14 callersFunctiondereferenceOrZero
(v *T)
components/model/arkbot/utils.go:25
↓ 14 callersFunctionexpandAgenticModelMessage
(message *schema.AgenticMessage)
callbacks/cozeloop/convert.go:668
↓ 14 callersFunctionnewServerToolCallContentBlock
(callID, name string, args *ServerToolCallArguments)
components/model/agenticclaude/convertor.go:638
↓ 14 callersFunctionptrOf
(v T)
components/retriever/dify/utils.go:19
↓ 14 callersMethodtoArkUserRoleItemInputMessage
(msg *schema.Message)
components/model/ark/responses_api.go:782
↓ 14 callersFunctiontoDeepSeekMessage
(m *schema.Message)
components/model/deepseek/deepseek.go:710
↓ 13 callersMethodExecute
(params *Param)
components/tool/browseruse/browseruse.go:382
↓ 13 callersMethodExecuteStreaming
(ctx context.Context, input *filesystem.ExecuteRequest)
adk/backend/local/local.go:948
↓ 13 callersFunctionGetItemStatus
(block *schema.ContentBlock)
components/model/agenticark/content_block_extra.go:59
↓ 13 callersMethodHeader
()
devops/internal/apihandler/server_test.go:58
↓ 13 callersFunctionNewIterator
NewIterator creates a new Iterator search mode.
components/retriever/milvus2/search_mode/iterator.go:49
↓ 13 callersFunctionNewRetriever
NewRetriever creates a new ES7 retriever with the provided configuration.
components/retriever/es7/retriever.go:70
↓ 13 callersFunctionNewRetriever
(ctx context.Context, config *RetrieverConfig)
components/retriever/milvus/retriever.go:79
↓ 13 callersMethodRetrieve
Retrieve searches for documents in Elasticsearch matching the given query.
components/retriever/es7/retriever.go:93
↓ 13 callersFunctiondereferenceOrZero
(v *T)
components/model/qianfan/utils.go:25
↓ 13 callersMethoddoResp
(res http.ResponseWriter)
devops/internal/apihandler/server.go:140
↓ 13 callersFunctionmakeServerToolResultIndexKey
(outputIndex int64)
components/model/agenticopenai/responses_event_convertor.go:1169
↓ 13 callersFunctionnewHTTPResp
* newHTTPResp create a new HTTPResp. data: the data to be returned. baseResp: the base resp to be returned. 1. if baseResp set, the base resp will be
devops/internal/apihandler/server.go:96
↓ 13 callersFunctionpopulateToolChoice
(req *openai.ChatCompletionRequest, tc *schema.ToolChoice, allowedToolNames []string)
libs/acl/openai/chat_model.go:1004
↓ 13 callersMethodvalidate
validate checks the configuration and sets default values.
components/indexer/milvus2/indexer.go:345
↓ 12 callersMethodClose
()
components/model/deepseek/deepseek_test.go:252
↓ 12 callersMethodEdit
(ctx context.Context, req *filesystem.EditRequest)
acp/backend.go:634
↓ 12 callersMethodError
()
components/model/ollama/chatmodel.go:564
↓ 12 callersMethodLoad
(ctx context.Context, src document.Source, opts ...document.LoaderOption)
components/document/loader/url/url.go:85
↓ 12 callersFunctionNewRange
NewRange creates a new Range search mode.
components/retriever/milvus2/search_mode/range.go:50
↓ 12 callersMethodParse
(ctx context.Context, reader io.Reader, opts ...parser.Option)
components/document/parser/html/html.go:68
↓ 12 callersMethodRead
(ctx context.Context, req *filesystem.ReadRequest)
acp/backend.go:324
↓ 12 callersMethodaddNode
(node string, gni compose.GraphNodeInfo, opts ...compose.GraphAddNodeOpt)
devops/internal/model/container.go:377
↓ 12 callersFunctioncheckExpectedType
(expectedType, chunkType reflect.Type)
components/model/agenticopenai/responses_extension.go:335
↓ 12 callersFunctionconvCandidate
(candidate *genai.Candidate)
components/model/gemini/gemini.go:1189
↓ 12 callersFunctionpopulateToolChoice
(params *anthropic.MessageNewParams, tc *schema.ToolChoice, allowedToolNames []string, disableParallelToolUse
components/model/claude/claude.go:865
↓ 11 callersMethodStream
(ctx context.Context, input []*schema.AgenticMessage, opts ...model.Option)
components/model/agenticgemini/model.go:274
↓ 11 callersMethodbuiltinEmbedding
(ctx context.Context, queries []string, options *indexer.Options)
components/indexer/volc_vikingdb/indexer.go:209
↓ 11 callersMethodbuiltinEmbedding
(ctx context.Context, query string, options *retriever.Options)
components/retriever/volc_vikingdb/retriever.go:212
↓ 11 callersFunctiongetAggrMessageOutputHookFromCtx
(ctx context.Context)
callbacks/cozeloop/utils.go:166
↓ 11 callersMethoditemAddedEventToContentBlock
(ev responses.ResponseOutputItemAddedEvent)
components/model/agenticopenai/responses_event_convertor.go:338
↓ 11 callersFunctioniterSlice
(sa []A, fb func(a A) B)
callbacks/cozeloop/convert.go:883
↓ 11 callersFunctionmakeServerToolCallIndexKey
(outputIndex int64)
components/model/agenticopenai/responses_event_convertor.go:1165
↓ 11 callersFunctionmessageToAgenticMessage
(msg *schema.Message)
libs/acl/openai/agentic_convert.go:40
↓ 11 callersFunctionparseSpanTypeFromComponent
parseSpanTypeFromComponent 转换 component 到 fornax 可以识别的 span_type span_type 会影响到 fornax 界面的展示 TODO: - 当前框架相比于之前缺失的后续需要补齐, 当前按照`原来的字符串`处理 - compose 相关概念
callbacks/cozeloop/data_parser.go:744
↓ 11 callersMethodpopulateInput
(in []*schema.Message, responseReq *responses.ResponsesRequest, enableReasoningPassback bool)
components/model/ark/responses_api.go:634
↓ 11 callersFunctionpopulateToolChoice
(req *qianfan.ChatCompletionV2Request, tc *schema.ToolChoice, allowedToolNames []string)
components/model/qianfan/chatmodel.go:398
↓ 11 callersFunctionptr
(t T)
libs/acl/openai/chat_model_test.go:1107
↓ 11 callersFunctionrequireTextChunk
(t *testing.T, su acpproto.SessionUpdate, wantText string)
acp/conv_test.go:45
↓ 11 callersMethodsetFromExtraIfNotZero
(key string, extra map[string]any)
callbacks/cozeloop/utils.go:98
↓ 11 callersFunctionsetStringArgument
(m map[string]any, key string, dst *string)
components/model/agenticclaude/utils.go:65
↓ 11 callersFunctionvalidateInSlice
validateInSlice validates whether a value is in the given slice using generics
components/tool/searxng/searxng.go:197
↓ 10 callersMethodGenerate
(ctx context.Context, in []*schema.Message, opts ...fmodel.Option)
components/model/ark/chatmodel.go:384
↓ 10 callersMethodGenerate
(ctx context.Context, input []*schema.Message, opts ...model.Option)
components/model/gemini/gemini.go:201
↓ 10 callersMethodGlobInfo
(ctx context.Context, req *filesystem.GlobInfoRequest)
acp/backend.go:564
↓ 10 callersFunctionNewApproximate
NewApproximate creates a new Approximate search mode with the specified metric type.
components/retriever/milvus2/search_mode/approximate.go:41
↓ 10 callersFunctionNewChatModel
(_ context.Context, config *ChatModelConfig)
components/model/deepseek/deepseek.go:140
↓ 10 callersFunctionNewSimpleGenerator
NewSimpleGenerator creates a new [SimpleGenerator] instance.
components/embedding/cache/generator.go:43
↓ 10 callersMethodSearch
Search sends a search request to Searxng API and returns the search results.
components/tool/searxng/searxng.go:390
↓ 10 callersMethodStream
(ctx context.Context, input []*schema.AgenticMessage, opts ...model.Option)
components/model/agenticopenai/responses_model.go:302
↓ 10 callersMethodToEntity
ToEntity converts ConsistencyLevel to the Milvus SDK entity.ConsistencyLevel type. Note: ConsistencyLevelDefault should be checked before calling this
components/retriever/milvus2/types.go:92
↓ 10 callersFunctiondiscardLogger
discardLogger is a slog.Logger that drops every record. It keeps test output clean while still exercising the warn/info/debug paths inside Backend.
acp/backend_test.go:34
↓ 10 callersFunctiongetServerToolResult
(res *schema.ServerToolResult)
components/model/agenticopenai/responses_extension.go:310
↓ 10 callersFunctionpopulateCompletionAPIToolChoice
(req *model.CreateChatCompletionRequest, schemaToolChoice *schema.ToolChoice, allowedToolNames []string)
components/model/ark/chat_completion_api.go:889
↓ 10 callersMethodpopulateToolChoice
(req *anthropic.MessageNewParams, options *model.Options)
components/model/agenticclaude/model.go:597
↓ 10 callersFunctionptrOf
(v T)
components/model/agenticopenai/utils.go:48
↓ 10 callersFunctionterminalMock
terminalMock returns a mockConn that simulates a shell command producing the given output and exit code. Used by LsInfo/GlobInfo/GrepRaw tests.
acp/backend_test.go:616
↓ 10 callersFunctiontoJson
(v any, bStream bool)
callbacks/cozeloop/utils.go:119
↓ 10 callersMethodvalidate
validate validates the configuration and sets default values if not provided.
components/tool/duckduckgo/search.go:58
↓ 9 callersFunctionAddTag
AddTag 插入tag
callbacks/langsmith/trace.go:57
↓ 9 callersMethodEndGeneration
(body *GenerationEventBody)
libs/acl/langfuse/langfuse.go:39
↓ 9 callersFunctionGetCacheExpiration
GetCacheExpiration returns the cache expiration time in seconds. Only available for ResponsesAPI responses.
components/model/ark/message_extra.go:193
↓ 9 callersMethodGrepRaw
(ctx context.Context, req *filesystem.GrepRequest)
acp/backend.go:394
↓ 9 callersMethodInfo
(_ context.Context)
components/tool/browseruse/browseruse.go:135
↓ 9 callersMethodInvokableRun
(ctx context.Context, argumentsInJSON string, opts ...tool.Option)
components/tool/browseruse/browseruse.go:139
↓ 9 callersMethodMultiModalRead
MultiModalRead reads file content with multimodal support for images and PDFs. For non-image/non-PDF files, it delegates to the standard Read method.
adk/backend/local/local.go:390
↓ 9 callersFunctionNew
(ctx context.Context, config *Config)
components/model/agenticqwen/model.go:133
↓ 9 callersFunctionNewIndexer
NewIndexer creates a new ES9 indexer with the provided configuration. It returns an error if the client or DocumentToFields mapping is missing.
components/indexer/es9/indexer.go:95
↓ 9 callersMethodRetrieve
Retrieve searches for documents in Elasticsearch matching the given query.
components/retriever/es9/retriever.go:101
↓ 9 callersMethodWithNList
WithNList sets the NList parameter.
components/indexer/milvus2/index_builder.go:147
↓ 9 callersFunctionconvertModelMessage
(message *schema.Message)
callbacks/cozeloop/convert.go:71
↓ 9 callersFunctiondereferenceOrZero
(v *T)
libs/acl/openai/utils.go:19
↓ 9 callersMethodexecute
execute executes a command in the sandbox.
adk/backend/agentkit/sandbox.go:999
↓ 9 callersFunctiongetErrorTags
(_ context.Context, err error)
callbacks/cozeloop/utils.go:39
↓ 9 callersFunctiongetNodeDebugStateCtx
getNodeDebugStateCtx get temporary storage node debug state from context.
devops/internal/service/call_option.go:338
↓ 9 callersFunctiongetReasoningDetails
(msg *schema.Message)
components/model/openrouter/message_extra.go:112
↓ 9 callersFunctiongetServerToolCallArguments
(call *schema.ServerToolCall)
components/model/agenticopenai/responses_extension.go:285
↓ 9 callersFunctiongetServerToolCallArguments
(call *schema.ServerToolCall)
components/model/agenticark/extension.go:150
↓ 9 callersFunctioninjectAggrMessageOutputHookToCtx
(ctx context.Context)
callbacks/cozeloop/utils.go:154
↓ 9 callersFunctioninjectGraphNodeLevelToCtx
(ctx context.Context, level int64)
callbacks/cozeloop/utils.go:150
↓ 9 callersFunctionisValidUUID
isValidUUID checks if a string is a valid UUID format
components/model/gemini/gemini_test.go:1253
↓ 9 callersFunctionnewOpenaiOpt
(optVal *T)
components/model/agenticopenai/utils.go:27
← previousnext →101–200 of 4,194, ranked by callers