Struct DiscoveryCoordinator 

pub struct DiscoveryCoordinator<S = GrowableInterfaceDiscoveryStorage>
where
    S: InterfaceDiscoveryStorage,
{ /* private fields */ }

Implementations

impl DiscoveryCoordinator

pub fn new(policy: InterfaceDiscoveryPolicy) -> DiscoveryCoordinator

impl<S> DiscoveryCoordinator<S>

where S: InterfaceDiscoveryStorage,

pub fn with_storage(policy: InterfaceDiscoveryPolicy) -> DiscoveryCoordinator<S>

pub const fn ingress_filter(&self) -> DiscoveryIngressFilter

pub fn seed_catalog( &mut self, catalog: DiscoveryCatalog<<S as InterfaceDiscoveryStorage>::Catalog>, )

pub fn reserve_endpoint( &mut self, endpoint: DiscoveredConnectionEndpointId, ) -> Result<DiscoveryEndpointReservation, DiscoveryEndpointReservationError>

pub fn reserve_network_endpoint( &mut self, host: &str, port: u16, ) -> Result<DiscoveryEndpointReservation, DiscoveryEndpointReservationError>

pub const fn catalog( &self, ) -> &DiscoveryCatalog<<S as InterfaceDiscoveryStorage>::Catalog>

pub fn startup(&self, now: InstantMillis) -> Vec<DiscoveryCoordinatorOutput>

pub fn observe_announce( &mut self, observation: AnnounceObservation<'_>, now: InstantMillis, decrypt: impl FnOnce(&[u8]) -> Result<Vec<u8>, DiscoveryDecryptionError>, ) -> Vec<DiscoveryCoordinatorOutput>

pub fn observe_announce_with_blackholes( &mut self, observation: AnnounceObservation<'_>, now: InstantMillis, decrypt: impl FnOnce(&[u8]) -> Result<Vec<u8>, DiscoveryDecryptionError>, blackholed: &[IdentityHash], ) -> Vec<DiscoveryCoordinatorOutput>

pub fn reconcile_blackholes( &mut self, blackholed: &[IdentityHash], ) -> Vec<DiscoveryCoordinatorOutput>

pub fn maintain( &mut self, now: InstantMillis, health: impl IntoIterator<Item = (InterfaceId, DiscoveredConnectionHealth)>, ) -> Vec<DiscoveryCoordinatorOutput>

pub fn attachment_succeeded( &mut self, plan: DiscoveredConnectionPlan, interface: InterfaceId, ) -> Result<DiscoveryCoordinatorEvent, Box<DiscoveryAttachmentRegistrationFailure>>