Trait rings_node::prelude::chunk::ChunkManager

pub trait ChunkManager {
    // Required methods
    fn list_completed(&self) -> Vec<Uuid, Global>;
    fn list_pending(&self) -> Vec<Uuid, Global>;
    fn get(&self, id: Uuid) -> Option<Bytes>;
    fn remove(&mut self, id: Uuid);
    fn remove_expired(&mut self);
    fn handle(&mut self, chunk: Chunk) -> Option<Bytes>;
}

A helper for manage chunks and chunk pool

Required Methods

fn list_completed(&self) -> Vec<Uuid, Global>

list completed Chunks;

fn list_pending(&self) -> Vec<Uuid, Global>

list pending Chunks;

fn get(&self, id: Uuid) -> Option<Bytes>

get sepc msg via uuid if a msg is not completed, it will returns None

fn remove(&mut self, id: Uuid)

remove all chunks of id

fn remove_expired(&mut self)

remove expired chunks by ttl

fn handle(&mut self, chunk: Chunk) -> Option<Bytes>

handle a chunk

Implementors

impl<const MTU: usize> ChunkManager for ChunkList<MTU>