Struct PostgresStorage 

pub struct PostgresStorage { /* private fields */ }

PostgreSQL storage backend for JACS documents.

Implements StorageDocumentTraits, DatabaseDocumentTraits, and SearchProvider. Supports fulltext search via PostgreSQL tsvector. Vector search (pgvector) is not yet implemented but the capability reporting is prepared for it.

Implementations

impl PostgresStorage

pub fn new( database_url: &str, max_connections: Option<u32>, min_connections: Option<u32>, connect_timeout_secs: Option<u64>, ) -> Result<Self, JacsError>

Create a new PostgresStorage connected to the given PostgreSQL URL.

Pool settings:

• max_connections: Maximum pool size (default 10)
• min_connections: Minimum pool size (default 1)
• connect_timeout_secs: Connection timeout (default 30)

pub fn with_pool(pool: PgPool, handle: Handle) -> Self

Create a PostgresStorage from an existing pool and handle (for testing).

pub fn pool(&self) -> &PgPool

Get a reference to the underlying pool.

Trait Implementations

impl DatabaseDocumentTraits for PostgresStorage

fn query_by_type( &self, jacs_type: &str, limit: usize, offset: usize, ) -> Result<Vec<JACSDocument>, JacsError>

Query documents by their jacsType field with pagination.

fn query_by_field( &self, field_path: &str, value: &str, jacs_type: Option<&str>, limit: usize, offset: usize, ) -> Result<Vec<JACSDocument>, JacsError>

Query documents where a JSONB field matches a value. field_path is a top-level field name (e.g., “jacsCommitmentStatus”).

fn count_by_type(&self, jacs_type: &str) -> Result<usize, JacsError>

Count documents by type.

fn get_versions(&self, jacs_id: &str) -> Result<Vec<JACSDocument>, JacsError>

Get all versions of a document ordered by creation date.

fn get_latest(&self, jacs_id: &str) -> Result<JACSDocument, JacsError>

Get the most recent version of a document.

fn query_by_agent( &self, agent_id: &str, jacs_type: Option<&str>, limit: usize, offset: usize, ) -> Result<Vec<JACSDocument>, JacsError>

Query documents by the agent that signed them.

fn run_migrations(&self) -> Result<(), JacsError>

Run database migrations to create/update the schema.

impl SearchProvider for PostgresStorage

fn search(&self, query: SearchQuery) -> Result<SearchResults, JacsError>

Search documents using the given query.

fn capabilities(&self) -> SearchCapabilities

Reports what search capabilities this backend supports.

impl StorageDocumentTraits for PostgresStorage

fn store_document(&self, doc: &JACSDocument) -> Result<(), JacsError>

fn get_document(&self, key: &str) -> Result<JACSDocument, JacsError>

fn remove_document(&self, key: &str) -> Result<JACSDocument, JacsError>

fn list_documents(&self, prefix: &str) -> Result<Vec<String>, JacsError>

fn document_exists(&self, key: &str) -> Result<bool, JacsError>

fn get_documents_by_agent( &self, agent_id: &str, ) -> Result<Vec<String>, JacsError>

fn get_document_versions( &self, document_id: &str, ) -> Result<Vec<String>, JacsError>

fn get_latest_document( &self, document_id: &str, ) -> Result<JACSDocument, JacsError>

fn merge_documents( &self, _doc_id: &str, _v1: &str, _v2: &str, ) -> Result<JACSDocument, JacsError>

fn store_documents( &self, docs: Vec<JACSDocument>, ) -> Result<Vec<String>, Vec<JacsError>>

fn get_documents( &self, keys: Vec<String>, ) -> Result<Vec<JACSDocument>, Vec<JacsError>>