Struct Store 

pub struct Store { /* private fields */ }

SQLite-backed storage for PlanSpec resources

Implementations

impl Store

pub async fn new(path: &str) -> Result<Self>

Create a new store, initializing the database schema

pub async fn create( &self, namespace: &str, kind: &str, name: &str, object: Value, ) -> Result<(StoredObject, WatchEvent)>

Create a new resource

pub async fn get( &self, namespace: &str, kind: &str, name: &str, ) -> Result<Option<StoredObject>>

Get a resource by key

pub async fn list( &self, namespace: &str, kind: &str, ) -> Result<Vec<StoredObject>>

List resources by namespace and kind

pub async fn list_all(&self, kind: &str) -> Result<Vec<StoredObject>>

List all resources of a kind across all namespaces

pub async fn replace( &self, namespace: &str, kind: &str, name: &str, object: Value, expected_resource_version: Option<&str>, ) -> Result<(StoredObject, WatchEvent)>

Replace a resource (with optimistic concurrency check)

pub async fn delete( &self, namespace: &str, kind: &str, name: &str, ) -> Result<Option<WatchEvent>>

Delete a resource

pub async fn create_namespace(&self, name: &str) -> Result<NamespaceInfo>

Create a namespace (fails if already exists)

pub async fn ensure_namespace(&self, name: &str) -> Result<NamespaceInfo>

Ensure a namespace exists, creating it if needed (idempotent, race-safe)

pub async fn get_namespace(&self, name: &str) -> Result<Option<NamespaceInfo>>

Get a namespace by name

pub async fn list_namespaces(&self) -> Result<Vec<NamespaceInfo>>

List all namespaces

pub async fn delete_namespace(&self, name: &str) -> Result<Option<i64>>

Delete a namespace and all its resources (cascade delete)

pub async fn namespace_exists(&self, name: &str) -> Result<bool>

Check if a namespace exists

Trait Implementations

impl Clone for Store

fn clone(&self) -> Store

Returns a duplicate of the value.

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

Performs copy-assignment from source.