Struct DuplicateWindow 

pub struct DuplicateWindow { /* private fields */ }

Bounded exact-byte duplicate window.

Implementations

impl DuplicateWindow

pub const fn new(capacity: usize) -> Self

Creates a duplicate window retaining at most capacity packet byte sequences. A zero-capacity window never retains packets.

Examples found in repository

examples/service_toolkit.rs (line 12)

fn main() -> Result<(), libaprs_engine::ParseError> {
    let mut engine = Engine::default();
    let mut duplicates = DuplicateWindow::new(128);
    let mut rate = PacketRateBudget::new(100);
    let blocked = SemanticBlocklist::new(&[SemanticFamily::Unsupported, SemanticFamily::Malformed]);

    for packet_bytes in [b"N0CALL>APRS:>service".as_slice()] {
        if rate.try_consume() == RateLimitDecision::Limited {
            continue;
        }
        if duplicates.observe(packet_bytes) == DuplicateDecision::Duplicate {
            continue;
        }

        let packet = parse_packet(packet_bytes)?;
        if blocked.rejects(&packet.aprs_data()) {
            continue;
        }

        let _event = engine.process_event(packet.raw().as_bytes());
    }

    Ok(())
}

pub fn observe(&mut self, packet: &[u8]) -> DuplicateDecision

Observes packet bytes and reports whether the exact bytes were recently retained.

Examples found in repository

examples/service_toolkit.rs (line 20)

fn main() -> Result<(), libaprs_engine::ParseError> {
    let mut engine = Engine::default();
    let mut duplicates = DuplicateWindow::new(128);
    let mut rate = PacketRateBudget::new(100);
    let blocked = SemanticBlocklist::new(&[SemanticFamily::Unsupported, SemanticFamily::Malformed]);

    for packet_bytes in [b"N0CALL>APRS:>service".as_slice()] {
        if rate.try_consume() == RateLimitDecision::Limited {
            continue;
        }
        if duplicates.observe(packet_bytes) == DuplicateDecision::Duplicate {
            continue;
        }

        let packet = parse_packet(packet_bytes)?;
        if blocked.rejects(&packet.aprs_data()) {
            continue;
        }

        let _event = engine.process_event(packet.raw().as_bytes());
    }

    Ok(())
}

pub fn retained_len(&self) -> usize

Returns the number of packet byte sequences currently retained.

pub const fn capacity(&self) -> usize

Returns the configured retention capacity.

Trait Implementations

impl Clone for DuplicateWindow

fn clone(&self) -> DuplicateWindow

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for DuplicateWindow

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl PartialEq for DuplicateWindow

fn eq(&self, other: &DuplicateWindow) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for DuplicateWindow

impl StructuralPartialEq for DuplicateWindow