MCPcopy Create free account

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

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

↓ 5 callersFunctionnewStreamMessageBuilder
(audio *Audio)
libs/acl/openai/chat_model.go:1170
↓ 5 callersFunctionnewThinkingServer
newThinkingServer creates a new instance of thinkingServer with initialized fields. Returns: A pointer to the newly created thinkingServer
components/tool/sequentialthinking/sequentialthinking.go:124
↓ 5 callersFunctionof
(t T)
components/model/qianfan/examples/generate_with_image/generate_with_image.go:82
↓ 5 callersFunctionpadEnd
padEnd pads the end of a string with spaces until it reaches the specified length. If the string is already longer than or equal to the specified leng
components/tool/sequentialthinking/util.go:28
↓ 5 callersMethodparseCustomOptions
(opts ...model.Option)
components/model/agenticopenai/chat_model.go:222
↓ 5 callersMethodparseSearchResult
(ctx context.Context, resp *opensearchapi.SearchResp)
components/retriever/opensearch3/retriever.go:164
↓ 5 callersMethodpopulateCache
(in []*schema.AgenticMessage, responseReq *responses.ResponsesRequest, arkOpts *arkOptions)
components/model/agenticark/model.go:689
↓ 5 callersMethodpopulateTools
(responseReq *responses.ResponsesRequest, options *model.Options, specOptions *arkOptions)
components/model/agenticark/model.go:832
↓ 5 callersFunctionresolveMultiModalReadConfig
resolveMultiModalReadConfig fills any zero/negative field of cfg with the corresponding package default, then clamps each field to its hard-cap. The r
adk/backend/agentkit/sandbox.go:227
↓ 5 callersFunctionresolveMultiModalReadConfig
resolveMultiModalReadConfig fills any zero/negative field of cfg with the corresponding package default, then clamps each field to its hard-cap. The r
adk/backend/local/local.go:213
↓ 5 callersFunctionserializeAgentEvent
(_ context.Context, event *adk.AgentEvent)
callbacks/cozeloop/data_parser.go:840
↓ 5 callersFunctionserializeInterruptInfo
(info *adk.InterruptInfo)
callbacks/cozeloop/data_parser.go:927
↓ 5 callersFunctionserverToolUseToContentBlock
(block anthropic.ServerToolUseBlock)
components/model/agenticclaude/convertor.go:617
↓ 5 callersFunctionsetMsgExtra
(msg *schema.Message, key string, value any)
components/model/claude/message_extra.go:118
↓ 5 callersFunctionsetReasoningContent
(msg *schema.Message, reasoningContent string)
components/model/ark/message_extra.go:119
↓ 5 callersFunctionsetReasoningDetails
(msg *schema.Message, reasoningDetails []*reasoningDetails)
components/model/openrouter/message_extra.go:103
↓ 5 callersFunctionshellCallToContentBlock
(item responses.ResponseFunctionShellToolCall)
components/model/agenticopenai/responses_convertor.go:2027
↓ 5 callersFunctionshellOutputToContentBlock
(item responses.ResponseFunctionShellToolCallOutput)
components/model/agenticopenai/responses_convertor.go:2077
↓ 5 callersFunctionshellQuote
shellQuote wraps s in single quotes for safe inclusion in a sh/bash/zsh command. It rejects strings containing null bytes, which shells cannot represe
acp/backend.go:733
↓ 5 callersFunctionstreamToEinoTokenUsage
(usage *deepseek.StreamUsage)
components/model/deepseek/deepseek.go:879
↓ 5 callersFunctiontoAnthropicTextCitations
(citations []*claude.TextCitation)
components/model/agenticclaude/convertor.go:1301
↓ 5 callersMethodtoArkAssistantRoleItemInputMessage
(msg *schema.Message)
components/model/ark/responses_api.go:824
↓ 5 callersFunctiontoAssistantTextExtension
(citations []anthropic.TextCitationUnion)
components/model/agenticclaude/convertor.go:1279
↓ 5 callersFunctiontoFunctionTools
(functionTools []*schema.ToolInfo)
components/model/agenticclaude/convertor.go:474
↓ 5 callersFunctiontoMessageToolCalls
(toolCalls []deepseek.ToolCall)
components/model/deepseek/deepseek.go:483
↓ 5 callersFunctiontoModelCallbackUsage
(respMeta *schema.ResponseMeta)
components/model/deepseek/deepseek.go:819
↓ 5 callersFunctiontoMultiOutPart
(part *genai.Part)
components/model/gemini/gemini.go:1309
↓ 5 callersFunctiontoOpenAIRole
(role schema.RoleType)
libs/acl/openai/chat_model.go:261
↓ 5 callersFunctiontoTools
(tis []*schema.ToolInfo)
libs/acl/openai/chat_model.go:1275
↓ 5 callersMethodtryConcatChunks
(chunks []any)
callbacks/cozeloop/data_parser.go:621
↓ 5 callersMethodvalidate
validate checks the ThoughtRequest for validity and consistency. Parameters: - input: The thought request to validate Returns: - td: The unmarshalled
components/tool/sequentialthinking/sequentialthinking.go:138
↓ 5 callersMethodvalidate
()
components/tool/searxng/searxng.go:114
↓ 5 callersFunctionvalidateEngines
validateEngines validates engines parameter, supports multiple engines
components/tool/searxng/searxng.go:207
↓ 5 callersFunctionvalidateMessagePartCommon
validateMessagePartCommon validates the URL / Base64Data branching rules shared by audio, image and video parts. partName is interpolated into error m
components/model/ark/chat_completion_api.go:455
↓ 5 callersFunctionvector2Bytes
(vector []float64)
components/retriever/redis/utils.go:39
↓ 5 callersFunctionwebFetchToolResultToContentBlock
(block anthropic.WebFetchToolResultBlock)
components/model/agenticclaude/convertor.go:847
↓ 5 callersMethodwebSearchPhaseToContentBlock
(itemID string, outputIdx int64, status string)
components/model/agenticopenai/responses_event_convertor.go:1047
↓ 5 callersFunctionwebSearchToolResultToContentBlock
(block anthropic.WebSearchToolResultBlock)
components/model/agenticclaude/convertor.go:805
↓ 4 callersMethodBuildGraphSchema
(graphName, graphID string)
devops/internal/model/container.go:159
↓ 4 callersMethodBuildSparseSearchOption
BuildSparseSearchOption creates a SearchOption configured for sparse vector search using text query.
components/retriever/milvus2/search_mode/sparse.go:69
↓ 4 callersMethodCreateCanvas
(graphID string)
devops/internal/service/container.go:38
↓ 4 callersMethodCreateDevGraph
(graphID, fromNode string)
devops/internal/service/container.go:166
↓ 4 callersMethodCreatePrefixCache
CreatePrefixCache assembles inputs the same as Generate/Stream and writes the final system instruction, tools, and messages into a reusable prefix cac
components/model/gemini/gemini.go:369
↓ 4 callersFunctionEnableMessageInputPartCacheControl
EnableMessageInputPartCacheControl enables cache control for a specific part of a user's message input. This allows for fine-grained control over how
components/model/openrouter/message_extra.go:199
↓ 4 callersFunctionEnableMessageOutputPartCacheControl
EnableMessageOutputPartCacheControl enables cache control for a specific part of an assistant's message output. This allows for fine-grained control o
components/model/openrouter/message_extra.go:218
↓ 4 callersMethodError
()
components/model/openai/types.go:45
↓ 4 callersMethodExecute
(ctx context.Context, input *filesystem.ExecuteRequest)
adk/backend/agentkit/sandbox.go:1156
↓ 4 callersMethodGenerate
(ctx context.Context, in []*schema.Message, opts ...fmodel.Option)
components/model/arkbot/chatmodel.go:253
↓ 4 callersMethodGenerate
(ctx context.Context, in []*schema.Message, opts ...model.Option)
components/model/qwen/chatmodel.go:221
↓ 4 callersMethodGet
(ctx context.Context, key string)
components/embedding/cache/redis/cacher.go:73
↓ 4 callersMethodGetCanvas
(graphID string)
devops/internal/service/container.go:39
↓ 4 callersFunctionGetReasoningContent
(msg *schema.Message)
libs/acl/openai/message_extra.go:62
↓ 4 callersFunctionGetResponseID
GetResponseID returns the response ID from the message. Available only for ResponsesAPI responses.
components/model/ark/message_extra.go:173
↓ 4 callersMethodGetType
()
components/model/agenticopenai/responses_model.go:378
↓ 4 callersMethodGetType
()
components/model/agenticark/model.go:401
↓ 4 callersFunctionNew
(_ context.Context, config *Config)
components/model/agenticark/model.go:160
↓ 4 callersFunctionNew
(ctx context.Context, cfg *Config)
components/model/agenticclaude/model.go:210
↓ 4 callersFunctionNew
New creates a new DDGS client with the given configuration
components/tool/duckduckgo/ddgsearch/client.go:78
↓ 4 callersFunctionNewAutoIndexBuilder
NewAutoIndexBuilder creates a new AutoIndexBuilder instance.
components/indexer/milvus2/index_builder.go:41
↓ 4 callersFunctionNewChatModel
(_ context.Context, config *ChatModelConfig)
components/model/ark/chatmodel.go:194
↓ 4 callersFunctionNewChatModel
NewChatModel creates a new Claude chat model instance Parameters: - ctx: The context for the operation - conf: Configuration for the Claude model Re
components/model/claude/claude.go:63
↓ 4 callersFunctionNewIndexer
(ctx context.Context, config *IndexerConfig)
components/indexer/volc_vikingdb/indexer.go:78
↓ 4 callersFunctionNewRetriever
(ctx context.Context, config *RetrieverConfig)
components/retriever/volc_vikingdb/retriever.go:91
↓ 4 callersFunctionNewRetriever
NewRetriever creates a new OpenSearch retriever with the provided configuration.
components/retriever/opensearch2/retriever.go:70
↓ 4 callersFunctionNewRetriever
NewRetriever creates a new OpenSearch retriever with the provided configuration.
components/retriever/opensearch3/retriever.go:69
↓ 4 callersFunctionNewSCANNIndexBuilder
NewSCANNIndexBuilder creates a new SCANNIndexBuilder with default parameters. Default: NList=128, WithRawData=true
components/indexer/milvus2/index_builder.go:219
↓ 4 callersFunctionNewXlsxParser
NewXlsxParser Create a new xlsxParser
components/document/parser/xlsx/xlsx_parser.go:54
↓ 4 callersMethodParse
Parse parses the XLSX content from io.Reader.
components/document/parser/xlsx/xlsx_parser.go:86
↓ 4 callersMethodRead
Read reads file content with support for line-based offset and limit.
adk/backend/agentkit/sandbox.go:435
↓ 4 callersMethodRetrieve
Retrieve performs the approximate vector search.
components/retriever/milvus2/search_mode/approximate.go:51
↓ 4 callersMethodRunCommand
RunCommand executes a command with explicit arguments (no shell involved)
components/tool/commandline/sandbox/sandbox.go:168
↓ 4 callersFunctionSafeDeepCopyMetadata
(original map[string]interface{})
callbacks/langsmith/utils.go:188
↓ 4 callersMethodSearch
Search performs a search with the given parameters
components/tool/duckduckgo/ddgsearch/search_text.go:29
↓ 4 callersFunctionSetToolInfoCacheControl
SetToolInfoCacheControl sets a cache control on a tool info. When a manual control is set, the top-level auto-cache will not override it.
components/model/agenticclaude/content_block_extra.go:90
↓ 4 callersMethodStream
(ctx context.Context, in []*schema.Message, opts ...model.Option)
components/model/deepseek/deepseek.go:273
↓ 4 callersMethodStream
(ctx context.Context, in []*schema.AgenticMessage, opts ...model.Option)
components/model/agenticqwen/model.go:206
↓ 4 callersMethodStream
(ctx context.Context, in []*schema.AgenticMessage, opts ...model.Option)
components/model/agenticdeepseek/model.go:164
↓ 4 callersMethodStream
(ctx context.Context, in []*schema.Message, opts ...model.Option)
components/model/openrouter/chatmodel.go:217
↓ 4 callersMethodStringToSpan
StringToSpan parse string to LangsmithState
callbacks/langsmith/flow_trace.go:127
↓ 4 callersMethodUpdateRun
(ctx context.Context, runID string, patch *RunPatch)
callbacks/langsmith/client.go:34
↓ 4 callersFunctionWithExtraFields
WithExtraFields sets extra fields to include in the request body. These fields will be merged into the top-level JSON request body, overriding any exi
components/model/agenticopenai/option.go:68
↓ 4 callersFunctionWithExtraFields
WithExtraFields returns a request-level option that merges the provided key/value pairs into the top-level JSON payload sent to the DeepSeek API. Key
components/model/deepseek/option.go:51
↓ 4 callersFunctionWithHeaders
WithHeaders configures gRPC requests headers for exported telemetry data
libs/acl/opentelemetry/option.go:146
↓ 4 callersFunctionWithReferenceExampleID
WithReferenceExampleID 关联到一个 example
callbacks/langsmith/trace.go:69
↓ 4 callersMethodWithTools
(tools []*schema.ToolInfo)
components/model/qwen/chatmodel.go:269
↓ 4 callersMethodWithTools
(tools []*schema.ToolInfo)
components/model/openrouter/chatmodel.go:449
↓ 4 callersFunctionbashCodeExecutionToolResultToBlockParam
(result *BashCodeExecutionResult, callID string)
components/model/agenticclaude/convertor.go:1058
↓ 4 callersFunctionbashCodeExecutionToolResultToContentBlock
(block anthropic.BashCodeExecutionToolResultBlock)
components/model/agenticclaude/convertor.go:927
↓ 4 callersFunctionbuildClient
(_ context.Context, config *Config)
components/tool/duckduckgo/v2/search.go:150
↓ 4 callersFunctionclearAnthropicAuthEnv
(t *testing.T)
components/model/agenticclaude/model_test.go:646
↓ 4 callersFunctionconcatDoubaoAppResults
(chunks []*DoubaoAppResult)
components/model/agenticark/extension.go:542
↓ 4 callersFunctionconcatFirst
(chunks []T)
components/model/agenticark/content_block_extra.go:103
↓ 4 callersFunctionconcatLast
(chunks []T)
components/model/agenticark/content_block_extra.go:111
↓ 4 callersFunctionconcatMessageArray
(mas [][]*schema.Message)
callbacks/apmplus/utils.go:116
↓ 4 callersFunctionconvInputMedia
(contents []schema.MessageInputPart)
components/model/gemini/gemini.go:895
↓ 4 callersFunctionconvMedia
(contents []schema.ChatMessagePart)
components/model/gemini/gemini.go:1063
↓ 4 callersFunctionconvMessagePartCommonToURL
(common schema.MessagePartCommon)
components/model/ark/responses_api.go:1550
↓ 4 callersFunctionconvResponse
(resp *genai.GenerateContentResponse)
components/model/gemini/gemini.go:1160
↓ 4 callersFunctionconvSchemaMessages
(messages []*schema.Message)
components/model/gemini/gemini.go:726
↓ 4 callersFunctionconvertAgenticModelOutput
(output *model.AgenticCallbackOutput)
callbacks/cozeloop/convert.go:441
← previousnext →501–600 of 4,194, ranked by callers