Struct NoopAdapter 

pub struct NoopAdapter { /* private fields */ }

No-op adapter that discards all events.

This adapter is useful for:

• Measuring pure ingestion throughput
• Testing without a backend
• Development/prototyping

Implementations

impl NoopAdapter

pub fn new() -> Self

Create a new no-op adapter.

pub fn batches_received(&self) -> u64

Get the number of batches received.

pub fn events_received(&self) -> u64

Get the number of events received.

pub fn reset(&self)

Reset counters.

Trait Implementations

impl Adapter for NoopAdapter

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

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

Initialize the adapter.

fn on_batch<'life0, 'async_trait>( &'life0 self, batch: Arc<Batch>, ) -> Pin<Box<dyn Future<Output = Result<(), AdapterError>> + Send + 'async_trait>>

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

Process a batch of events.

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

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

Force flush any buffered data.

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

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

Gracefully shut down the adapter.

fn poll_shard<'life0, 'life1, 'async_trait>( &'life0 self, _shard_id: u16, _from_id: Option<&'life1 str>, _limit: usize, ) -> Pin<Box<dyn Future<Output = Result<ShardPollResult, AdapterError>> + Send + 'async_trait>>

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

Poll events from a single shard.

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

Get the adapter name (for logging/metrics).

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

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

Check if the adapter is healthy.

impl Debug for NoopAdapter

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

Formats the value using the given formatter.

impl Default for NoopAdapter

fn default() -> NoopAdapter

Returns the “default value” for a type.