Struct VertexNativeProvider 

pub struct VertexNativeProvider { /* private fields */ }

Implementations

impl VertexNativeProvider

pub fn new( auth: Arc<VertexAuth>, project: String, region: String, request_timeout: Duration, endpoint_override: Option<String>, ) -> Self

pub async fn generate( &self, model: &str, req: &ChatRequest, region: Option<&str>, ) -> Result<Completion, GatewayError>

SUPERSEDED by stream_generate + the buffered aggregator. The live native path (both stream and non-stream via collect_committed) goes through stream_generate; this unary call is retained only for its endpoint/auth tests. Note parse_response does NOT extract tool calls — do not re-wire the request path back through here without restoring that.

pub async fn passthrough_request( &self, model: &str, action: &str, alt_sse: bool, body: Value, region: Option<&str>, ) -> Result<Response, GatewayError>

Forward a raw Gemini-native models/{model}:{action} request to Vertex, re-authenticated with the gateway’s own credentials. Used by the passthrough surface (server::gemini_passthrough), which meters usage from the response’s usageMetadata; the body is forwarded verbatim.

pub async fn stream_generate( &self, model: &str, req: &ChatRequest, region: Option<&str>, ) -> Result<impl Stream<Item = Result<StreamItem, LegError>>, GatewayError>

Open a Vertex SSE stream and normalize chunks into StreamItems.

The outer Err is the connection phase, returned as a GatewayError so the handler preserves Vertex’s status distinction (non-retryable 4xx → BadRequest; 429/408/5xx/transport → Upstream for multi-leg fallback) — the same mapping the non-stream generate used. Per-item (mid-stream) errors remain LegError.

Trait Implementations

impl Clone for VertexNativeProvider

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 VertexNativeProvider

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

Formats the value using the given formatter.