Struct keri_controller::communication::Communication

pub struct Communication {
    pub events: Arc<KnownEvents>,
    pub transport: Box<dyn Transport + Send + Sync>,
    pub tel_transport: Box<dyn GeneralTelTransport + Send + Sync>,
}

Fields

events: Arc<KnownEvents>

transport: Box<dyn Transport + Send + Sync>

tel_transport: Box<dyn GeneralTelTransport + Send + Sync>

Implementations

impl Communication

pub fn new( known_events: Arc<KnownEvents>, transport: Box<dyn Transport<ActorError> + Send + Sync>, tel_transport: Box<dyn GeneralTelTransport + Send + Sync> ) -> Self

pub async fn resolve_loc_schema( &self, lc: &LocationScheme ) -> Result<(), ControllerError>

Make http request to get identifier’s endpoints information.

pub async fn resolve_end_role( &self, er: &EndRole ) -> Result<(), ControllerError>

Make http request to get identifier’s endpoints information.

pub async fn resolve_oobi(&self, oobi: &Oobi) -> Result<(), ControllerError>

Make http request to get identifier’s endpoints information.

pub async fn send_message_to( &self, id: &IdentifierPrefix, scheme: Scheme, msg: Message ) -> Result<(), ControllerError>

pub async fn send_query_to( &self, id: &IdentifierPrefix, scheme: Scheme, query: SignedKelQuery ) -> Result<PossibleResponse, ControllerError>

pub async fn publish( &self, witness_prefixes: &[BasicPrefix], message: &SignedEventMessage ) -> Result<(), ControllerError>

Publish key event to witnesses

1. send it to all witnesses
2. collect witness receipts and process them
3. get processed receipts from db and send it to all witnesses

pub async fn send_oobi_to_watcher( &self, id: &IdentifierPrefix, oobi: &Oobi ) -> Result<(), ControllerError>

Sends identifier’s endpoint information to identifiers’s watchers.