Struct Computer

pub struct Computer { /* private fields */ }

Implementations

impl Computer

pub fn new( computed_dir: PathBuf, fetcher: Option<Fetcher>, compressed: bool, ) -> Self

Examples found in repository

examples/main.rs (line 35)

pub fn main() -> color_eyre::Result<()> {
    color_eyre::install()?;

    brk_logger::init(Some(Path::new(".log")));

    let bitcoin_dir = default_bitcoin_path();

    let rpc = Box::leak(Box::new(rpc::Client::new(
        "http://localhost:8332",
        rpc::Auth::CookieFile(bitcoin_dir.join(".cookie")),
    )?));
    let exit = Exit::new();

    let parser = Parser::new(bitcoin_dir.join("blocks"), rpc);

    let outputs_dir = Path::new("../../_outputs");

    let compressed = true;

    let mut indexer = Indexer::new(outputs_dir.join("indexed"), compressed, true)?;
    indexer.import_stores()?;
    indexer.import_vecs()?;

    let fetcher = Fetcher::import(None)?;

    let mut computer = Computer::new(outputs_dir.join("computed"), Some(fetcher), compressed);
    computer.import_stores()?;
    computer.import_vecs()?;

    let starting_indexes = indexer.index(&parser, rpc, &exit)?;

    computer.compute(&mut indexer, starting_indexes, &exit)?;

    Ok(())
}

pub fn import_vecs(&mut self) -> Result<()>

Examples found in repository

examples/main.rs (line 37)

pub fn main() -> color_eyre::Result<()> {
    color_eyre::install()?;

    brk_logger::init(Some(Path::new(".log")));

    let bitcoin_dir = default_bitcoin_path();

    let rpc = Box::leak(Box::new(rpc::Client::new(
        "http://localhost:8332",
        rpc::Auth::CookieFile(bitcoin_dir.join(".cookie")),
    )?));
    let exit = Exit::new();

    let parser = Parser::new(bitcoin_dir.join("blocks"), rpc);

    let outputs_dir = Path::new("../../_outputs");

    let compressed = true;

    let mut indexer = Indexer::new(outputs_dir.join("indexed"), compressed, true)?;
    indexer.import_stores()?;
    indexer.import_vecs()?;

    let fetcher = Fetcher::import(None)?;

    let mut computer = Computer::new(outputs_dir.join("computed"), Some(fetcher), compressed);
    computer.import_stores()?;
    computer.import_vecs()?;

    let starting_indexes = indexer.index(&parser, rpc, &exit)?;

    computer.compute(&mut indexer, starting_indexes, &exit)?;

    Ok(())
}

pub fn import_stores(&mut self) -> Result<()>

Do NOT import multiple times or things will break !!! Clone struct instead

Examples found in repository

examples/main.rs (line 36)

pub fn main() -> color_eyre::Result<()> {
    color_eyre::install()?;

    brk_logger::init(Some(Path::new(".log")));

    let bitcoin_dir = default_bitcoin_path();

    let rpc = Box::leak(Box::new(rpc::Client::new(
        "http://localhost:8332",
        rpc::Auth::CookieFile(bitcoin_dir.join(".cookie")),
    )?));
    let exit = Exit::new();

    let parser = Parser::new(bitcoin_dir.join("blocks"), rpc);

    let outputs_dir = Path::new("../../_outputs");

    let compressed = true;

    let mut indexer = Indexer::new(outputs_dir.join("indexed"), compressed, true)?;
    indexer.import_stores()?;
    indexer.import_vecs()?;

    let fetcher = Fetcher::import(None)?;

    let mut computer = Computer::new(outputs_dir.join("computed"), Some(fetcher), compressed);
    computer.import_stores()?;
    computer.import_vecs()?;

    let starting_indexes = indexer.index(&parser, rpc, &exit)?;

    computer.compute(&mut indexer, starting_indexes, &exit)?;

    Ok(())
}

impl Computer

pub fn compute( &mut self, indexer: &mut Indexer, starting_indexes: Indexes, exit: &Exit, ) -> Result<()>

Examples found in repository

examples/main.rs (line 41)

pub fn main() -> color_eyre::Result<()> {
    color_eyre::install()?;

    brk_logger::init(Some(Path::new(".log")));

    let bitcoin_dir = default_bitcoin_path();

    let rpc = Box::leak(Box::new(rpc::Client::new(
        "http://localhost:8332",
        rpc::Auth::CookieFile(bitcoin_dir.join(".cookie")),
    )?));
    let exit = Exit::new();

    let parser = Parser::new(bitcoin_dir.join("blocks"), rpc);

    let outputs_dir = Path::new("../../_outputs");

    let compressed = true;

    let mut indexer = Indexer::new(outputs_dir.join("indexed"), compressed, true)?;
    indexer.import_stores()?;
    indexer.import_vecs()?;

    let fetcher = Fetcher::import(None)?;

    let mut computer = Computer::new(outputs_dir.join("computed"), Some(fetcher), compressed);
    computer.import_stores()?;
    computer.import_vecs()?;

    let starting_indexes = indexer.index(&parser, rpc, &exit)?;

    computer.compute(&mut indexer, starting_indexes, &exit)?;

    Ok(())
}

pub fn path(&self) -> &Path

pub fn vecs(&self) -> &Vecs

pub fn mut_vecs(&mut self) -> &mut Vecs

pub fn stores(&self) -> &Stores

pub fn mut_stores(&mut self) -> &mut Stores

Trait Implementations

impl Clone for Computer

fn clone(&self) -> Computer

Returns a copy of the value.

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

Performs copy-assignment from source.