Struct EnhancedEmbeddings 

pub struct EnhancedEmbeddings<'client, E>
where
    E: OpenaiEnvironment + EnvironmentInterface + Send + Sync + 'static,
{ /* private fields */ }

Enhanced embeddings client with intelligent batching

Implementations

impl<'client, E> EnhancedEmbeddings<'client, E>

where E: OpenaiEnvironment + EnvironmentInterface + Send + Sync + 'static,

pub fn new(client: &'client Client<E>, config: BatchConfig) -> Self

Create new enhanced embeddings client with custom batching config

pub fn with_default_batching(client: &'client Client<E>) -> Self

Create new enhanced embeddings client with default batching

pub async fn create_direct( &self, request: CreateEmbeddingRequest, ) -> Result<CreateEmbeddingResponse>

Create embeddings directly without batching (fallback method)

Errors

Returns an error if the API request fails or if the response cannot be parsed.

pub async fn create_batched( &self, request: CreateEmbeddingRequest, ) -> Result<CreateEmbeddingResponse>

Create embeddings with automatic batching optimization

Errors

Returns an error if the request fails, batching fails, or if the response cannot be parsed.

pub async fn create_bulk( &self, texts: Vec<String>, model: String, ) -> Result<Vec<CreateEmbeddingResponse>>

Create multiple embeddings with optimal batching

Errors

Returns an error if any batch request fails or if responses cannot be parsed.

pub async fn get_metrics(&self) -> BatchMetrics

Get batching performance metrics

pub fn create_streaming( &self, texts: Vec<String>, model: String, ) -> Result<Receiver<Result<CreateEmbeddingResponse, OpenAIError>>>

Create streaming embeddings with batching

Errors

Returns an error if the streaming setup fails or if channel creation fails.

impl<E> EnhancedEmbeddings<'_, E>

where E: OpenaiEnvironment + EnvironmentInterface + Send + Sync + 'static,

pub async fn flush_pending(&self)

Flush all pending requests

Trait Implementations

impl<'client, E> Debug for EnhancedEmbeddings<'client, E>

where E: OpenaiEnvironment + EnvironmentInterface + Send + Sync + 'static + Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.