streamAndConcat is a helper function that streams responses and concatenates them.

DenseVectorSimilarity calculates the embedding similarity between a dense_vector field and the query using script_score. See: https://www.elastic.co/g

GetStreamTerminatedError retrieves the StreamTerminatedError from the message's extra data. It returns the error and a boolean indicating whether the

LsInfo lists file information under the given path.

NewChatModel creates a new Gemini chat model instance Parameters: - ctx: The context for the operation - cfg: Configuration for the Gemini model Ret

NewGPUCagraIndexBuilder creates a new GPUCagraIndexBuilder with default parameters. Default: IntermediateGraphDegree=128, GraphDegree=64

NewIndexer creates a new Milvus2 indexer with the provided configuration. It returns an error if the configuration is invalid.

NewS3Loader creates a new s3 loader.

NewSandboxToolBackend creates a new SandboxTool instance. SandboxTool refers to the sandbox running instance created by the sandbox tool in Volcengine

SetToolInfoCacheControl sets a cache breakpoint on the tool info with the given cache control settings. A nil CacheControl or zero-value TTL means the

Store adds the provided documents to the Elasticsearch index. It returns the list of IDs for the stored documents or an error.

WithCustomHeaders sets custom HTTP headers for the request.

WithRequestPayloadModifier registers a payload modifier to customize the serialized request based on input messages.

buildMessageFromAssistantGenMultiContent builds a ChatCompletionMessage from AssistantGenMultiContent. It processes text parts and a single audio part

clampInt returns def when v <= 0, max when v > max, otherwise v.

clampInt returns def when v <= 0, max when v > max, otherwise v.

isPDFExt checks if the file extension represents a PDF.