Struct CedrosData 

pub struct CedrosData { /* private fields */ }

Implementations

impl CedrosData

pub async fn verify_contract( &self, request: VerifyContractRequest, ) -> Result<ContractVerificationReport>

impl CedrosData

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

pub async fn bootstrap_defaults(&self) -> Result<SiteBootstrapReport>

pub async fn list_default_page_entries(&self) -> Result<Vec<EntryRecord>>

pub async fn upsert_default_page_entry( &self, page_key: &str, payload: Value, ) -> Result<EntryRecord>

impl CedrosData

pub async fn upsert_entry( &self, request: UpsertEntryRequest, ) -> Result<EntryRecord>

pub async fn query_entries( &self, request: QueryEntriesRequest, ) -> Result<Vec<EntryRecord>>

impl CedrosData

pub async fn export_site( &self, request: ExportSiteRequest, ) -> Result<SiteExport>

pub async fn import_site( &self, request: ImportSiteRequest, ) -> Result<ImportResult>

impl CedrosData

pub async fn apply_content_gating( &self, entries: &mut [EntryRecord], visitor_id: &str, record_reads: bool, ) -> Result<()>

Applies transparent content gating to entries for a visitor.

• If metering is disabled (freeReadsPerMonth == 0), no-op.
• If record_reads is true, records a read for each entry (deduplicated).
• Strips body fields and injects _metering status when reads exhausted.

impl CedrosData

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

Run database migrations.

ignore_missing = true so the migrator tolerates foreign entries in _sqlx_migrations from other packages sharing the same database.

locking = false avoids acquiring a session-level pg_advisory_lock that would leak on failure and block all subsequent migrations.

impl CedrosData

pub async fn register_custom_schema( &self, request: RegisterCustomSchemaRequest, ) -> Result<CustomSchemaApplyReport>

impl CedrosData

pub async fn register_site(&self, request: RegisterSiteRequest) -> Result<Site>

pub async fn register_collection( &self, request: RegisterCollectionRequest, ) -> Result<Collection>

pub async fn list_collections(&self) -> Result<Vec<Collection>>

impl CedrosData

pub async fn from_env() -> Result<Self>

pub async fn connect(postgres_uri: &str) -> Result<Self>

pub fn pool(&self) -> &PgPool

Trait Implementations

impl Clone for CedrosData

fn clone(&self) -> CedrosData

Returns a duplicate of the value.

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

Performs copy-assignment from source.