Struct AccessConnectorClient 

pub(crate) struct AccessConnectorClient {
    pub(crate) key_store: KeyStore<KeySlotIds>,
    pub(crate) api_configurations: Arc<ApiConfigurations>,
}

Domain-typed wrapper around the generated PAM rotation API clients.

Fields

key_store: KeyStore<KeySlotIds>

api_configurations: Arc<ApiConfigurations>

Implementations

impl AccessConnectorClient

pub(crate) async fn poll_jobs(&self) -> Result<Vec<JobRef>, ApiError>

Poll for claimable rotation jobs. A 404 maps to ApiError::NotEligible.

pub(crate) async fn claim( &self, job_id: Uuid, ) -> Result<Option<WorkSnapshot>, ApiError>

Attempt to claim a rotation job.

Ok(None) means another connector won the race (409). A 404 maps to ApiError::NotEligible.

pub(crate) async fn get_cipher( &self, attempt_id: Uuid, ) -> Result<Cipher, ApiError>

Fetch the encrypted cipher for an attempt. A 404 maps to ApiError::UnknownAttempt.

pub(crate) async fn put_cipher( &self, attempt_id: Uuid, body: CipherRequestModel, ) -> Result<(), ApiError>

Write the re-encrypted cipher back. lastKnownRevisionDate is the optimistic-concurrency check; a 409 means revision drift or capability lost, a 404 an unknown attempt.

pub(crate) async fn report_success( &self, attempt_id: Uuid, termination: SessionTerminationOutcome, ) -> Result<(), ApiError>

Report a successful rotation attempt. A 409 or 404 is final: do not retry.

pub(crate) async fn report_failure( &self, attempt_id: Uuid, code: RotationFailureCode, detail: Option<SafeDetail>, sync_state: RotationSyncState, ) -> Result<(), ApiError>

Report a failed rotation attempt. A 409 or 404 is final, as in Self::report_success.

Trait Implementations

impl FromClient for AccessConnectorClient

fn from_client(client: &Client) -> Self

Construct this type from a [Client] reference.