Struct AcpAgent 

pub struct AcpAgent {
    pub identity: AgentIdentity,
    pub identity_document: Map<String, Value>,
    pub discovery: DiscoveryClient,
    pub transport: TransportClient,
    pub amqp_transport: Option<AmqpTransportClient>,
    pub mqtt_transport: Option<MqttTransportClient>,
    pub capabilities: AgentCapabilities,
    pub storage_dir: PathBuf,
    pub trust_profile: String,
    pub relay_url: String,
    pub default_delivery_mode: DeliveryMode,
    pub key_provider_info: KeyProviderInfo,
    /* private fields */
}

Fields

identity: AgentIdentity

identity_document: Map<String, Value>

discovery: DiscoveryClient

transport: TransportClient

amqp_transport: Option<AmqpTransportClient>

mqtt_transport: Option<MqttTransportClient>

capabilities: AgentCapabilities

storage_dir: PathBuf

trust_profile: String

relay_url: String

default_delivery_mode: DeliveryMode

key_provider_info: KeyProviderInfo

Implementations

impl AcpAgent

pub fn load_or_create( agent_id: &str, options: Option<AcpAgentOptions>, ) -> AcpResult<Self>

pub fn agent_id(&self) -> &str

pub fn get_delivery_states(&self) -> &HashMap<String, HashMap<String, String>>

pub fn build_well_known_document( &self, base_url: Option<&str>, identity_document_url: Option<&str>, ) -> AcpResult<Map<String, Value>>

pub fn register_identity_document( &mut self, identity_document: Map<String, Value>, ) -> AcpResult<()>

pub fn resolve_well_known( &mut self, base_url: &str, expected_agent_id: Option<&str>, ) -> AcpResult<Map<String, Value>>

pub fn send( &mut self, recipients: Vec<String>, payload: Map<String, Value>, context: Option<String>, message_class: MessageClass, expires_in_seconds: i64, correlation_id: Option<String>, in_reply_to: Option<String>, delivery_mode: Option<DeliveryMode>, ) -> AcpResult<SendResult>

pub fn send_basic( &mut self, recipients: Vec<String>, payload: Map<String, Value>, context: Option<String>, ) -> AcpResult<SendResult>

pub fn send_compensate( &mut self, recipients: Vec<String>, original_operation_id: &str, reason: &str, actions: Vec<Map<String, Value>>, context: Option<String>, delivery_mode: Option<DeliveryMode>, ) -> AcpResult<SendResult>

pub fn decrypt_message_for_self( &mut self, raw_message: &Map<String, Value>, ) -> AcpResult<DecryptedMessage>

pub fn receive( &mut self, raw_message: &Map<String, Value>, handler: Option<&InboundHandlerFn>, ) -> InboundResult

pub fn request_capabilities( &mut self, recipient: &str, ) -> AcpResult<CapabilityRequestResult>

pub fn consume_from_amqp<F>( &mut self, max_messages: usize, handler: Option<F>, ) -> AcpResult<usize>

where F: Fn(&Map<String, Value>, &Envelope) -> Option<Map<String, Value>> + Send + 'static,

pub fn consume_from_mqtt<F>( &mut self, max_messages: usize, handler: Option<F>, ) -> AcpResult<usize>

where F: Fn(&Map<String, Value>, &Envelope) -> Option<Map<String, Value>> + Send + 'static,

Trait Implementations

impl Clone for AcpAgent

fn clone(&self) -> AcpAgent

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for AcpAgent

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.