Struct mles_utils::ResyncMsg
[−]
[src]
pub struct ResyncMsg { /* fields omitted */ }
ResyncMsg structure
This structure defines resynchronization Msg structure that can be used to resynchronize history state to root server from peers. The resynchronization message can be sent only during initial connection message and packs the history into one message that can be taken into account by Mles root server.
Methods
impl ResyncMsg
[src]
fn new(messages: &Vec<Vec<u8>>) -> ResyncMsg
[src]
Create a new ResyncMsg object with encoded message vector.
Example
use mles_utils::{Msg, ResyncMsg}; let msg = Msg::new("My uid".to_string(), "My channel".to_string(), Vec::new()); let msg = msg.encode(); let vec = vec![msg]; let rmsg = ResyncMsg::new(&vec);
fn len(&self) -> usize
[src]
Get the length of the resync message vector
Example
use mles_utils::{Msg, ResyncMsg}; let msg = Msg::new("My uid".to_string(), "My channel".to_string(), Vec::new()); let msg = msg.encode(); let vec = vec![msg]; let rmsg = ResyncMsg::new(&vec); assert_eq!(1, rmsg.len());
fn get_messages(&self) -> Vec<Vec<u8>>
[src]
Get all items of the resync message vector
Example
use mles_utils::{Msg, ResyncMsg}; let msg = Msg::new("My uid".to_string(), "My channel".to_string(), Vec::new()); let msg = msg.encode(); let vec = vec![msg]; let rmsg = ResyncMsg::new(&vec); let rvec = rmsg.get_messages(); assert_eq!(vec[0], rvec[0]);
fn encode(&self) -> Vec<u8>
[src]
Encode ResyncMsg object to CBOR.
Errors
If resync message cannot be encoded, an empty vector is returned.
Example
use mles_utils::{ResyncMsg, Msg}; let msg = Msg::new("My uid".to_string(), "My channel".to_string(), Vec::new()); let msg = msg.encode(); let vec = vec![msg]; let rmsg = ResyncMsg::new(&vec); let encoded_msg: Vec<u8> = rmsg.encode();
fn decode(slice: &[u8]) -> ResyncMsg
[src]
Decode CBOR byte string to ResyncMsg object.
Errors
If message cannot be decoded, a ResyncMsg structure with empty items is returned.
Example
use mles_utils::{ResyncMsg, Msg}; let msg = Msg::new("My uid".to_string(), "My channel".to_string(), Vec::new()); let msg = msg.encode(); let vec = vec![msg]; let rmsg = ResyncMsg::new(&vec); let encoded_msg: Vec<u8> = rmsg.encode(); let decoded_msg: ResyncMsg = ResyncMsg::decode(&encoded_msg); assert_eq!(1, decoded_msg.len());