Module adapter 

Adapter trait and implementations for durable event storage.

Adapters provide the persistence layer for the event bus. They receive batches of events from the ingestion core and store them durably.

Adapter Contract

Adapters must:

• Append batches in received order
• Never block ingestion indefinitely
• Fail fast on internal errors
• Be idempotent under retry
• Preserve per-shard FIFO order
• NOT allocate memory per-event (only per-batch or static)

Available Adapters

• NoopAdapter: Discards events (for testing/benchmarking)
• RedisAdapter: Redis Streams backend (requires redis feature)
• JetStreamAdapter: NATS JetStream backend (requires jetstream feature)
• NetAdapter: High-performance UDP transport (requires net feature)

Re-exports

pub use self::net::NetAdapter;

pub use self::net::NetAdapterConfig;

Modules

net

Net L0 Transport Protocol (Net) adapter.

Structs

NoopAdapter

No-op adapter that discards all events.

PersistentProducerNonce

Persistent u64 nonce loaded from (or created at) a stable path.

ShardPollResult

Result of polling a single shard.

Traits

Adapter

Adapter trait for durable event storage.