Struct DistributedSolver 

pub struct DistributedSolver { /* private fields */ }

Wraps any Solver for clustered / distributed deployments.

Before delegating to the inner solver, the distributed solver stores the challenge data (domain, token, key_auth) in shared Storage so that other cluster members can read it and respond to validation requests.

During cleanup, the challenge data is removed from storage and the inner solver’s cleanup method is also called.

Implementations

impl DistributedSolver

pub fn new( inner: Box<dyn Solver>, storage: Arc<dyn Storage>, ) -> DistributedSolver

Create a new distributed solver wrapping inner, using storage for cross-instance coordination.

Challenge tokens are stored under the default prefix (challenge_tokens/). Use DistributedSolver::with_prefix to specify an issuer-specific prefix.

pub fn with_prefix( inner: Box<dyn Solver>, storage: Arc<dyn Storage>, prefix: String, ) -> DistributedSolver

Create a new distributed solver with an issuer-specific storage key prefix.

The prefix is prepended to the challenge tokens storage path, e.g. "<prefix>/challenge_tokens/<domain>/<token>.json".

Trait Implementations

impl Debug for DistributedSolver

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Solver for DistributedSolver

fn present<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, domain: &'life1 str, token: &'life2 str, key_auth: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, DistributedSolver: 'async_trait,

Present the challenge — make it solvable by the ACME CA’s validation server (e.g. start an HTTP server, create a DNS record, or install a TLS certificate).

fn wait<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, domain: &'life1 str, token: &'life2 str, key_auth: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, DistributedSolver: 'async_trait,

Optionally wait until the challenge is ready to be verified by the CA.

fn cleanup<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, domain: &'life1 str, token: &'life2 str, key_auth: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, DistributedSolver: 'async_trait,

Clean up after the challenge (e.g. stop the server, delete the DNS record, remove the certificate from the cache).