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
↓ 788 callersMethodRun
Run starts the janitor in a new goroutine
components/tool/duckduckgo/ddgsearch/cache.go:32
↓ 583 callersMethodBuild
Build creates a Milvus index configured with the specified metric type.
components/indexer/milvus2/index_builder.go:27
↓ 336 callersMethodLen
()
components/document/transformer/reranker/score/score.go:104
↓ 207 callersMethodError
()
components/model/ark/utils.go:55
↓ 153 callersMethodClose
()
components/tool/mcp/mcp_test.go:159
↓ 150 callersMethodMarshal
(v any)
components/embedding/cache/redis/codec.go:24
↓ 131 callersMethodUnmarshal
(data []byte, v any)
components/embedding/cache/redis/codec.go:25
↓ 115 callersMethodRecv
()
components/model/deepseek/deepseek_test.go:243
↓ 105 callersMethodError
()
components/tool/wikipedia/internal/errors.go:37
↓ 94 callersMethodCompile
()
devops/internal/model/container.go:372
↓ 94 callersMethodSet
Set stores the value in the cache with the given key. If the key already exists, it will be overwritten.
components/embedding/cache/cacher.go:27
↓ 86 callersMethodset
(key string, value any)
callbacks/cozeloop/utils.go:59
↓ 81 callersMethodGet
Get retrieves the value from the cache with the given key. If the key does not exist, the bool return value is false，otherwise it returns true If the
components/embedding/cache/cacher.go:32
↓ 79 callersFunctionsetItemID
(block *schema.ContentBlock, itemID string)
components/model/agenticopenai/responses_content_block_extra.go:35
↓ 78 callersMethodError
()
adk/backend/local/local.go:1203
↓ 64 callersMethodGenerate
(ctx context.Context, text string, opt GeneratorOption)
components/embedding/cache/generator.go:33
↓ 63 callersMethodOnError
(ctx context.Context, info *callbacks.RunInfo, err error)
callbacks/cozeloop/callback.go:80
↓ 63 callersMethodOnStart
(ctx context.Context, info *callbacks.RunInfo, input callbacks.CallbackInput)
callbacks/cozeloop/callback.go:56
↓ 63 callersFunctionnewStreamReceiver
(options *model.Options)
components/model/agenticopenai/responses_event_convertor.go:275
↓ 57 callersFunctionptrOf
(v T)
components/model/ark/utils.go:46
↓ 57 callersFunctionptrOf
(v T)
components/model/agenticark/utils.go:50
↓ 56 callersMethodError
()
components/model/agenticopenai/utils.go:61
↓ 56 callersFunctionsetItemStatus
(block *schema.ContentBlock, status string)
components/model/agenticopenai/responses_content_block_extra.go:56
↓ 55 callersMethodError
()
components/model/agenticark/utils.go:63
↓ 54 callersFunctiongetItemID
(block *schema.ContentBlock)
components/model/agenticopenai/responses_content_block_extra.go:39
↓ 52 callersMethodInvoke
(ctx context.Context, input reflect.Value, opts ...compose.Option)
devops/internal/model/runnable.go:31
↓ 50 callersMethodBuildRequest
BuildRequest generates the search request body based on the configuration and query.
components/retriever/opensearch3/retriever.go:59
↓ 48 callersMethodOnEnd
(ctx context.Context, info *callbacks.RunInfo, output callbacks.CallbackOutput)
callbacks/cozeloop/callback.go:68
↓ 47 callersMethodReadFile
(ctx context.Context, path string)
components/tool/commandline/operator.go:45
↓ 47 callersMethodgetBlockIndex
(key string)
components/model/agenticopenai/responses_event_convertor.go:289
↓ 45 callersFunctionUnmarshalJson
(b []byte, rt reflect.Type)
devops/internal/model/types.go:105
↓ 40 callersFunctionsetItemID
(block *schema.ContentBlock, itemID string)
components/model/agenticark/content_block_extra.go:42
↓ 38 callersMethodWriteFile
(ctx context.Context, path string, content string)
components/tool/commandline/operator.go:46
↓ 37 callersFunctionBuildDevGraph
(gi *GraphInfo, fromNode string)
devops/internal/model/container.go:80
↓ 37 callersFunctionstrPtr
(s string)
components/prompt/cozeloop/prompthub_test.go:29
↓ 36 callersMethodDo
(request *http.Request)
callbacks/cozeloop/callback_test.go:40
↓ 36 callersMethodsendBlock
(block *schema.ContentBlock, err error)
components/model/agenticark/event_convertor.go:265
↓ 35 callersMethodgetBlockIndex
(key string)
components/model/agenticark/event_convertor.go:322
↓ 35 callersFunctionptrWithoutZero
(v T)
components/retriever/es8/search_mode/utils.go:50
↓ 34 callersMethodAdd
(ctx context.Context, item esutil.BulkIndexerItem)
components/indexer/es8/indexer_test.go:276
↓ 34 callersMethodStore
Store adds the provided documents to the Elasticsearch index.
components/indexer/es7/indexer.go:149
↓ 34 callersFunctionValidateInputReflectTypeSupported
(typ reflect.Type)
devops/internal/utils/generic/type_utils.go:92
↓ 34 callersMethodWriteHeader
(statusCode int)
devops/internal/apihandler/server_test.go:67
↓ 33 callersFunctionGetItemStatus
(block *schema.ContentBlock)
components/model/agenticopenai/responses_content_block_extra.go:60
↓ 33 callersFunctioncollectUpdates
collectUpdates drains an iter.Seq2 into slices for assertion.
acp/conv_test.go:32
↓ 32 callersFunctionnewOpenaiStrOpt
(optVal string)
components/model/agenticopenai/utils.go:34
↓ 32 callersMethodsendBlock
(block *schema.ContentBlock, err error)
components/model/agenticopenai/responses_event_convertor.go:231
↓ 31 callersFunctionintPtr
(i int)
components/tool/searxng/searxng_test.go:598
↓ 31 callersFunctionnewStreamReceiver
()
components/model/agenticark/event_convertor.go:309
↓ 31 callersMethodtoArkContent
(msg *schema.Message)
components/model/ark/chat_completion_api.go:622
↓ 30 callersFunctionRegisterType
(rt reflect.Type)
devops/internal/model/types.go:92
↓ 29 callersMethodError
()
components/model/deepseek/deepseek.go:950
↓ 29 callersFunctionparseAny
(ctx context.Context, v any, bStream bool)
callbacks/cozeloop/data_parser.go:661
↓ 28 callersFunctionAgentEventToSessionUpdate
AgentEventToSessionUpdate converts an eino AgentEvent into a sequence of ACP SessionUpdate notifications. It handles message output (both streaming an
acp/conv.go:99
↓ 28 callersFunctionNewClient
(cfg *ClientConfig)
components/tool/searxng/searxng.go:288
↓ 27 callersMethodParseOutput
(ctx context.Context, info *callbacks.RunInfo, output callbacks.CallbackOutput)
callbacks/cozeloop/data_parser.go:184
↓ 26 callersMethodError
()
libs/acl/openai/chat_model.go:1437
↓ 26 callersMethodRun
Run starts the janitor in a new goroutine
components/tool/bingsearch/internal/bingcore/cache.go:32
↓ 26 callersFunctionsetItemStatus
(block *schema.ContentBlock, status string)
components/model/agenticark/content_block_extra.go:55
↓ 26 callersMethodtoEntity
toEntity converts MetricType to the Milvus SDK entity.MetricType type.
components/indexer/milvus2/types.go:106
↓ 25 callersMethodErr
()
components/model/agenticopenai/responses_model_test.go:281
↓ 25 callersMethodError
()
components/model/claude/claude.go:1573
↓ 25 callersMethodapply
(cfg *config)
libs/acl/opentelemetry/option.go:29
↓ 25 callersFunctionptrIfNonZero
(v T)
components/model/agenticark/utils.go:28
↓ 25 callersFunctionsetupTestDir
(t *testing.T)
adk/backend/local/local_test.go:38
↓ 24 callersMethodWrite
Write creates file content.
adk/backend/agentkit/sandbox.go:554
↓ 24 callersFunctionconvertAgenticModelMessage
(message *schema.AgenticMessage)
callbacks/cozeloop/convert.go:460
↓ 22 callersMethodClose
()
components/model/agenticopenai/responses_model_test.go:191
↓ 22 callersMethodError
()
components/model/agenticclaude/utils.go:54
↓ 22 callersMethodNext
()
components/model/agenticopenai/responses_model_test.go:176
↓ 21 callersFunctionGetThoughtSignatureFromExtra
GetThoughtSignatureFromExtra tries to read thought_signature from an Extra map. thought_signature should be read from: - message.AssistantGenMultiCon
components/model/gemini/message_extra.go:209
↓ 21 callersFunctionNewIndexer
NewIndexer creates a new ES7 indexer with the provided configuration.
components/indexer/es7/indexer.go:93
↓ 21 callersFunctionconvSchemaMessage
(message *schema.Message)
components/model/claude/claude.go:989
↓ 21 callersMethodconvert
(msg *schema.Message)
libs/acl/openai/agentic_convert.go:134
↓ 20 callersMethodWithTools
(functionTools []*schema.ToolInfo)
components/model/agenticark/model.go:384
↓ 20 callersMethodWrite
(b []byte)
components/tool/commandline/sandbox/sandbox_test.go:333
↓ 20 callersFunctioncreateContentBlockFromType
(t schema.ContentBlockType)
components/model/agenticgemini/conv.go:707
↓ 19 callersFunctionmustJSON
(t *testing.T, v any)
components/model/agenticclaude/convertor_test.go:644
↓ 18 callersMethodConvCallbackOutput
(src callbacks.CallbackOutput)
devops/internal/service/call_option.go:292
↓ 18 callersMethodExecute
Execute performs file operations command
components/tool/commandline/editor.go:190
↓ 18 callersMethodRetrieve
Retrieve searches for documents in Elasticsearch matching the given query.
components/retriever/es8/retriever.go:101
↓ 18 callersFunctioncoalesce
(x, y T)
components/model/agenticopenai/utils.go:41
↓ 18 callersFunctioninputPartToContentBlock
(part schema.MessageInputPart)
acp/conv.go:465
↓ 18 callersFunctionnewMockBackend
newMockBackend creates a Backend with a mock connection and shell wired up.
acp/backend_test.go:602
↓ 18 callersFunctiontoOllamaMessage
(einoMsg *schema.Message)
components/model/ollama/chatmodel.go:348
↓ 17 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
libs/acl/langfuse/mock/langfuse_mock.go:49
↓ 17 callersFunctionNewBackend
NewBackend creates a new local filesystem Local instance. IMPORTANT - System Compatibility: - Supported: Unix/MacOS only - NOT Supported: Windows (re
adk/backend/local/local.go:270
↓ 17 callersFunctioncreateMockResponse
createMockResponse is a helper to build a valid JSON response for the mock API.
adk/backend/agentkit/sandbox_test.go:148
↓ 17 callersFunctionnewStreamConverter
()
components/model/agenticclaude/event_convertor.go:33
↓ 16 callersMethodName
()
devops/internal/model/runnable_test.go:32
↓ 16 callersFunctionNewIndexer
NewIndexer creates a new indexer.
components/indexer/milvus/indexer.go:90
↓ 16 callersMethodOnEndWithStreamOutput
(ctx context.Context, info *callbacks.RunInfo, output *schema.StreamReader[callbacks.CallbackOutput])
callbacks/cozeloop/callback.go:107
↓ 16 callersMethodaddMessages
(messages ...*tracespec.ModelMessage)
callbacks/cozeloop/trace_handler.go:75
↓ 16 callersFunctionagenticMessagesToMessages
(in []*schema.AgenticMessage)
libs/acl/openai/agentic_convert.go:26
↓ 16 callersFunctionconvSchemaMessage
(message *schema.Message)
components/model/gemini/gemini.go:782
↓ 16 callersFunctiondereferenceOrZero
(v *T)
components/model/ark/utils.go:29
↓ 16 callersMethodgenMessageNewParams
(input []*schema.Message, opts ...model.Option)
components/model/claude/claude.go:583
↓ 16 callersFunctiongetItemID
(block *schema.ContentBlock)
components/model/agenticark/content_block_extra.go:46
↓ 16 callersFunctionoutputPartToSessionUpdate
(part schema.MessageOutputPart)
acp/conv.go:527
↓ 16 callersFunctionptrWithoutZero
(v T)
components/retriever/es9/search_mode/utils.go:50
next →1–100 of 4,194, ranked by callers