Module storage 

Storage subsystem for chunk persistence.

This module provides content-addressed LMDB storage for chunks, along with a protocol handler that integrates with saorsa-core’s Protocol trait for automatic message routing.

Architecture

┌─────────────────────────────────────────────────────────┐
│        AntProtocol (implements Protocol trait)        │
├─────────────────────────────────────────────────────────┤
│  protocol_id() = "autonomi/ant/chunk/v1"                  │
│                                                         │
│  handle(peer_id, data) ──▶ decode AntProtocolMessage │
│                                   │                     │
│         ┌─────────────────────────┼─────────────────┐  │
│         ▼                         ▼                 ▼  │
│   QuoteRequest           ChunkPutRequest    ChunkGetRequest
│         │                         │                 │  │
│         ▼                         ▼                 ▼  │
│   QuoteGenerator          PaymentVerifier   LmdbStorage│
│         │                         │                 │  │
│         └─────────────────────────┴─────────────────┘  │
│                           │                             │
│                 return Ok(Some(response_bytes))         │
└─────────────────────────────────────────────────────────┘

Example

use std::sync::Arc;
use ant_node::storage::{AntProtocol, LmdbStorage, LmdbStorageConfig};

// Create storage
let config = LmdbStorageConfig::default();
let storage = Arc::new(LmdbStorage::new(config).await?);

// Create protocol handler
let protocol = AntProtocol::new(storage, Arc::new(payment_verifier), Arc::new(quote_generator));

// Register with saorsa-core
listener.register_protocol(protocol).await?;

Re-exports

pub use crate::ant_protocol::XorName;

Structs

AntProtocol

ANT protocol handler.

LmdbStorage

Content-addressed LMDB storage.

LmdbStorageConfig

Configuration for LMDB storage.

StorageStats

Statistics about storage operations.