appcore-gateway 2.0.0-alpha.1

Multi-tenant Gateway capability for the AppCore Runtime.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55

// =============================================================================
//        #######
//     ###       ###     F: resolver.rs
//    ##   ## ##   ##    P: AppCore-Runtime
//         ## ##
//                       C: 2026/07/26 08:53:09 by dnettoRaw
//    ##   ## ##   ##    U: 2026/07/26 08:53:09 by dnettoRaw
//      ###########      S: 1.0.1-rc.8
// =============================================================================

//! Capability resolver to locate appropriate workers.

use crate::connection::WorkerConnectionKey;
use crate::registry::CapabilityRegistry;
use appcore_types::CapabilityName;

/// Strategy to choose one worker from multiple candidates.
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub enum SelectionPolicy {
    /// Always picks the first available candidate.
    FirstAvailable,
}

/// Resolves worker targets for capability requests within a tenant partition.
#[derive(Debug, Clone)]
pub struct CapabilityResolver {
    policy: SelectionPolicy,
}

impl Default for CapabilityResolver {
    fn default() -> Self {
        Self {
            policy: SelectionPolicy::FirstAvailable,
        }
    }
}

impl CapabilityResolver {
    /// Creates a resolver with the default selection policy.
    pub fn new() -> Self {
        Self::default()
    }

    /// Resolves a worker connection key for a given capability using the registry.
    pub fn resolve(
        &self,
        capability: &CapabilityName,
        registry: &CapabilityRegistry,
    ) -> Option<WorkerConnectionKey> {
        let candidates = registry.resolve(capability)?;
        match self.policy {
            SelectionPolicy::FirstAvailable => candidates.iter().next().cloned(),
        }
    }
}