mars-server · federation::discovery

Package: mars-server · Workspace version: 0.1.0 · Module: federation::discovery

This reference follows declared modules and public syntax, including public implementation methods. Function bodies and constant values are omitted. Feature conditions are retained. Private-module re-exports and trait resolution require the compiler; not every declaration is a root import.

federation::discovery::FederatedDiscoveryConfig

Federated query fanout, policy, and cursor bounds.

#[derive(Debug, Clone)]
pub struct FederatedDiscoveryConfig {
pub enabled: bool,
pub fanout: u32,
pub peer_timeout: StdDuration,
pub max_results_per_peer: u32,
/// Maximum remote result slots (`selected peers * per-peer result cap`)

/// consumed by one request.

pub max_cost: u64,
pub default_page_size: u64,
pub max_page_size: u64,
pub anchoring_required: bool,
pub cursor_ttl: Duration
}

Source line: 39.

federation::discovery::FederatedDiscoveryCoordinator

Optional fanout coordinator. Remote entries are treated as untrusted until envelope, publisher, query, visibility, and local anchor checks complete.

#[derive(Clone)]
pub struct FederatedDiscoveryCoordinator {

}

Source line: 80.

federation::discovery::FederatedDiscoveryCoordinator::new

#[allow(clippy::too_many_arguments)]
pub fn new(
        local: Arc<DiscoveryEngine>,
        store: Arc<dyn EntryStore>,
        transport: Arc<dyn FederationTransport>,
        signer: FederationSigner,
        verifier: FederationEnvelopeVerifier,
        validation: ValidationPipeline,
        config: FederatedDiscoveryConfig,
    ) -> Result<Self, ServerError>;

Source line: 92.

federation::discovery::FederatedDiscoveryCoordinator::execute

Execute using the server clock.

pub async fn execute(
        &self,
        query: &MarsQuery,
    ) -> Result<FederatedDiscoveryResult, ServerError>;

Source line: 114.

federation::discovery::FederatedDiscoveryCoordinator::execute_at

Deterministic clock entry point used by tests and replay tooling.

pub async fn execute_at(
        &self,
        query: &MarsQuery,
        now: DateTime<Utc>,
    ) -> Result<FederatedDiscoveryResult, ServerError>;

Source line: 122.

Source provenance

Source: mars-server/src/federation/discovery.rs · SHA-256 9f0ea2708dfe0a6e84c362c799bce0584f51c1188dcb0fec58bd2c6dc71b7051. Package overview.