Struct EffectAdapter 

pub struct EffectAdapter {
    inner: Arc<dyn DatabaseOperations>,
    effects: Vec<Mutation>,
    resource: Option<ResourceBinding>,
}

Binds app-declared inserts to each domain write transaction. Read-only operations never emit effects, and domain result indices remain unchanged.

Fields

inner: Arc<dyn DatabaseOperations>

effects: Vec<Mutation>

resource: Option<ResourceBinding>

Implementations

impl EffectAdapter

pub fn new( inner: Arc<dyn DatabaseOperations>, schema: &AppSchema, effects: Vec<Mutation>, ) -> Result<Self, DatabaseError>

Accepts a bounded insertion-only outbox plan with local identity references.

pub fn with_resource( self, schema: &AppSchema, resource: ResourceBinding, ) -> Result<Self, DatabaseError>

Binds one declared resource to its generated domain identity at commit.

Trait Implementations

impl DatabaseOperations for EffectAdapter

fn backend_name(&self) -> &'static str

Delegates backend name through the same configured operation interface.

fn local_artifact_format(&self) -> Option<&'static str>

Preserves the underlying adapter artifact contract through this wrapper.

fn ensure_database( &self, config: &DbBackendConfig, schema: &AppSchema, ) -> Result<(), DatabaseError>

Delegates ensure database through the same configured operation interface.

fn user_credentials( &self, config: &DbBackendConfig, schema: &AppSchema, username: &str, ) -> Result<Option<UserCredentials>, DatabaseError>

Delegates user credentials through the same configured operation interface.

fn update_user_password( &self, config: &DbBackendConfig, user_id: i64, password_hash: &str, ) -> Result<(), DatabaseError>

Delegates update user password through the same configured operation interface.

fn issue_session( &self, config: &DbBackendConfig, user_id: i64, session_token_hash: &str, expires_at: &str, ) -> Result<(), DatabaseError>

Delegates issue session through the same configured operation interface.

fn revoke_session( &self, config: &DbBackendConfig, session_token_hash: &str, ) -> Result<(), DatabaseError>

Delegates revoke session through the same configured operation interface.

fn revoke_user_sessions( &self, config: &DbBackendConfig, user_id: i64, ) -> Result<(), DatabaseError>

Delegates revoke user sessions through the same configured operation interface.

fn active_session( &self, config: &DbBackendConfig, schema: &AppSchema, session_token_hash: &str, now_epoch_seconds: u64, ) -> Result<Option<ActiveSession>, DatabaseError>

Delegates active session through the same configured operation interface.

fn append_rate_limit_event( &self, config: &DbBackendConfig, policy_key: &str, bucket_key: &str, outcome: &str, ) -> Result<(), DatabaseError>

Delegates append rate limit event through the same configured operation interface.

fn admit_rate_limited_request( &self, config: &DbBackendConfig, policy_key: &str, bucket_key: &str, maximum: usize, window_seconds: u64, ) -> Result<bool, DatabaseError>

Delegates admit rate limited request through the same configured operation interface.

fn apply_contract( &self, config: &DbBackendConfig, contract: &AppDataContract, ) -> Result<(), DatabaseError>

Delegates apply contract through the same configured operation interface.

fn migration_ledger( &self, config: &DbBackendConfig, app_id: &str, ) -> Result<BTreeMap<String, String>, DatabaseError>

Delegates migration ledger through the same configured operation interface.

fn applied_migration_checksum( &self, config: &DbBackendConfig, app_id: &str, migration_id: &str, ) -> Result<Option<String>, DatabaseError>

Delegates applied migration checksum through the same configured operation interface.

fn verify_contract( &self, config: &DbBackendConfig, contract: &AppDataContract, ) -> Result<(), DatabaseError>

Delegates verify contract through the same configured operation interface.

fn ready( &self, config: &DbBackendConfig, schema: &AppSchema, ) -> Result<(), DatabaseError>

Delegates ready through the same configured operation interface.

fn field_exists( &self, config: &DbBackendConfig, schema: &AppSchema, entity_name: &str, field_name: &str, ) -> Result<bool, DatabaseError>

Delegates field exists through the same configured operation interface.

fn migrate( &self, config: &DbBackendConfig, schema: &AppSchema, migration: &Migration, ) -> Result<(), DatabaseError>

Delegates migrate through the same configured operation interface.

fn adopt_legacy_migration( &self, config: &DbBackendConfig, schema: &AppSchema, migration: &Migration, expected_legacy: &BTreeMap<String, String>, ) -> Result<(), DatabaseError>

Delegates adopt legacy migration through the same configured operation interface.

fn query( &self, config: &DbBackendConfig, schema: &AppSchema, query: &Query, ) -> Result<Vec<Map<String, Value>>, DatabaseError>

Delegates query through the same configured operation interface.

fn join_query( &self, config: &DbBackendConfig, schema: &AppSchema, request: &JoinedQuery, ) -> Result<Vec<JoinedRecord>, DatabaseError>

Delegates join query through the same configured operation interface.

fn aggregate( &self, config: &DbBackendConfig, schema: &AppSchema, query: &AggregateQuery, ) -> Result<Value, DatabaseError>

Delegates aggregate through the same configured operation interface.

fn transact( &self, config: &DbBackendConfig, schema: &AppSchema, transaction: &Transaction, ) -> Result<TransactionResult, DatabaseError>

Delegates transact through the same configured operation interface.

fn claim_one( &self, config: &DbBackendConfig, schema: &AppSchema, claim: &Claim, ) -> Result<Option<i64>, DatabaseError>

Delegates claim one through the same configured operation interface.

fn export_page( &self, config: &DbBackendConfig, schema: &AppSchema, entity: &str, after_identity: Option<Value>, limit: u32, ) -> Result<Vec<Record>, DatabaseError>

Delegates export page through the same configured operation interface.

fn export_snapshot( &self, config: &DbBackendConfig, schema: &AppSchema, limits: SnapshotLimits, ) -> Result<Vec<Record>, DatabaseError>

Delegates export snapshot through the same configured operation interface.

fn restore_snapshot( &self, config: &DbBackendConfig, schema: &AppSchema, records: &[Record], limits: SnapshotLimits, counts: &[RestoreCount], ) -> Result<(), DatabaseError>

Delegates restore snapshot through the same configured operation interface.

fn import_batch( &self, config: &DbBackendConfig, schema: &AppSchema, records: &[Record], ) -> Result<(), DatabaseError>

Delegates import batch through the same configured operation interface.