Struct GcsArtifactService 

pub struct GcsArtifactService { /* private fields */ }

GCS-backed artifact service.

Path format (on the wire, mirroring ADK): {app_name}/{user_id}/{session_id}/{filename}/{version} for session-scoped artifacts, and {app_name}/{user_id}/user/{filename}/{version} for user-namespaced filenames (those starting with "user:").

Quick start

let svc = GcsArtifactService::new("my-bucket", "my-app")
    .with_token("ya29.my-access-token")
    .user_id("alice");

Implementations

impl GcsArtifactService

pub fn new(bucket: impl Into<String>, app_name: impl Into<String>) -> Self

Create a new GCS artifact service targeting the given bucket.

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

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

Set a static bearer token (OAuth2 access 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 user_id(self, user_id: impl Into<String>) -> Self

Override the user ID used in blob paths (defaults to "user").

The crate’s ArtifactService trait is session-scoped and carries no user_id, so it is fixed on the service to complete ADK’s {app_name}/{user_id}/{session_id}/... blob layout.

pub fn bucket(&self) -> &str

The bucket this service targets.

pub fn app_name(&self) -> &str

The application name prefix used in object paths.

Trait Implementations

impl ArtifactService for GcsArtifactService

fn save<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, artifact: Artifact, ) -> Pin<Box<dyn Future<Output = Result<ArtifactMetadata, ArtifactError>> + Send + 'async_trait>>

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

Save an artifact, creating a new version if it already exists.

fn load<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 str, name: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Artifact>, ArtifactError>> + Send + 'async_trait>>

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

Load the latest version of an artifact.

fn load_version<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 str, name: &'life2 str, version: u32, ) -> Pin<Box<dyn Future<Output = Result<Option<Artifact>, ArtifactError>> + Send + 'async_trait>>

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

Load a specific version of an artifact.

fn list<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<ArtifactMetadata>, ArtifactError>> + Send + 'async_trait>>

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

List all artifact metadata for a session.

fn delete<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 str, name: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), ArtifactError>> + Send + 'async_trait>>

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

Delete all versions of an artifact.