Struct EventSender

pub struct EventSender { /* private fields */ }

Implementations

impl EventSender

pub fn queue(&mut self, payload: &[u8]) -> Result<u64, Error>

pub fn due(&mut self, now: u64, budget: usize) -> Vec<EventPacket>

Returns at most budget events. Call with a monotonic millisecond clock.

pub fn acknowledge(&mut self, sequence: u64) -> bool

Acknowledgments are individual, so loss of an earlier event cannot be hidden by a newer ACK.

pub fn pending(&self) -> usize

Trait Implementations

impl Default for EventSender

fn default() -> EventSender

Returns the “default value” for a type.