Struct OperatorContext 

pub struct OperatorContext {
    pub kube_client: Client,
    pub event_recorder: Recorder,
    pub observability: OperatorObservability,
    /* private fields */
}

Shared state for the operator, passed to every reconciliation.

Fields

kube_client: Client

Kubernetes client for API calls.

event_recorder: Recorder

Kubernetes Event recorder for transition-based policy Events.

observability: OperatorObservability

Shared health/metrics state.

Implementations

impl OperatorContext

pub fn new( kube_client: Client, observability: OperatorObservability, event_recorder: Recorder, ) -> Self

Create a new operator context with an empty pool cache.

pub async fn try_lock_database( &self, database_identity: &str, ) -> Option<DatabaseLockGuard>

Try to acquire the in-process lock for the given database identity.

Returns Some(guard) if no other reconcile is in progress for this database, None if one is already running. The lock is released when the guard is dropped.

pub async fn get_or_create_pool( &self, namespace: &str, secret_name: &str, secret_key: &str, ) -> Result<PgPool, ContextError>

Get or create a PgPool for the given secret reference.

Reads the DATABASE_URL (or custom key) from the referenced Secret, and caches the resulting pool for reuse.

pub async fn fetch_secret_value( &self, namespace: &str, secret_name: &str, secret_key: &str, ) -> Result<String, ContextError>

Fetch a single string value from a Kubernetes Secret.

Used to resolve role passwords from Secret references at reconcile time.

pub async fn evict_pool( &self, namespace: &str, secret_name: &str, secret_key: &str, )

Remove a cached pool (e.g. when secret changes or CR is deleted).

Trait Implementations

impl Clone for OperatorContext

fn clone(&self) -> OperatorContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.