Struct StreamStorage 

pub struct StreamStorage { /* private fields */ }

Implementations

impl StreamStorage

pub fn open(dir: &Path, key: Keypair) -> Result<Self>

pub fn public_key(&self) -> &PublicKey

pub fn contains_doc(&self, doc: &DocId) -> Result<bool>

pub fn docs(&self) -> impl Iterator<Item = Result<DocId>>

pub fn contains_stream(&self, id: &StreamId) -> Result<bool>

pub fn streams(&self) -> impl Iterator<Item = Result<StreamId>>

pub fn substreams(&self, doc: DocId) -> impl Iterator<Item = Result<StreamId>>

pub fn head(&self, id: &StreamId) -> Result<Option<SignedHead>>

pub fn append(&mut self, doc: DocId) -> Result<StreamWriter<Arc<Keypair>>>

pub fn subscribe(&mut self, id: &StreamId) -> Result<StreamWriter<()>>

pub fn remove(&mut self, id: &StreamId) -> Result<()>

pub fn slice( &mut self, id: &StreamId, start: u64, len: u64, ) -> Result<StreamReader>

pub fn extract( &mut self, id: &StreamId, start: u64, len: u64, slice: &mut Slice, ) -> Result<()>