Struct ResponsesViaGemini 

pub struct ResponsesViaGemini { /* private fields */ }

A prepared Responses client request executed by the selected Gemini endpoint.

Implementations

impl ResponsesViaGemini

pub async fn convert_response_with_image_resources<S: StateStore, R: ResourceAccess>( &mut self, native: GenerateContentResponseBody, facts: GeminiReturnFacts, _state: &GenerationStateAccess<'_, S>, resources: &GenerationResources<'_, R>, progress: &mut ImageResourceProgress<GenerateContentResponseBody, R::PublishedHandle>, ) -> Result<Converted<GenerateContentResponseBody>, TransformError>

Materialize actual native fileData images and convert that view. An image’s signature goes to the client with its bytes, so nothing is kept.

pub async fn invoke_with_image_resources<U: Upstream, S: StateStore, R: ResourceAccess>( &mut self, upstream: &U, target: &U::Target, limits: CodecLimits, state: &GenerationStateAccess<'_, S>, resources: &GenerationResources<'_, R>, progress: &mut ImageResourceProgress<GenerateContentResponseBody, R::PublishedHandle>, facts: impl FnOnce(&GenerateContentResponseBody) -> Result<GeminiReturnFacts, TransformError>, ) -> Result<GenerationOutcome<GenerateContentResponseBody>, TransformError>

One buffered generation POST followed by scoped image reads. Recovery retains the native result and never repeats the generation request.

pub async fn recover_with_image_resources<S: StateStore, R: ResourceAccess>( &mut self, limits: CodecLimits, state: &GenerationStateAccess<'_, S>, resources: &GenerationResources<'_, R>, progress: &mut ImageResourceProgress<GenerateContentResponseBody, R::PublishedHandle>, facts: impl FnOnce(&GenerateContentResponseBody) -> Result<GeminiReturnFacts, TransformError>, ) -> Result<GenerationOutcome<GenerateContentResponseBody>, TransformError>

impl ResponsesViaGemini

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

pub async fn prepare_with_state<S: StateStore>( input: GenerateContentRequestBody, endpoint: Endpoint, identities: GenerationIdentity, state: &GenerationStateAccess<'_, S>, context: GeminiReplayContext, ) -> 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>, context: GeminiReplayContext, ) -> 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: GeminiReturnFacts, ) -> 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<GeminiReturnFacts, 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<GeminiReturnFacts, TransformError>, ) -> Result<GenerationOutcome<GenerateContentResponseBody>, TransformError>

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

impl ResponsesViaGemini

pub async fn prepare_for_stream_synthesis<S: StateStore>( input: GenerateContentRequestBody, endpoint: Endpoint, identities: GenerationIdentity, state: &GenerationStateAccess<'_, S>, context: GeminiReplayContext, ) -> 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>, context: GeminiReplayContext, ) -> Result<Self, TransformError>

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

impl ResponsesViaGemini

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

pub async fn prepare_stream_with_history_cache<S: StateStore>( input: GenerateContentRequestBody, target: StreamTarget, context: ResponsesViaGeminiStreamFacts, settings: StreamSettings, state: &GenerationStateAccess<'_, S>, history_cache: &ResponsesHistoryCache, ) -> Result<StreamInvocation<GeminiToResponsesStream>, TransformError>

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

pub async fn prepare_stream_with_capabilities_and_history_cache<S: StateStore, R: ResourceAccess>( input: GenerateContentRequestBody, target: StreamTarget, context: ResponsesViaGeminiStreamFacts, settings: StreamSettings, state: &GenerationStateAccess<'_, S>, resources: &GenerationResources<'_, R>, history_cache: &ResponsesHistoryCache, ) -> Result<StreamInvocation<GeminiToResponsesStream>, TransformError>

Trait Implementations

impl Debug for ResponsesViaGemini

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

Formats the value using the given formatter.