Struct StreamingBlockTransfer 

pub struct StreamingBlockTransfer {
    pub transfers: HashMap<u64, BlockTransfer>,
    pub next_id: u64,
    pub current_tick: u64,
}

Manager for chunked, resumable block transfers between peers.

Each transfer is identified by a unique u64 transfer ID returned by StreamingBlockTransfer::start_transfer.

Fields

transfers: HashMap<u64, BlockTransfer>

All tracked transfers indexed by their transfer ID.

next_id: u64

Counter used to assign the next unique transfer ID.

current_tick: u64

Monotonically increasing logical clock.

Implementations

impl StreamingBlockTransfer

pub fn new() -> Self

Create a new, empty transfer manager.

pub fn start_transfer( &mut self, cid: String, peer_id: String, direction: TransferDirection, total_bytes: u64, chunk_size: u64, ) -> u64

Register a new transfer and return its assigned transfer ID.

The transfer begins in the TransferState::Pending state. If chunk_size is 0, it defaults to 65536.

pub fn receive_chunk( &mut self, transfer_id: u64, chunk: TransferChunk, ) -> Result<(), String>

Process an incoming chunk for the given transfer.

Errors

Returns an error string when:

• The transfer ID is unknown.
• The transfer is not in an InProgress or Pending state.
• The chunk checksum does not match its data.
• The chunk index has already been received.

pub fn pause(&mut self, transfer_id: u64) -> bool

Pause an active or pending transfer.

Returns true if the transfer was successfully paused, false otherwise (e.g., the transfer ID is unknown, or the transfer is already paused/done).

pub fn resume(&mut self, transfer_id: u64) -> bool

Resume a paused transfer.

Returns true if the transfer was successfully resumed, false otherwise.

pub fn fail(&mut self, transfer_id: u64, reason: String) -> bool

Mark a transfer as failed with a descriptive reason.

Returns true if the transfer was found and transitioned to TransferState::Failed, false if the ID is unknown or the transfer has already completed/failed.

pub fn stats(&self) -> TransferManagerStats

Compute aggregated statistics across all managed transfers.

pub fn advance_tick(&mut self)

Advance the logical clock by one tick.

Trait Implementations

impl Default for StreamingBlockTransfer

fn default() -> Self

Returns the “default value” for a type.