Struct BedrockEmbedder 

pub struct BedrockEmbedder { /* private fields */ }

Embeddings through Amazon Bedrock’s InvokeModel.

Why this exists beside the OpenAI-compatible one

Bedrock is the deployment that cannot reach the other driver: a plane chosen for Bedrock was usually chosen because its data may not leave a particular account, and telling it to call api.openai.com for the query text is the one thing it cannot do. Without this, semantic retrieval was unavailable to exactly the regulated deployments this crate is built for — the AWS SDK already being paid for by the bedrock feature.

Implementations

impl BedrockEmbedder

pub async fn from_env( region: impl Into<String>, model: impl Into<String>, dialect: EmbeddingDialect, ) -> Result<Self, StoreError>

Load the standard AWS credential chain for this region.

The same chain Bedrock::from_env documents, Bedrock API keys included — they cover InvokeModel.

Errors

If the region is blank.

pub fn from_client( client: Client, model: impl Into<String>, dialect: EmbeddingDialect, ) -> Result<Self, StoreError>

Build from an already configured AWS client.

The region is read from the client, not accepted beside it. It is half of Embedder::revision, which decides whether a stored vector belongs to the index being queried — so a region taken as a separate argument is a second copy of a fact the client already holds, free to disagree with the service the vectors actually came from. Two indexes built in different regions would then share one revision and be treated as comparable.

Errors

If the client carries no region, or a blank one.

pub const fn dimensions(self, dimensions: u32) -> Self

Ask Titan for a shortened vector.

Titan v2 accepts 256, 512 or 1024. Cohere does not take the parameter at all, so setting it there is refused rather than ignored — a ceiling that silently does nothing is the shape this crate refuses everywhere else.

pub const fn pricing(self, pricing: Pricing) -> Self

What this model’s input tokens cost, so its calls count against a money ceiling.

Only Titan reports its input tokens on Bedrock, so a priced Cohere embedder refuses every call rather than reporting it free.

Trait Implementations

impl Clone for BedrockEmbedder

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for BedrockEmbedder

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

Formats the value using the given formatter.

impl Embedder for BedrockEmbedder

fn revision(&self) -> String

Region, model and width.

The region is in it because a Bedrock model id names a model, not a deployment: the same id in two regions is two services, and a vector from one has no standing in an index built from the other. It is also the fact a compliance reader most wants on the record.

fn pricing(&self) -> Option<Pricing>

What this service’s tokens cost, when the deployment stated it.

fn embed<'life0, 'life1, 'async_trait>( &'life0 self, text: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Embedded, StoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Embed one text.