Struct GeminiViaChat 

pub struct GeminiViaChat { /* private fields */ }

A prepared Gemini client request executed by the selected Chat Completions endpoint.

Implementations

impl GeminiViaChat

pub fn prepare( input: GenerateContentRequestBody, selected_model: impl Into<String>, endpoint: Endpoint, identities: GenerationIdentity, ) -> Result<Self, TransformError>

pub async fn prepare_with_state<S: StateStore>( input: GenerateContentRequestBody, endpoint: Endpoint, identities: GenerationIdentity, state: &GenerationStateAccess<'_, S>, ) -> Result<Self, TransformError>

Restore exact tool aliases and names from declared history/scoped state before mapping.

pub async fn prepare_with_capabilities<S: StateStore, R: ResourceAccess>( input: GenerateContentRequestBody, endpoint: Endpoint, identities: GenerationIdentity, state: &GenerationStateAccess<'_, S>, resources: &GenerationResources<'_, R>, ) -> Result<Self, TransformError>

Materialize foreign resources and restore scoped history before preparing the selected endpoint.

pub fn original_request(&self) -> &GenerateContentRequestBody

pub fn target_request(&self) -> &GenerateContentRequestBody

pub fn identities(&self) -> &GenerationIdentity

pub fn report(&self) -> &Report

pub fn selected_model(&self) -> &str

pub fn convert_response( &mut self, native: GenerateContentResponseBody, _facts: (), ) -> Result<Converted<GenerateContentResponseBody>, TransformError>

pub async fn invoke<U: Upstream, S: StateStore>( &mut self, upstream: &U, target: &U::Target, limits: CodecLimits, state: &GenerationStateAccess<'_, S>, progress: &mut GenerationProgress<GenerateContentResponseBody>, facts: impl FnOnce(&GenerateContentResponseBody) -> Result<(), TransformError>, ) -> Result<GenerationOutcome<GenerateContentResponseBody>, TransformError>

Performs one POST. The factual supplement is obtained from the actual decoded response. Conversion errors keep native bytes/results in caller-owned progress.

pub async fn recover<S: StateStore>( &mut self, limits: CodecLimits, state: &GenerationStateAccess<'_, S>, progress: &mut GenerationProgress<GenerateContentResponseBody>, facts: impl FnOnce(&GenerateContentResponseBody) -> Result<(), TransformError>, ) -> Result<GenerationOutcome<GenerateContentResponseBody>, TransformError>

Complete response conversion and pending state writes using the retained result; sends no request.

impl GeminiViaChat

pub async fn prepare_for_stream_synthesis<S: StateStore>( input: GenerateContentRequestBody, endpoint: Endpoint, identities: GenerationIdentity, state: &GenerationStateAccess<'_, S>, ) -> Result<Self, TransformError>

Prepare a buffered upstream result for later native stream synthesis, retaining the original client stream flag and all declared controls.

pub async fn prepare_for_stream_synthesis_with_capabilities<S: StateStore, R: ResourceAccess>( input: GenerateContentRequestBody, endpoint: Endpoint, identities: GenerationIdentity, state: &GenerationStateAccess<'_, S>, resources: &GenerationResources<'_, R>, ) -> Result<Self, TransformError>

Prepare a buffered upstream result for later native stream synthesis, retaining the original client stream flag and all declared controls.

impl GeminiViaChat

pub async fn prepare_stream<S: StateStore>( input: GenerateContentRequestBody, target: StreamTarget, settings: StreamSettings, state: &GenerationStateAccess<'_, S>, ) -> Result<StreamInvocation<ChatToGeminiStream>, TransformError>

pub async fn prepare_stream_with_capabilities<S: StateStore, R: ResourceAccess>( input: GenerateContentRequestBody, target: StreamTarget, settings: StreamSettings, state: &GenerationStateAccess<'_, S>, resources: &GenerationResources<'_, R>, ) -> Result<StreamInvocation<ChatToGeminiStream>, TransformError>

Trait Implementations

impl Debug for GeminiViaChat

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

Formats the value using the given formatter.