Struct PluginStorage 

pub struct PluginStorage { /* private fields */ }

Implementations

impl PluginStorage

pub async fn new(config: &Config) -> Result<Self>

pub async fn upload_plugin( &self, plugin_name: &str, version: &str, data: Vec<u8>, ) -> Result<String>

pub async fn upload_template( &self, template_name: &str, version: &str, data: Vec<u8>, ) -> Result<String>

pub async fn upload_scenario( &self, scenario_name: &str, version: &str, data: Vec<u8>, ) -> Result<String>

pub fn plugin_object_key(plugin_name: &str, version: &str) -> Result<String>

Resolve the storage key for a plugin version using the same sanitization rules as upload_plugin. Public so background workers can fetch artifacts for scanning without duplicating the scheme.

pub async fn download_plugin(&self, key: &str) -> Result<Vec<u8>>

pub async fn delete_plugin(&self, key: &str) -> Result<()>

pub async fn upload_spec( &self, org_id: &str, spec_name: &str, data: Vec<u8>, ) -> Result<String>

Upload an OpenAPI spec file for a hosted mock deployment

pub async fn health_check(&self) -> Result<()>

Health check - verify storage connectivity

pub async fn upload_snapshot_blob( &self, workspace_id: Uuid, snapshot_id: Uuid, data: Vec<u8>, ) -> Result<String>

Upload a workspace snapshot manifest blob (#10). Snapshots inline their manifest in snapshots.manifest for small workspaces; for larger ones the registry serializes the JSON once + uploads here, then stores the returned URL in snapshots.storage_url.

Key format: snapshots/{workspace_id}/{snapshot_id}.json — keyed by workspace so a stray scan stays within tenant boundaries (the snapshots row is workspace-scoped on the DB side too, no org_id column).

pub async fn read_snapshot_blob( &self, workspace_id: Uuid, snapshot_id: Uuid, ) -> Result<Vec<u8>>

Read back a snapshot manifest blob the registry previously uploaded. Returns the raw bytes — caller deserializes.

pub async fn delete_snapshot_blob( &self, workspace_id: Uuid, snapshot_id: Uuid, ) -> Result<()>

Delete a snapshot’s blob (called from snapshot retention worker once the row is marked expired). Idempotent — missing keys are not an error.

Trait Implementations

impl Clone for PluginStorage

fn clone(&self) -> PluginStorage

Returns a duplicate of the value.

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

Performs copy-assignment from source.