Struct IoTScapeServiceAsync

pub struct IoTScapeServiceAsync<SocketType: SocketTraitAsync = UdpSocket> {
    pub definition: ServiceDefinition,
    pub name: String,
    pub next_msg_id: AtomicU64,
    pub rx_queue: Arc<Mutex<VecDeque<Request>>>,
    pub tx_queue: Arc<Mutex<VecDeque<Response>>>,
    pub client: Client,
    /* private fields */
}

Fields

definition: ServiceDefinition

name: String

next_msg_id: AtomicU64

rx_queue: Arc<Mutex<VecDeque<Request>>>

tx_queue: Arc<Mutex<VecDeque<Response>>>

client: Client

Implementations

impl<SocketType: SocketTraitAsync> IoTScapeServiceAsync<SocketType>

pub async fn new( name: &str, definition: ServiceDefinition, server: SocketAddr, ) -> Self

pub async fn announce(&self) -> Result<usize, Error>

Send the service description to the server

pub async fn announce_lite(&self) -> Result<usize, Error>

Announce without full definition

pub async fn announce_http(&self, endpoint: &str) -> Result<Response, Error>

pub async fn poll(&self)

Handle rx/tx

pub async fn enqueue_response_to( &self, request: Request, params: Result<Vec<Value>, String>, ) -> Result<usize, Error>

Create a response to an Request and enqueue it for sending

pub async fn send_event( &self, call_id: &str, event_type: &str, args: BTreeMap<String, String>, ) -> Result<usize, Error>

Set an event message to be sent

pub async fn enqueue_response_to_http( &self, endpoint: &str, request: Request, params: Result<Vec<Value>, String>, ) -> Result<Response, Error>

Create a response to an Request and enqueue it for sending