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.

Implementations

impl VertexAiSessionService

pub fn new(config: VertexAiSessionConfig) -> Self

Create a new Vertex AI session service.

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.