Struct VertexAiSessionService 

pub struct VertexAiSessionService { /* private fields */ }

Session service backed by the Vertex AI managed session endpoint.

Uses the Vertex AI REST API for session CRUD and event storage. Requires a valid Google Cloud project with the AI Platform API enabled.

Sessions are stored server-side by Google Cloud, providing managed persistence without requiring a separate database.

Quick start

let svc = VertexAiSessionService::new(
    VertexAiSessionConfig::new("my-project", "us-central1")
        .ttl_seconds(3600),
)
.with_token("ya29.my-access-token")
.reasoning_engine("my-engine-id");

Implementations

impl VertexAiSessionService

pub fn new(config: VertexAiSessionConfig) -> Self

Create a new Vertex AI session service.

No auth token is configured yet — call with_token or with_token_refresher before issuing requests, otherwise they will return SessionError::Storage("missing auth token").

pub fn with_token(self, token: impl Into<String>) -> Self

Set a static bearer token for all requests.

pub fn with_token_refresher( self, f: impl Fn() -> String + Send + Sync + 'static, ) -> Self

Set a dynamic token refresher closure.

The closure is invoked before every HTTP request, allowing the caller to supply a freshly-refreshed token each time.

pub fn reasoning_engine(self, id: impl Into<String>) -> Self

Override the reasoning engine ID (defaults to "default").

pub fn project(&self) -> &str

Returns the configured project ID.

pub fn location(&self) -> &str

Returns the configured location.

pub fn ttl_seconds(&self) -> Option<u64>

Returns the configured TTL in seconds, if any.

Trait Implementations

impl SessionService for VertexAiSessionService

fn create_session<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, app_name: &'life1 str, user_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Session, SessionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Create a new session.

fn get_session<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = Result<Option<Session>, SessionError>> + Send + 'async_trait>>

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

Get a session by ID.

fn list_sessions<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, app_name: &'life1 str, user_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<Session>, SessionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

List sessions for an app + user.

fn delete_session<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = Result<(), SessionError>> + Send + 'async_trait>>

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

Delete a session.

fn append_event<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 SessionId, event: Event, ) -> Pin<Box<dyn Future<Output = Result<(), SessionError>> + Send + 'async_trait>>

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

Append an event to a session’s history.

fn get_events<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = Result<Vec<Event>, SessionError>> + Send + 'async_trait>>

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

Get all events for a session.