Struct HeavyDecoyProvider 

pub struct HeavyDecoyProvider<T: IdentityType + Clone + 'static, AE: AsyncExecutor + 'static> { /* private fields */ }

Heavy mode implements sending large decoy packets at a low cadence (background-heartbeat shape).

Trait Implementations

impl<T: IdentityType + Clone, AE: AsyncExecutor> DecoyCommunicationMode<T, AE> for HeavyDecoyProvider<T, AE>

fn new( manager: Weak<dyn DecoyFlowSender>, settings: Arc<Settings<AE>>, identity: DerivedValue<T>, counter: Arc<AtomicU32>, fallthrough_probability: Option<f64>, ) -> Self

Create a new decoy provider; counter is the per-session monotonic packet-number counter shared with the session manager and the health-check provider; every emitted decoy packet advances it. fallthrough_probability pins the per-flow fallthrough rate, None samples from the settings keys.

fn name() -> &'static str

Short name of this provider, derived from the type name (no path, no generics).

impl<T: IdentityType + Clone + 'static, AE: AsyncExecutor + 'static> DecoyProvider for HeavyDecoyProvider<T, AE>

fn name(&self) -> &'static str

Short display name of this provider (e.g. “SparseDecoyProvider”).

fn start<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Start the background decoy generation timer.

fn feed_input<'life0, 'async_trait>( &'life0 self, packet: DynamicByteBuffer, _tailer_buf: DynamicByteBuffer, ) -> Pin<Box<dyn Future<Output = Option<DynamicByteBuffer>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Process an incoming packet, updating internal rate tracking. tailer_buf is the deobfuscated tailer for the packet (flags, packet number, etc.).

fn feed_output<'life0, 'async_trait>( &'life0 self, body: DynamicByteBuffer, tailer_buf: DynamicByteBuffer, ) -> Pin<Box<dyn Future<Output = Option<DynamicByteBuffer>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Process an outgoing packet body and its plaintext tailer, updating internal rate tracking. Returns the (possibly modified) body, or None to suppress the packet entirely.