Struct BedrockProvider 

pub struct BedrockProvider { /* private fields */ }

Amazon Bedrock provider implementation.

Clone-able and cheap to copy (wraps an [Arc]-backed reqwest::Client).

Examples

use codetether_agent::provider::bedrock::{AwsCredentials, BedrockProvider};

let creds = AwsCredentials::from_environment().unwrap();
let p = BedrockProvider::with_credentials(creds, "us-west-2".into()).unwrap();
assert_eq!(p.region(), "us-west-2");

Implementations

impl BedrockProvider

pub async fn send_converse_request( &self, url: &str, body: &[u8], ) -> Result<Response>

Send a pre-formed POST request to any Bedrock runtime URL, signed with whichever auth mode is configured. Used by the thinker backend for direct URL access.

Arguments

• url — The full HTTPS URL to POST to.
• body — The serialized JSON request body.

Errors

Returns anyhow::Error if the network call fails.

Examples

use codetether_agent::provider::bedrock::{AwsCredentials, BedrockProvider};
let creds = AwsCredentials::from_environment().unwrap();
let p = BedrockProvider::with_credentials(creds, "us-west-2".into()).unwrap();
let url = "https://bedrock-runtime.us-west-2.amazonaws.com/model/amazon.nova-micro-v1:0/converse";
let resp = p.send_converse_request(url, b"{}" ).await.unwrap();
assert!(resp.status().is_client_error() || resp.status().is_success());

impl BedrockProvider

pub fn new(api_key: String) -> Result<Self>

Create a bearer-token provider in the default region.

Errors

Currently infallible, but returns Result for API symmetry with BedrockProvider::with_credentials and future validation needs.

Examples

use codetether_agent::provider::bedrock::BedrockProvider;
let p = BedrockProvider::new("token-abc".into()).unwrap();
assert_eq!(p.region(), "us-east-1");

pub fn with_region(api_key: String, region: String) -> Result<Self>

Create a bearer-token provider with an explicit region.

Examples

use codetether_agent::provider::bedrock::BedrockProvider;
let p = BedrockProvider::with_region("token".into(), "eu-west-1".into()).unwrap();
assert_eq!(p.region(), "eu-west-1");

pub fn with_credentials( credentials: AwsCredentials, region: String, ) -> Result<Self>

Create a SigV4 provider from AWS IAM credentials.

Examples

use codetether_agent::provider::bedrock::{AwsCredentials, BedrockProvider};
let creds = AwsCredentials::from_environment().unwrap();
let p = BedrockProvider::with_credentials(creds, "us-west-2".into()).unwrap();
assert_eq!(p.region(), "us-west-2");

pub fn region(&self) -> &str

Return the configured AWS region.

pub fn resolve_model_id(model: &str) -> &str

Resolve a short model alias to a full Bedrock model ID.

See aliases::resolve_model_id for details.

pub fn build_converse_body( &self, request: &CompletionRequest, model_id: &str, ) -> Value

Build a Converse request body. See body::build_converse_body.

Trait Implementations

impl Clone for BedrockProvider

fn clone(&self) -> BedrockProvider

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BedrockProvider

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

Formats the value using the given formatter.

impl Provider for BedrockProvider

fn name(&self) -> &str

Provider identifier (e.g. "openai", "bedrock").

fn list_models<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<ModelInfo>>> + Send + 'async_trait>>

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

List models available under this provider.

fn complete<'life0, 'async_trait>( &'life0 self, request: CompletionRequest, ) -> Pin<Box<dyn Future<Output = Result<CompletionResponse>> + Send + 'async_trait>>

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

Generate a single completion.

fn complete_stream<'life0, 'async_trait>( &'life0 self, request: CompletionRequest, ) -> Pin<Box<dyn Future<Output = Result<BoxStream<'static, StreamChunk>>> + Send + 'async_trait>>

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

Generate a streaming completion.

fn embed<'life0, 'async_trait>( &'life0 self, _request: EmbeddingRequest, ) -> Pin<Box<dyn Future<Output = Result<EmbeddingResponse>> + Send + 'async_trait>>

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

Generate embeddings (optional; default returns an error).