[][src]Struct channel_protocol::ChannelProtocol

pub struct ChannelProtocol { /* fields omitted */ }

Channel protocol structure

Methods

impl Protocol[src]

pub fn new(host_ip: &str, remote_addr: &str, data_len: u32) -> Self[src]

Create a new channel protocol instance using an automatically assigned UDP socket

Arguments

  • host_ip - The local IP address
  • remote_addr - The remote IP and port to communicate with
  • data_len - Max payload length

Errors

If this function encounters any errors, it will panic

Examples

use channel_protocol::*;

let channel_protocol = ChannelProtocol::new("0.0.0.0", "192.168.0.1:7000", 4096);

pub fn set_remote(&mut self, remote: SocketAddr)[src]

Set new remote address on existing channel procotol structure

Arguments

  • remote - New remote address

pub fn send(&self, vec: &[u8]) -> Result<(), ProtocolError>[src]

Send CBOR packet to the destination port

Arguments

  • vec - CBOR packet to send

Errors

If this function encounters any errors, it will return an error message string

Examples

use channel_protocol::*;
use serde_cbor::ser;

let c_protocol = ChannelProtocol::new("0.0.0.0", "0.0.0.0:7000", 4096);
let message = ser::to_vec_packed(&"ping").unwrap();

c_protocol.send(&message);

pub fn recv_raw(
    &self,
    timeout: Option<Duration>
) -> Result<Value, ProtocolError>
[src]

Receive a raw cbor message message

Arguments

  • timeout - Maximum time to wait for a reply. If None, will block indefinitely

Errors

  • If this function times out, it will return Err(ProtocolError::ReceiveTimeout)
  • If this function encounters any errors, it will return an error message string

Examples

use channel_protocol::*;
use std::time::Duration;

let c_protocol = ChannelProtocol::new("0.0.0.0", "0.0.0.0:7000", 4096);

let message = match c_protocol.recv_raw(Some(Duration::from_secs(1))) {
    Ok(data) => data,
    Err(ProtocolError::ReceiveTimeout) =>  {
        println!("Timeout waiting for message");
        return;
    }
    Err(err) => panic!("Failed to receive message: {}", err),
};

pub fn recv_message(
    &self,
    timeout: Option<Duration>
) -> Result<Message, ProtocolError>
[src]

Receive a parsed channel procotol message

Arguments

  • timeout - Maximum time to wait for a reply. If None, will block indefinitely

Errors

  • If this function times out, it will return Err(ProtocolError::ReceiveTimeout)
  • If this function encounters any errors, it will return an error message string

Examples

use channel_protocol::*;
use std::time::Duration;

let c_protocol = ChannelProtocol::new("0.0.0.0", "0.0.0.0:7000", 4096);

let message = match c_protocol.recv_message(Some(Duration::from_secs(1))) {
    Ok(data) => data,
    Err(ProtocolError::ReceiveTimeout) =>  {
        println!("Timeout waiting for message");
        return;
    }
    Err(err) => panic!("Failed to receive message: {}", err),
};

Auto Trait Implementations

impl Send for Protocol

impl Unpin for Protocol

impl !Sync for Protocol

impl UnwindSafe for Protocol

impl !RefUnwindSafe for Protocol

Blanket Implementations

impl<T, U> Into<U> for T where
    U: From<T>, 
[src]

impl<T> From<T> for T[src]

impl<T, U> TryFrom<U> for T where
    U: Into<T>, 
[src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, 
[src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

impl<T> BorrowMut<T> for T where
    T: ?Sized
[src]

impl<T> Borrow<T> for T where
    T: ?Sized
[src]

impl<T> Any for T where
    T: 'static + ?Sized
[src]