Struct MutationContext 

pub struct MutationContext {
    pub auth: AuthContext,
    pub request: RequestMetadata,
    /* private fields */
}

Context for mutation functions (transactional database access).

Fields

auth: AuthContext

Authentication context.

request: RequestMetadata

Request metadata.

Implementations

impl MutationContext

pub fn new(db_pool: PgPool, auth: AuthContext, request: RequestMetadata) -> Self

Create a new mutation context.

pub fn with_dispatch( db_pool: PgPool, auth: AuthContext, request: RequestMetadata, http_client: CircuitBreakerClient, job_dispatch: Option<Arc<dyn JobDispatch>>, workflow_dispatch: Option<Arc<dyn WorkflowDispatch>>, ) -> Self

Create a mutation context with dispatch capabilities.

pub fn with_env( db_pool: PgPool, auth: AuthContext, request: RequestMetadata, http_client: CircuitBreakerClient, job_dispatch: Option<Arc<dyn JobDispatch>>, workflow_dispatch: Option<Arc<dyn WorkflowDispatch>>, env_provider: Arc<dyn EnvProvider>, ) -> Self

Create a mutation context with a custom environment provider.

pub fn with_transaction( db_pool: PgPool, tx: Transaction<'static, Postgres>, auth: AuthContext, request: RequestMetadata, http_client: CircuitBreakerClient, job_info_lookup: JobInfoLookup, ) -> (Self, Arc<AsyncMutex<Transaction<'static, Postgres>>>, Arc<Mutex<OutboxBuffer>>)

Returns handles to transaction and outbox for the caller to commit/flush.

pub fn is_transactional(&self) -> bool

pub fn db(&self) -> DbConn<'_>

pub fn pool(&self) -> &PgPool

Direct pool access for operations that cannot run inside a transaction.

pub fn http(&self) -> &Client

Get the HTTP client for external requests.

The client includes circuit breaker protection that tracks failure rates per host. After repeated failures, requests fail fast to prevent cascade failures when downstream services are unhealthy.

pub fn http_with_circuit_breaker(&self) -> &CircuitBreakerClient

Get the circuit breaker client directly for advanced usage.

pub fn require_user_id(&self) -> Result<Uuid>

pub fn require_subject(&self) -> Result<&str>

pub async fn dispatch_job<T: Serialize>( &self, job_type: &str, args: T, ) -> Result<Uuid>

In transactional mode, buffers for atomic commit; otherwise dispatches immediately.

pub async fn dispatch_job_with_context<T: Serialize>( &self, job_type: &str, args: T, context: Value, ) -> Result<Uuid>

Dispatch a job with initial context.

pub async fn cancel_job( &self, job_id: Uuid, reason: Option<String>, ) -> Result<bool>

Request cancellation for a job.

pub async fn start_workflow<T: Serialize>( &self, workflow_name: &str, input: T, ) -> Result<Uuid>

In transactional mode, buffers for atomic commit; otherwise starts immediately.

Trait Implementations

impl EnvAccess for MutationContext

fn env_provider(&self) -> &dyn EnvProvider

Get the environment provider.

fn env(&self, key: &str) -> Option<String>

Get an environment variable.

fn env_or(&self, key: &str, default: &str) -> String

Get an environment variable with a default value.

fn env_require(&self, key: &str) -> Result<String>

Get a required environment variable.

fn env_parse<T: FromStr>(&self, key: &str) -> Result<T>

where T::Err: Display,

Get an environment variable and parse it to the specified type.

fn env_parse_or<T: FromStr>(&self, key: &str, default: T) -> Result<T>

where T::Err: Display,

Get an environment variable and parse it, with a default.

fn env_contains(&self, key: &str) -> bool

Check if an environment variable is set.