Struct SqlShimResolver 

pub struct SqlShimResolver { /* private fields */ }

Resolves a workload’s sql ComputeBindings to a shim endpoint + credential injected into the guest env. Holds the same SqlBackends provider a handler uses, the shim registry, the guest-reachable shim base URL, and a per-node secret used to derive a token that is deterministic (recomputable at release / re-register without persisting it) yet unguessable (keyed by the secret).

Implementations

impl SqlShimResolver

pub fn new( provider: Arc<dyn SqlBackends>, shim: SqlShim, base_url: String, secret: [u8; 32], ) -> Self

base_url is the shim URL reachable from the guest (e.g. the compute bridge gateway); secret is a per-node random used only to key the token derivation.

Trait Implementations

impl ComputeBindingResolver for SqlShimResolver

fn resolve<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, project: &'life1 str, workload: &'life2 str, replica: u32, bindings: &'life3 [ComputeBinding], ) -> Pin<Box<dyn Future<Output = Vec<(String, String)>> + Send + 'async_trait>>

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

Resolve bindings to (env_key, env_value) pairs to inject into the guest, registering the shim state for (project, workload, replica).

fn release<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, project: &'life1 str, workload: &'life2 str, replica: u32, bindings: &'life3 [ComputeBinding], ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Release the shim state for a torn-down replica.