MCPcopy Create free account

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

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

⨍ Functions 4,194◇ Types & classes 1,041
↓ 1 callersMethodmakeEmbeddingCtx
(ctx context.Context, emb embedding.Embedder)
components/retriever/volc_vikingdb/retriever.go:283
↓ 1 callersMethodmakeEmbeddingCtx
(ctx context.Context, emb embedding.Embedder)
components/retriever/qdrant/retriever.go:160
↓ 1 callersMethodmakeEmbeddingCtx
(ctx context.Context, emb embedding.Embedder)
components/retriever/redis/retriever.go:206
↓ 1 callersMethodmakeEmbeddingCtx
makeEmbeddingCtx makes the embedding context
components/retriever/milvus/utils.go:171
↓ 1 callersFunctionmarshalMessage
(message *schema.Message)
libs/acl/langfuse/media.go:104
↓ 1 callersFunctionmarshalMessages
(messages []*schema.Message)
libs/acl/langfuse/media.go:108
↓ 1 callersFunctionmergeAdjacentToolContents
mergeAdjacentToolContents merges adjacent tool response contents into a single content. Gemini requires all tool responses to be in a single message w
components/model/gemini/gemini.go:749
↓ 1 callersFunctionmergeAdjacentToolContents
mergeAdjacentToolContents merges adjacent tool response contents into one. Gemini requires all tool responses to be in a single message when respondin
components/model/agenticgemini/conv.go:53
↓ 1 callersFunctionmergeAdjacentToolResults
mergeAdjacentToolResults merges adjacent tool-result user messages into one. Anthropic requires all tool_result blocks for an assistant turn in a sing
components/model/agenticclaude/convertor.go:77
↓ 1 callersFunctionmergeAdjacentToolResults
mergeAdjacentToolResults merges adjacent tool-result user messages into one. Anthropic requires all tool_result blocks for an assistant turn in a sing
components/model/claude/claude.go:724
↓ 1 callersFunctionmustWebFetchCaller
(t *testing.T)
components/model/agenticclaude/convertor_test.go:634
↓ 1 callersFunctionmustWebSearchCaller
(t *testing.T)
components/model/agenticclaude/convertor_test.go:624
↓ 1 callersFunctionnewCache
(maxAge time.Duration)
components/tool/bingsearch/internal/bingcore/cache.go:72
↓ 1 callersFunctionnewCache
(maxAge time.Duration)
components/tool/duckduckgo/ddgsearch/cache.go:72
↓ 1 callersFunctionnewClient
( cli *http.Client, host string, publicKey string, secretKey string, sdkVersion string, )
libs/acl/langfuse/client.go:34
↓ 1 callersFunctionnewConfig
(opts []Option)
libs/acl/opentelemetry/option.go:57
↓ 1 callersFunctionnewDefaultDataParserWithConcatFuncs
(concatFuncs map[reflect.Type]any, enableAggrMessageOutput bool)
callbacks/cozeloop/data_parser.go:55
↓ 1 callersFunctionnewDirectAnthropicClient
(opts ...option.RequestOption)
components/model/claude/claude.go:320
↓ 1 callersFunctionnewGraph
()
devops/internal/model/container_test.go:1500
↓ 1 callersFunctionnewIngestionConsumer
( cli *client, q *queue, flushAt int, flushInterval time.Duration, sampleRate float64, logMessage string
libs/acl/langfuse/consumer.go:51
↓ 1 callersFunctionnewJanitor
newJanitor creates a new janitor with the specified interval
components/tool/bingsearch/internal/bingcore/cache.go:52
↓ 1 callersFunctionnewJanitor
newJanitor creates a new janitor with the specified interval
components/tool/duckduckgo/ddgsearch/cache.go:52
↓ 1 callersFunctionnewPanicErr
(info any, stack []byte)
components/model/agenticark/utils.go:67
↓ 1 callersFunctionnewQueue
(maxSize int)
libs/acl/langfuse/queue.go:28
↓ 1 callersFunctionnewRequestTool
(config *Config)
components/tool/httprequest/get/tool.go:91
↓ 1 callersFunctionnewRequestTool
(config *Config)
components/tool/httprequest/delete/tool.go:95
↓ 1 callersFunctionnewRequestTool
(config *Config)
components/tool/httprequest/put/tool.go:99
↓ 1 callersFunctionnewRequestTool
(config *Config)
components/tool/httprequest/post/tool.go:99
↓ 1 callersFunctionnewTaskManager
( threads int, cli *http.Client, host string, maxTaskQueueSize int, flushAt int, flushInterval time.Dura
libs/acl/langfuse/task.go:26
↓ 1 callersFunctionnewWikipedia
newWikipedia creates a new wikipedia search tool.
components/tool/wikipedia/wikipedia.go:119
↓ 1 callersMethodnext
()
libs/acl/langfuse/consumer.go:141
↓ 1 callersFunctionof
(a T)
components/model/ollama/examples/generate_with_image/generate_with_image.go:70
↓ 1 callersFunctionof
(a T)
components/model/openai/examples/generate_with_image/generate_with_image.go:78
↓ 1 callersFunctionof
(a T)
components/model/openrouter/examples/generate_with_image/generate_with_image.go:75
↓ 1 callersFunctionof
(v T)
components/model/claude/examples/generate_with_image/generate_with_image.go:93
↓ 1 callersFunctionof
(t T)
components/retriever/es8/examples/dense_vector_similarity/dense_vector_similarity.go:185
↓ 1 callersFunctionof
(t T)
components/retriever/es8/examples/sparse_vector_query/sparse_vector_query.go:197
↓ 1 callersFunctionof
(v T)
components/retriever/es9/search_mode/search_mode_test.go:227
↓ 1 callersFunctionopenFile
(path string)
components/document/loader/file/file_loader.go:136
↓ 1 callersFunctionpairToolCallItems
(items []responses.ResponseInputItemUnionParam)
components/model/agenticopenai/responses_convertor.go:148
↓ 1 callersFunctionpairToolCallItems
(items []*responses.InputItem)
components/model/agenticark/convertor.go:145
↓ 1 callersMethodparseAgentInput
(ctx context.Context, info *callbacks.RunInfo, input *adk.AgentCallbackInput)
callbacks/cozeloop/data_parser.go:791
↓ 1 callersMethodparseAgentOutput
(ctx context.Context, info *callbacks.RunInfo, output *adk.AgentCallbackOutput)
callbacks/cozeloop/data_parser.go:813
↓ 1 callersMethodparseDefaultStreamInput
(ctx context.Context, input *schema.StreamReader[callbacks.CallbackInput])
devops/internal/service/call_option.go:238
↓ 1 callersMethodparseDefaultStreamOutput
(ctx context.Context, output *schema.StreamReader[callbacks.CallbackOutput])
devops/internal/service/call_option.go:258
↓ 1 callersFunctionparseJSONToObject
(jsonStr string)
components/model/ollama/chatmodel.go:490
↓ 1 callersFunctionparseSearchResponse
parseSearchResponse parses the search response from DuckDuckGo
components/tool/duckduckgo/ddgsearch/search_text.go:155
↓ 1 callersMethodparseSearchResult
(ctx context.Context, body io.Reader)
components/retriever/es7/retriever.go:164
↓ 1 callersMethodparseSearchResult
(ctx context.Context, resp *search.Response)
components/retriever/es8/retriever.go:155
↓ 1 callersMethodparseSearchResult
(ctx context.Context, resp *search.Response)
components/retriever/es9/retriever.go:155
↓ 1 callersMethodpatchMedia
( mediaID string, uploadedAt time.Time, uploadHTTPStatus int, uploadHTTPError string, uploadTimeMs int64,
libs/acl/langfuse/client.go:249
↓ 1 callersFunctionpopulateAndGetEmbeddedStreamReader
(stream *openai.ChatCompletionStream)
libs/acl/openai/chat_model_test.go:875
↓ 1 callersMethodpopulateCache
populateCache resolves the PreviousResponseID for cache continuation. Priority: auto-discovered response ID in messages > WithHeadPreviousResponseID o
components/model/agenticopenai/responses_model.go:631
↓ 1 callersFunctionpopulateChatMsgReasoningContent
(in *schema.Message, msg *model.ChatCompletionMessage)
components/model/ark/chat_completion_api.go:302
↓ 1 callersMethodpopulateInput
(in []*schema.AgenticMessage, responseReq *responses.ResponseNewParams)
components/model/agenticopenai/responses_model.go:688
↓ 1 callersMethodpopulateInput
(params *anthropic.MessageNewParams, system []*schema.Message, msgs []*schema.Message, specOptions *options)
components/model/claude/claude.go:673
↓ 1 callersFunctionpopulateResponseAPIToolChoice
(responseReq *responses.ResponsesRequest, tc *schema.ToolChoice, allowedToolNames []string)
components/model/ark/responses_api.go:1597
↓ 1 callersFunctionpopulateStreamingMeta
(curBlocks []*schema.ContentBlock, curIndex int, lastType schema.ContentBlockType)
components/model/agenticgemini/conv.go:637
↓ 1 callersMethodpopulateToolChoice
(responseReq *responses.ResponseNewParams, options *model.Options)
components/model/agenticopenai/responses_model.go:731
↓ 1 callersMethodpopulateTools
(params *anthropic.MessageNewParams, commonOptions *model.Options, specOptions *options)
components/model/claude/claude.go:790
↓ 1 callersMethodprePopulateConfig
(responseReq *responses.ResponseNewParams, options *model.Options, specOptions *options)
components/model/agenticopenai/responses_model.go:580
↓ 1 callersFunctionpreProcessMessages
(input []*schema.Message)
components/model/claude/claude.go:560
↓ 1 callersFunctionprepareDocs
()
components/indexer/es7/examples/indexer/add_documents.go:136
↓ 1 callersFunctionprepareDocs
(emb *localEmbeddings)
components/indexer/es8/examples/indexer_with_sparse_vector/add_documents.go:152
↓ 1 callersFunctionprepareDocs
()
components/indexer/es8/examples/indexer/add_documents.go:144
↓ 1 callersFunctionprepareDocs
(emb *localEmbeddings)
components/indexer/es9/examples/indexer_with_sparse_vector/add_documents.go:160
↓ 1 callersFunctionprepareDocs
()
components/indexer/es9/examples/indexer/add_documents.go:153
↓ 1 callersFunctionprepareEmbeddings
()
components/indexer/es7/examples/indexer/add_documents.go:122
↓ 1 callersFunctionprepareEmbeddings
()
components/indexer/es8/examples/indexer_with_sparse_vector/add_documents.go:138
↓ 1 callersFunctionprepareEmbeddings
()
components/indexer/es8/examples/indexer/add_documents.go:130
↓ 1 callersFunctionprepareEmbeddings
()
components/indexer/es9/examples/indexer_with_sparse_vector/add_documents.go:146
↓ 1 callersFunctionprepareEmbeddings
()
components/indexer/es9/examples/indexer/add_documents.go:139
↓ 1 callersFunctionprepareEmbeddings
()
components/retriever/es7/examples/dense_vector_similarity/dense_vector_similarity.go:145
↓ 1 callersFunctionprepareEmbeddings
()
components/retriever/es8/examples/dense_vector_similarity/dense_vector_similarity.go:171
↓ 1 callersFunctionprepareEmbeddings
()
components/retriever/es8/examples/approximate/approximate.go:179
↓ 1 callersFunctionprepareEmbeddings
()
components/retriever/es8/examples/sparse_vector_query/sparse_vector_query.go:183
↓ 1 callersFunctionprepareEmbeddings
()
components/retriever/es9/examples/approximate/approximate.go:169
↓ 1 callersMethodprepareRequest
(req *http.Request)
components/retriever/volc_knowledge/knowledge.go:235
↓ 1 callersFunctionprintEvent
(event *adk.AgentEvent)
components/model/claude/examples/client_tool_search/main.go:132
↓ 1 callersFunctionptrOf
(v T)
components/model/ollama/utils.go:19
↓ 1 callersFunctionptrOf
(v T)
components/retriever/volc_vikingdb/utils.go:77
↓ 1 callersMethodput
(value *event)
libs/acl/langfuse/queue.go:44
↓ 1 callersFunctionrandomDocs
(slice []*schema.Document)
components/document/transformer/reranker/score/score_test.go:83
↓ 1 callersFunctionreadFromTar
readFromTar reads file content from tar stream
components/tool/commandline/sandbox/sandbox.go:454
↓ 1 callersMethodreadFull
readFull reads an entire file via the ACP ReadTextFile RPC (no offset/limit). Used by both Read (when no offset) and Edit for the read-modify-write cy
acp/backend.go:650
↓ 1 callersMethodreadStderrAsync
readStderrAsync reads stderr in a separate goroutine.
adk/backend/local/local.go:1116
↓ 1 callersFunctionreadVersionByGoMod
(path string)
callbacks/cozeloop/builtin.go:33
↓ 1 callersFunctionreasoningToBlockParam
(reasoning *schema.Reasoning)
components/model/agenticclaude/convertor.go:236
↓ 1 callersFunctionreceivedStreamResponse
(streamReader *utils.ResponsesStreamReader, config *model.AgenticConfig, sw *schema.StreamWriter[*model.Agent
components/model/agenticark/event_convertor.go:30
↓ 1 callersFunctionreceivedStreamingResponse
(sr *ssestream.Stream[responses.ResponseStreamEventUnion], config *model.AgenticConfig, sw *schema.StreamWrit
components/model/agenticopenai/responses_event_convertor.go:30
↓ 1 callersFunctionregisterRoutes
(r *mux.Router)
devops/internal/apihandler/server.go:55
↓ 1 callersFunctionremoveReasoningItems
(itemList []*responses.InputItem)
components/model/agenticark/model.go:816
↓ 1 callersMethodresolveChatResponse
(resp model.ChatCompletionResponse)
components/model/ark/chat_completion_api.go:478
↓ 1 callersMethodresolveChatResponse
(resp model.BotChatCompletionResponse)
components/model/arkbot/chatmodel.go:548
↓ 1 callersFunctionresolveQianfanResponse
(resp *qianfan.ChatCompletionV2Response)
components/model/qianfan/chatmodel.go:660
↓ 1 callersFunctionresolveStreamResponse
(resp model.BotChatCompletionStreamResponse)
components/model/arkbot/chatmodel.go:599
↓ 1 callersMethodresolveStreamResponse
(resp model.ImagesStreamResponse)
components/model/ark/image_generation_model.go:466
↓ 1 callersMethodresolveStreamResponse
(resp model.ChatCompletionStreamResponse)
components/model/ark/chat_completion_api.go:529
↓ 1 callersFunctionresponseMetaChunkModifier
()
components/model/agenticopenai/chat_extension.go:85
↓ 1 callersFunctionresponseMetaChunkModifier
()
components/model/agenticqwen/extension.go:79
← previousnext →2,001–2,100 of 4,194, ranked by callers