Struct ContentAcquisitionManager 

pub struct ContentAcquisitionManager { /* private fields */ }

Manager for acquiring content from distributed peers

Implementations

impl ContentAcquisitionManager

pub fn new(content_store: ContentAddressableStore) -> Self

Create a new content acquisition manager

pub fn register_peer( &self, advertisement: PeerAdvertisement, ) -> Result<(), String>

Register a peer for content acquisition

pub fn resolve( &self, flow_ref: &FlowRef, policy: AcquisitionPolicy, ) -> Result<Option<Vec<u8>>, String>

Resolve a reference using the acquisition policy

pub fn verify_content( content: &[u8], expected_identity: &ContentIdentity, ) -> Result<(), ContentTransferError>

Verify content against its content identity

pub fn materialize( &self, flow_ref: &FlowRef, content: Vec<u8>, content_identity: &ContentIdentity, ) -> Result<(), String>

Materialize acquired content into local storage

pub fn get_local(&self, flow_ref: &FlowRef) -> Result<Option<Vec<u8>>, String>

Get content from local store

pub fn has_local(&self, flow_ref: &FlowRef) -> Result<bool, String>

Check if content exists locally

Trait Implementations

impl Clone for ContentAcquisitionManager

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for ContentAcquisitionManager

fn default() -> Self

Returns the “default value” for a type.