Struct cyfs_bdt::StackOpenParams

source ·

pub struct StackOpenParams {
    pub config: StackConfig,
    pub tcp_port_mapping: Option<Vec<(Endpoint, u16)>>,
    pub known_sn: Option<Vec<Device>>,
    pub known_device: Option<Vec<Device>>,
    pub active_pn: Option<Vec<Device>>,
    pub passive_pn: Option<Vec<Device>>,
    pub outer_cache: Option<Box<dyn OuterDeviceCache>>,
    pub chunk_store: Option<Box<dyn ChunkReader>>,
    pub ndn_event: Option<Box<dyn NdnEventHandler>>,
}

Fields§

§config: StackConfig§tcp_port_mapping: Option<Vec<(Endpoint, u16)>>§known_sn: Option<Vec<Device>>§known_device: Option<Vec<Device>>§active_pn: Option<Vec<Device>>§passive_pn: Option<Vec<Device>>§outer_cache: Option<Box<dyn OuterDeviceCache>>§chunk_store: Option<Box<dyn ChunkReader>>§ndn_event: Option<Box<dyn NdnEventHandler>>

Implementations§

source §

impl StackOpenParams

source

pub fn new(isolate: &str) -> Self

Examples found in repository ?

examples/utils.rs (line 54)

pub async fn local_stack_pair_with_config(
    ln_ep: &[&str],
    rn_ep: &[&str],
    ln_config: Option<StackConfig>,
    rn_config: Option<StackConfig>,
) -> BuckyResult<((StackGuard, MemChunkStore), (StackGuard, MemChunkStore))> {
    let (ln_dev, ln_secret) = create_device("5aSixgLuJjfrNKn9D4z66TEM6oxL3uNmWCWHk52cJDKR", ln_ep)?;
    let (rn_dev, rn_secret) = create_device("5aSixgLuJjfrNKn9D4z66TEM6oxL3uNmWCWHk52cJDKR", rn_ep)?;

    let mut ln_params = StackOpenParams::new("");
    let ln_store = MemChunkStore::new();
    ln_params.chunk_store = Some(ln_store.clone_as_reader());
    let mut ln_config = ln_config;
    if ln_config.is_some() {
        std::mem::swap(&mut ln_params.config, ln_config.as_mut().unwrap());
    }

    ln_params.known_device = Some(vec![rn_dev.clone()]);
    let ln_stack = Stack::open(ln_dev.clone(), ln_secret, ln_params).await?;

    let mut rn_params = StackOpenParams::new("");
    let rn_store = MemChunkStore::new();
    rn_params.chunk_store = Some(rn_store.clone_as_reader());
    let mut rn_config = rn_config;
    if rn_config.is_some() {
        std::mem::swap(&mut rn_params.config, rn_config.as_mut().unwrap());
    }

    let rn_stack = Stack::open(rn_dev, rn_secret, rn_params).await?;

    Ok(((ln_stack, ln_store), (rn_stack, rn_store)))
}