Struct iotscape::IoTScapeService

pub struct IoTScapeService<SocketType: SocketTrait = UdpSocket> {
    pub definition: ServiceDefinition,
    pub name: String,
    pub next_msg_id: u64,
    pub rx_queue: VecDeque<Request>,
    pub tx_queue: VecDeque<Response>,
    /* private fields */
}

Fields

definition: ServiceDefinition

name: String

next_msg_id: u64

rx_queue: VecDeque<Request>

tx_queue: VecDeque<Response>

Implementations

impl<SocketType: SocketTrait> IoTScapeService<SocketType>

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

pub fn announce(&mut self) -> Result<usize, String>

Send the service description to the server

pub fn poll(&mut self, timeout: Option<Duration>)

Handle rx/tx

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

Create a response to an Request and enqueue it for sending

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

Set an event message to be sent