Struct InteractionsCompletionModel 

pub struct InteractionsCompletionModel<T = Client> {
    pub model: String,
    /* private fields */
}

Completion model wrapper for the Gemini Interactions API.

Fields

model: String

Implementations

impl<T> InteractionsCompletionModel<T>

where T: HttpClientExt + Clone + Default + Debug + 'static,

pub async fn raw_stream( &self, completion_request: CompletionRequest, ) -> Result<Pin<Box<dyn Stream<Item = Result<RawStreamingChoice<StreamingCompletionResponse>, CompletionError>> + Send>>, CompletionError>

Open an Interactions stream whose terminal record stays provider-native.

The normalized CompletionModel::stream delegates here and maps only the terminal record, so both paths open exactly one stream over the same request, telemetry, and error handling.

impl<T> InteractionsCompletionModel<T>

pub fn new( client: Client<GeminiInteractionsExt, T>, model: impl Into<String>, ) -> InteractionsCompletionModel<T>

Create a new Interactions completion model for the given client and model name.

pub fn with_model( client: Client<GeminiInteractionsExt, T>, model: &str, ) -> InteractionsCompletionModel<T>

Create a new Interactions completion model using a string model name.

pub fn generate_content_api(self) -> CompletionModel<T>

Use the GenerateContent API instead of Interactions.

impl<T> InteractionsCompletionModel<T>

where T: HttpClientExt + Clone + Debug + Default + 'static,

pub async fn create_interaction( &self, completion_request: CompletionRequest, ) -> Result<Interaction, CompletionError>

Create an interaction and return the raw response payload.

pub async fn get_interaction( &self, interaction_id: impl AsRef<str>, ) -> Result<Interaction, CompletionError>

Fetch an interaction by ID for polling background tasks.

pub async fn stream_interaction_events( &self, completion_request: CompletionRequest, ) -> Result<Pin<Box<dyn Stream<Item = Result<InteractionSseEvent, CompletionError>> + Send>>, CompletionError>

Start an interaction and stream raw SSE events.

pub async fn stream_interaction_events_by_id( &self, interaction_id: impl AsRef<str>, last_event_id: Option<&str>, ) -> Result<Pin<Box<dyn Stream<Item = Result<InteractionSseEvent, CompletionError>> + Send>>, CompletionError>

Resume an interaction stream by ID and optional last event ID.

impl<T> InteractionsCompletionModel<T>

where T: HttpClientExt + Clone + Debug + Default + 'static,

pub async fn raw_completion( &self, completion_request: CompletionRequest, ) -> Result<Interaction, CompletionError>

Execute a completion and return the Interactions API’s own payload.

This is the escape hatch for interaction fields rig does not normalize — step history, lifecycle status, hosted-tool exchanges. It shares the request builder, transport, telemetry, and error handling with CompletionModel::completion, which calls it and then applies the provider-local mapping — one network request either way.

Trait Implementations

impl<T> Clone for InteractionsCompletionModel<T>

where T: Clone,

fn clone(&self) -> InteractionsCompletionModel<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> CompletionModel for InteractionsCompletionModel<T>

where T: HttpClientExt + Clone + Debug + Default + 'static,

async fn completion( &self, completion_request: CompletionRequest, ) -> Result<CompletionResponse, CompletionError>

Generates a completion response for the given completion request.

async fn stream( &self, request: CompletionRequest, ) -> Result<StreamingCompletionResponse, CompletionError>

Streams a completion response for the given completion request.

fn completion_request( &self, prompt: impl Into<Message>, ) -> CompletionRequestBuilder<Self>

where Self: Sized + Clone,

Generates a completion request builder for the given prompt.

fn capabilities(&self) -> ProviderCapabilities

Provider behavior a runtime should account for when preparing requests.

impl<T> ConstructCompletionModel<Client<GeminiInteractionsExt, T>> for InteractionsCompletionModel<T>

where Client<GeminiInteractionsExt, T>: Clone,

fn construct( client: &Client<GeminiInteractionsExt, T>, model: String, ) -> InteractionsCompletionModel<T>

Build this model from its provider client and a model identifier.

impl<T> Debug for InteractionsCompletionModel<T>

where T: Debug,

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

Formats the value using the given formatter.