Documentation
¶
Overview ¶
Package providers implements various LLM providers and their utility functions. This file contains the Volcengine provider implementation.
Index ¶
- type VolcengineProvider
- func (provider *VolcengineProvider) BatchCancel(_ *schemas.BifrostContext, _ []schemas.Key, ...) (*schemas.BifrostBatchCancelResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) BatchCreate(_ *schemas.BifrostContext, _ schemas.Key, _ *schemas.BifrostBatchCreateRequest) (*schemas.BifrostBatchCreateResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) BatchDelete(_ *schemas.BifrostContext, _ []schemas.Key, ...) (*schemas.BifrostBatchDeleteResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) BatchList(_ *schemas.BifrostContext, _ []schemas.Key, _ *schemas.BifrostBatchListRequest) (*schemas.BifrostBatchListResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) BatchResults(_ *schemas.BifrostContext, _ []schemas.Key, ...) (*schemas.BifrostBatchResultsResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) BatchRetrieve(_ *schemas.BifrostContext, _ []schemas.Key, ...) (*schemas.BifrostBatchRetrieveResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) ChatCompletion(ctx *schemas.BifrostContext, key schemas.Key, ...) (*schemas.BifrostChatResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) ChatCompletionStream(ctx *schemas.BifrostContext, postHookRunner schemas.PostHookRunner, ...) (chan *schemas.BifrostStreamChunk, *schemas.BifrostError)
- func (provider *VolcengineProvider) ContainerCreate(_ *schemas.BifrostContext, _ schemas.Key, ...) (*schemas.BifrostContainerCreateResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) ContainerDelete(_ *schemas.BifrostContext, _ []schemas.Key, ...) (*schemas.BifrostContainerDeleteResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) ContainerFileContent(_ *schemas.BifrostContext, _ []schemas.Key, ...) (*schemas.BifrostContainerFileContentResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) ContainerFileCreate(_ *schemas.BifrostContext, _ schemas.Key, ...) (*schemas.BifrostContainerFileCreateResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) ContainerFileDelete(_ *schemas.BifrostContext, _ []schemas.Key, ...) (*schemas.BifrostContainerFileDeleteResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) ContainerFileList(_ *schemas.BifrostContext, _ []schemas.Key, ...) (*schemas.BifrostContainerFileListResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) ContainerFileRetrieve(_ *schemas.BifrostContext, _ []schemas.Key, ...) (*schemas.BifrostContainerFileRetrieveResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) ContainerList(_ *schemas.BifrostContext, _ []schemas.Key, ...) (*schemas.BifrostContainerListResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) ContainerRetrieve(_ *schemas.BifrostContext, _ []schemas.Key, ...) (*schemas.BifrostContainerRetrieveResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) CountTokens(_ *schemas.BifrostContext, _ schemas.Key, _ *schemas.BifrostResponsesRequest) (*schemas.BifrostCountTokensResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) Embedding(ctx *schemas.BifrostContext, key schemas.Key, ...) (*schemas.BifrostEmbeddingResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) FileContent(ctx *schemas.BifrostContext, keys []schemas.Key, ...) (*schemas.BifrostFileContentResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) FileDelete(ctx *schemas.BifrostContext, keys []schemas.Key, ...) (*schemas.BifrostFileDeleteResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) FileList(ctx *schemas.BifrostContext, keys []schemas.Key, ...) (*schemas.BifrostFileListResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) FileRetrieve(ctx *schemas.BifrostContext, keys []schemas.Key, ...) (*schemas.BifrostFileRetrieveResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) FileUpload(ctx *schemas.BifrostContext, key schemas.Key, ...) (*schemas.BifrostFileUploadResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) GetProviderKey() schemas.ModelProvider
- func (provider *VolcengineProvider) ImageEdit(ctx *schemas.BifrostContext, key schemas.Key, ...) (*schemas.BifrostImageGenerationResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) ImageEditStream(ctx *schemas.BifrostContext, postHookRunner schemas.PostHookRunner, ...) (chan *schemas.BifrostStreamChunk, *schemas.BifrostError)
- func (provider *VolcengineProvider) ImageGeneration(ctx *schemas.BifrostContext, key schemas.Key, ...) (*schemas.BifrostImageGenerationResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) ImageGenerationStream(ctx *schemas.BifrostContext, postHookRunner schemas.PostHookRunner, ...) (chan *schemas.BifrostStreamChunk, *schemas.BifrostError)
- func (provider *VolcengineProvider) ImageVariation(ctx *schemas.BifrostContext, key schemas.Key, ...) (*schemas.BifrostImageGenerationResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) ListModels(ctx *schemas.BifrostContext, keys []schemas.Key, ...) (*schemas.BifrostListModelsResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) OCR(ctx *schemas.BifrostContext, key schemas.Key, ...) (*schemas.BifrostOCRResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) Passthrough(_ *schemas.BifrostContext, _ schemas.Key, _ *schemas.BifrostPassthroughRequest) (*schemas.BifrostPassthroughResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) PassthroughStream(_ *schemas.BifrostContext, _ schemas.PostHookRunner, _ func(context.Context), ...) (chan *schemas.BifrostStreamChunk, *schemas.BifrostError)
- func (provider *VolcengineProvider) Rerank(ctx *schemas.BifrostContext, key schemas.Key, ...) (*schemas.BifrostRerankResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) Responses(ctx *schemas.BifrostContext, key schemas.Key, ...) (*schemas.BifrostResponsesResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) ResponsesStream(ctx *schemas.BifrostContext, postHookRunner schemas.PostHookRunner, ...) (chan *schemas.BifrostStreamChunk, *schemas.BifrostError)
- func (provider *VolcengineProvider) Speech(ctx *schemas.BifrostContext, key schemas.Key, ...) (*schemas.BifrostSpeechResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) SpeechStream(ctx *schemas.BifrostContext, postHookRunner schemas.PostHookRunner, ...) (chan *schemas.BifrostStreamChunk, *schemas.BifrostError)
- func (provider *VolcengineProvider) TextCompletion(ctx *schemas.BifrostContext, key schemas.Key, ...) (*schemas.BifrostTextCompletionResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) TextCompletionStream(ctx *schemas.BifrostContext, postHookRunner schemas.PostHookRunner, ...) (chan *schemas.BifrostStreamChunk, *schemas.BifrostError)
- func (provider *VolcengineProvider) Transcription(ctx *schemas.BifrostContext, key schemas.Key, ...) (*schemas.BifrostTranscriptionResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) TranscriptionStream(ctx *schemas.BifrostContext, postHookRunner schemas.PostHookRunner, ...) (chan *schemas.BifrostStreamChunk, *schemas.BifrostError)
- func (provider *VolcengineProvider) VideoDelete(ctx *schemas.BifrostContext, key schemas.Key, ...) (*schemas.BifrostVideoDeleteResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) VideoDownload(ctx *schemas.BifrostContext, key schemas.Key, ...) (*schemas.BifrostVideoDownloadResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) VideoGeneration(ctx *schemas.BifrostContext, key schemas.Key, ...) (*schemas.BifrostVideoGenerationResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) VideoList(ctx *schemas.BifrostContext, key schemas.Key, ...) (*schemas.BifrostVideoListResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) VideoRemix(_ *schemas.BifrostContext, _ schemas.Key, _ *schemas.BifrostVideoRemixRequest) (*schemas.BifrostVideoGenerationResponse, *schemas.BifrostError)
- func (provider *VolcengineProvider) VideoRetrieve(ctx *schemas.BifrostContext, key schemas.Key, ...) (*schemas.BifrostVideoGenerationResponse, *schemas.BifrostError)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type VolcengineProvider ¶
type VolcengineProvider struct {
// contains filtered or unexported fields
}
VolcengineProvider implements the Provider interface for Volcengine's API.
func NewModelArkProvider ¶
func NewModelArkProvider(config *schemas.ProviderConfig, logger schemas.Logger) (*VolcengineProvider, error)
NewModelArkProvider creates a new ModelArk provider instance. ModelArk uses the BytePlus-hosted international ARK endpoint but otherwise shares Volcengine behavior.
func NewVolcengineProvider ¶
func NewVolcengineProvider(config *schemas.ProviderConfig, logger schemas.Logger) (*VolcengineProvider, error)
NewVolcengineProvider creates a new Volcengine provider instance. It initializes the HTTP client with the provided configuration and sets up response pools. The client is configured with timeouts, concurrency limits, and optional proxy settings.
func (*VolcengineProvider) BatchCancel ¶
func (provider *VolcengineProvider) BatchCancel(_ *schemas.BifrostContext, _ []schemas.Key, _ *schemas.BifrostBatchCancelRequest) (*schemas.BifrostBatchCancelResponse, *schemas.BifrostError)
BatchCancel is not supported by Volcengine provider.
func (*VolcengineProvider) BatchCreate ¶
func (provider *VolcengineProvider) BatchCreate(_ *schemas.BifrostContext, _ schemas.Key, _ *schemas.BifrostBatchCreateRequest) (*schemas.BifrostBatchCreateResponse, *schemas.BifrostError)
BatchCreate is not supported by Volcengine provider.
func (*VolcengineProvider) BatchDelete ¶
func (provider *VolcengineProvider) BatchDelete(_ *schemas.BifrostContext, _ []schemas.Key, _ *schemas.BifrostBatchDeleteRequest) (*schemas.BifrostBatchDeleteResponse, *schemas.BifrostError)
BatchDelete is not supported by Volcengine provider.
func (*VolcengineProvider) BatchList ¶
func (provider *VolcengineProvider) BatchList(_ *schemas.BifrostContext, _ []schemas.Key, _ *schemas.BifrostBatchListRequest) (*schemas.BifrostBatchListResponse, *schemas.BifrostError)
BatchList is not supported by Volcengine provider.
func (*VolcengineProvider) BatchResults ¶
func (provider *VolcengineProvider) BatchResults(_ *schemas.BifrostContext, _ []schemas.Key, _ *schemas.BifrostBatchResultsRequest) (*schemas.BifrostBatchResultsResponse, *schemas.BifrostError)
BatchResults is not supported by Volcengine provider.
func (*VolcengineProvider) BatchRetrieve ¶
func (provider *VolcengineProvider) BatchRetrieve(_ *schemas.BifrostContext, _ []schemas.Key, _ *schemas.BifrostBatchRetrieveRequest) (*schemas.BifrostBatchRetrieveResponse, *schemas.BifrostError)
BatchRetrieve is not supported by Volcengine provider.
func (*VolcengineProvider) ChatCompletion ¶
func (provider *VolcengineProvider) ChatCompletion(ctx *schemas.BifrostContext, key schemas.Key, request *schemas.BifrostChatRequest) (*schemas.BifrostChatResponse, *schemas.BifrostError)
ChatCompletion performs a chat completion request to the Volcengine API.
func (*VolcengineProvider) ChatCompletionStream ¶
func (provider *VolcengineProvider) ChatCompletionStream(ctx *schemas.BifrostContext, postHookRunner schemas.PostHookRunner, postHookSpanFinalizer func(context.Context), key schemas.Key, request *schemas.BifrostChatRequest) (chan *schemas.BifrostStreamChunk, *schemas.BifrostError)
ChatCompletionStream performs a streaming chat completion request to the Volcengine API. It supports real-time streaming of responses using Server-Sent Events (SSE). Uses Volcengine's OpenAI-compatible streaming format. Returns a channel containing BifrostStreamChunk objects representing the stream or an error if the request fails.
func (*VolcengineProvider) ContainerCreate ¶
func (provider *VolcengineProvider) ContainerCreate(_ *schemas.BifrostContext, _ schemas.Key, _ *schemas.BifrostContainerCreateRequest) (*schemas.BifrostContainerCreateResponse, *schemas.BifrostError)
ContainerCreate is not supported by the Volcengine provider.
func (*VolcengineProvider) ContainerDelete ¶
func (provider *VolcengineProvider) ContainerDelete(_ *schemas.BifrostContext, _ []schemas.Key, _ *schemas.BifrostContainerDeleteRequest) (*schemas.BifrostContainerDeleteResponse, *schemas.BifrostError)
ContainerDelete is not supported by the Volcengine provider.
func (*VolcengineProvider) ContainerFileContent ¶
func (provider *VolcengineProvider) ContainerFileContent(_ *schemas.BifrostContext, _ []schemas.Key, _ *schemas.BifrostContainerFileContentRequest) (*schemas.BifrostContainerFileContentResponse, *schemas.BifrostError)
ContainerFileContent is not supported by the Volcengine provider.
func (*VolcengineProvider) ContainerFileCreate ¶
func (provider *VolcengineProvider) ContainerFileCreate(_ *schemas.BifrostContext, _ schemas.Key, _ *schemas.BifrostContainerFileCreateRequest) (*schemas.BifrostContainerFileCreateResponse, *schemas.BifrostError)
ContainerFileCreate is not supported by the Volcengine provider.
func (*VolcengineProvider) ContainerFileDelete ¶
func (provider *VolcengineProvider) ContainerFileDelete(_ *schemas.BifrostContext, _ []schemas.Key, _ *schemas.BifrostContainerFileDeleteRequest) (*schemas.BifrostContainerFileDeleteResponse, *schemas.BifrostError)
ContainerFileDelete is not supported by the Volcengine provider.
func (*VolcengineProvider) ContainerFileList ¶
func (provider *VolcengineProvider) ContainerFileList(_ *schemas.BifrostContext, _ []schemas.Key, _ *schemas.BifrostContainerFileListRequest) (*schemas.BifrostContainerFileListResponse, *schemas.BifrostError)
ContainerFileList is not supported by the Volcengine provider.
func (*VolcengineProvider) ContainerFileRetrieve ¶
func (provider *VolcengineProvider) ContainerFileRetrieve(_ *schemas.BifrostContext, _ []schemas.Key, _ *schemas.BifrostContainerFileRetrieveRequest) (*schemas.BifrostContainerFileRetrieveResponse, *schemas.BifrostError)
ContainerFileRetrieve is not supported by the Volcengine provider.
func (*VolcengineProvider) ContainerList ¶
func (provider *VolcengineProvider) ContainerList(_ *schemas.BifrostContext, _ []schemas.Key, _ *schemas.BifrostContainerListRequest) (*schemas.BifrostContainerListResponse, *schemas.BifrostError)
ContainerList is not supported by the Volcengine provider.
func (*VolcengineProvider) ContainerRetrieve ¶
func (provider *VolcengineProvider) ContainerRetrieve(_ *schemas.BifrostContext, _ []schemas.Key, _ *schemas.BifrostContainerRetrieveRequest) (*schemas.BifrostContainerRetrieveResponse, *schemas.BifrostError)
ContainerRetrieve is not supported by the Volcengine provider.
func (*VolcengineProvider) CountTokens ¶
func (provider *VolcengineProvider) CountTokens(_ *schemas.BifrostContext, _ schemas.Key, _ *schemas.BifrostResponsesRequest) (*schemas.BifrostCountTokensResponse, *schemas.BifrostError)
CountTokens is not supported by the Volcengine provider.
func (*VolcengineProvider) Embedding ¶
func (provider *VolcengineProvider) Embedding(ctx *schemas.BifrostContext, key schemas.Key, request *schemas.BifrostEmbeddingRequest) (*schemas.BifrostEmbeddingResponse, *schemas.BifrostError)
func (*VolcengineProvider) FileContent ¶
func (provider *VolcengineProvider) FileContent(ctx *schemas.BifrostContext, keys []schemas.Key, request *schemas.BifrostFileContentRequest) (*schemas.BifrostFileContentResponse, *schemas.BifrostError)
func (*VolcengineProvider) FileDelete ¶
func (provider *VolcengineProvider) FileDelete(ctx *schemas.BifrostContext, keys []schemas.Key, request *schemas.BifrostFileDeleteRequest) (*schemas.BifrostFileDeleteResponse, *schemas.BifrostError)
func (*VolcengineProvider) FileList ¶
func (provider *VolcengineProvider) FileList(ctx *schemas.BifrostContext, keys []schemas.Key, request *schemas.BifrostFileListRequest) (*schemas.BifrostFileListResponse, *schemas.BifrostError)
func (*VolcengineProvider) FileRetrieve ¶
func (provider *VolcengineProvider) FileRetrieve(ctx *schemas.BifrostContext, keys []schemas.Key, request *schemas.BifrostFileRetrieveRequest) (*schemas.BifrostFileRetrieveResponse, *schemas.BifrostError)
func (*VolcengineProvider) FileUpload ¶
func (provider *VolcengineProvider) FileUpload(ctx *schemas.BifrostContext, key schemas.Key, request *schemas.BifrostFileUploadRequest) (*schemas.BifrostFileUploadResponse, *schemas.BifrostError)
func (*VolcengineProvider) GetProviderKey ¶
func (provider *VolcengineProvider) GetProviderKey() schemas.ModelProvider
GetProviderKey returns the provider identifier for Volcengine.
func (*VolcengineProvider) ImageEdit ¶
func (provider *VolcengineProvider) ImageEdit(ctx *schemas.BifrostContext, key schemas.Key, request *schemas.BifrostImageEditRequest) (*schemas.BifrostImageGenerationResponse, *schemas.BifrostError)
ImageEdit is not supported by the Volcengine provider.
func (*VolcengineProvider) ImageEditStream ¶
func (provider *VolcengineProvider) ImageEditStream(ctx *schemas.BifrostContext, postHookRunner schemas.PostHookRunner, postHookSpanFinalizer func(context.Context), key schemas.Key, request *schemas.BifrostImageEditRequest) (chan *schemas.BifrostStreamChunk, *schemas.BifrostError)
ImageEditStream is not supported by the Volcengine provider.
func (*VolcengineProvider) ImageGeneration ¶
func (provider *VolcengineProvider) ImageGeneration(ctx *schemas.BifrostContext, key schemas.Key, request *schemas.BifrostImageGenerationRequest) (*schemas.BifrostImageGenerationResponse, *schemas.BifrostError)
func (*VolcengineProvider) ImageGenerationStream ¶
func (provider *VolcengineProvider) ImageGenerationStream(ctx *schemas.BifrostContext, postHookRunner schemas.PostHookRunner, postHookSpanFinalizer func(context.Context), key schemas.Key, request *schemas.BifrostImageGenerationRequest) (chan *schemas.BifrostStreamChunk, *schemas.BifrostError)
ImageGenerationStream is not supported by the Volcengine provider.
func (*VolcengineProvider) ImageVariation ¶
func (provider *VolcengineProvider) ImageVariation(ctx *schemas.BifrostContext, key schemas.Key, request *schemas.BifrostImageVariationRequest) (*schemas.BifrostImageGenerationResponse, *schemas.BifrostError)
ImageVariation is not supported by the Volcengine provider.
func (*VolcengineProvider) ListModels ¶
func (provider *VolcengineProvider) ListModels(ctx *schemas.BifrostContext, keys []schemas.Key, request *schemas.BifrostListModelsRequest) (*schemas.BifrostListModelsResponse, *schemas.BifrostError)
ListModels performs a list models request to Volcengine's API.
func (*VolcengineProvider) OCR ¶ added in v1.4.20
func (provider *VolcengineProvider) OCR(ctx *schemas.BifrostContext, key schemas.Key, request *schemas.BifrostOCRRequest) (*schemas.BifrostOCRResponse, *schemas.BifrostError)
OCR is not supported by the Volcengine provider.
func (*VolcengineProvider) Passthrough ¶
func (provider *VolcengineProvider) Passthrough(_ *schemas.BifrostContext, _ schemas.Key, _ *schemas.BifrostPassthroughRequest) (*schemas.BifrostPassthroughResponse, *schemas.BifrostError)
Passthrough is not supported by the Volcengine provider.
func (*VolcengineProvider) PassthroughStream ¶
func (provider *VolcengineProvider) PassthroughStream(_ *schemas.BifrostContext, _ schemas.PostHookRunner, _ func(context.Context), _ schemas.Key, _ *schemas.BifrostPassthroughRequest) (chan *schemas.BifrostStreamChunk, *schemas.BifrostError)
PassthroughStream is not supported by the Volcengine provider.
func (*VolcengineProvider) Rerank ¶
func (provider *VolcengineProvider) Rerank(ctx *schemas.BifrostContext, key schemas.Key, request *schemas.BifrostRerankRequest) (*schemas.BifrostRerankResponse, *schemas.BifrostError)
Rerank is not supported by the Volcengine provider.
func (*VolcengineProvider) Responses ¶
func (provider *VolcengineProvider) Responses(ctx *schemas.BifrostContext, key schemas.Key, request *schemas.BifrostResponsesRequest) (*schemas.BifrostResponsesResponse, *schemas.BifrostError)
Responses performs a responses request to the Volcengine API.
func (*VolcengineProvider) ResponsesStream ¶
func (provider *VolcengineProvider) ResponsesStream(ctx *schemas.BifrostContext, postHookRunner schemas.PostHookRunner, postHookSpanFinalizer func(context.Context), key schemas.Key, request *schemas.BifrostResponsesRequest) (chan *schemas.BifrostStreamChunk, *schemas.BifrostError)
ResponsesStream performs a streaming responses request to the Volcengine API.
func (*VolcengineProvider) Speech ¶
func (provider *VolcengineProvider) Speech(ctx *schemas.BifrostContext, key schemas.Key, request *schemas.BifrostSpeechRequest) (*schemas.BifrostSpeechResponse, *schemas.BifrostError)
Speech is not supported by the Volcengine provider.
func (*VolcengineProvider) SpeechStream ¶
func (provider *VolcengineProvider) SpeechStream(ctx *schemas.BifrostContext, postHookRunner schemas.PostHookRunner, postHookSpanFinalizer func(context.Context), key schemas.Key, request *schemas.BifrostSpeechRequest) (chan *schemas.BifrostStreamChunk, *schemas.BifrostError)
SpeechStream is not supported by the Volcengine provider.
func (*VolcengineProvider) TextCompletion ¶
func (provider *VolcengineProvider) TextCompletion(ctx *schemas.BifrostContext, key schemas.Key, request *schemas.BifrostTextCompletionRequest) (*schemas.BifrostTextCompletionResponse, *schemas.BifrostError)
TextCompletion performs a text completion request to the Volcengine API.
func (*VolcengineProvider) TextCompletionStream ¶
func (provider *VolcengineProvider) TextCompletionStream(ctx *schemas.BifrostContext, postHookRunner schemas.PostHookRunner, postHookSpanFinalizer func(context.Context), key schemas.Key, request *schemas.BifrostTextCompletionRequest) (chan *schemas.BifrostStreamChunk, *schemas.BifrostError)
TextCompletionStream performs a streaming text completion request to Volcengine's API. It formats the request, sends it to Volcengine, and processes the response. Returns a channel of BifrostStreamChunk objects or an error if the request fails.
func (*VolcengineProvider) Transcription ¶
func (provider *VolcengineProvider) Transcription(ctx *schemas.BifrostContext, key schemas.Key, request *schemas.BifrostTranscriptionRequest) (*schemas.BifrostTranscriptionResponse, *schemas.BifrostError)
Transcription is not supported by the Volcengine provider.
func (*VolcengineProvider) TranscriptionStream ¶
func (provider *VolcengineProvider) TranscriptionStream(ctx *schemas.BifrostContext, postHookRunner schemas.PostHookRunner, postHookSpanFinalizer func(context.Context), key schemas.Key, request *schemas.BifrostTranscriptionRequest) (chan *schemas.BifrostStreamChunk, *schemas.BifrostError)
TranscriptionStream is not supported by the Volcengine provider.
func (*VolcengineProvider) VideoDelete ¶
func (provider *VolcengineProvider) VideoDelete(ctx *schemas.BifrostContext, key schemas.Key, request *schemas.BifrostVideoDeleteRequest) (*schemas.BifrostVideoDeleteResponse, *schemas.BifrostError)
func (*VolcengineProvider) VideoDownload ¶
func (provider *VolcengineProvider) VideoDownload(ctx *schemas.BifrostContext, key schemas.Key, request *schemas.BifrostVideoDownloadRequest) (*schemas.BifrostVideoDownloadResponse, *schemas.BifrostError)
func (*VolcengineProvider) VideoGeneration ¶
func (provider *VolcengineProvider) VideoGeneration(ctx *schemas.BifrostContext, key schemas.Key, request *schemas.BifrostVideoGenerationRequest) (*schemas.BifrostVideoGenerationResponse, *schemas.BifrostError)
func (*VolcengineProvider) VideoList ¶
func (provider *VolcengineProvider) VideoList(ctx *schemas.BifrostContext, key schemas.Key, request *schemas.BifrostVideoListRequest) (*schemas.BifrostVideoListResponse, *schemas.BifrostError)
func (*VolcengineProvider) VideoRemix ¶
func (provider *VolcengineProvider) VideoRemix(_ *schemas.BifrostContext, _ schemas.Key, _ *schemas.BifrostVideoRemixRequest) (*schemas.BifrostVideoGenerationResponse, *schemas.BifrostError)
VideoRemix is not supported by Volcengine provider.
func (*VolcengineProvider) VideoRetrieve ¶
func (provider *VolcengineProvider) VideoRetrieve(ctx *schemas.BifrostContext, key schemas.Key, request *schemas.BifrostVideoRetrieveRequest) (*schemas.BifrostVideoGenerationResponse, *schemas.BifrostError)