diff options
Diffstat (limited to 'rust/src/bin/fatcat-export.rs')
-rw-r--r-- | rust/src/bin/fatcat-export.rs | 10 |
1 files changed, 4 insertions, 6 deletions
diff --git a/rust/src/bin/fatcat-export.rs b/rust/src/bin/fatcat-export.rs index 82f40048..d6764dc6 100644 --- a/rust/src/bin/fatcat-export.rs +++ b/rust/src/bin/fatcat-export.rs @@ -13,17 +13,15 @@ extern crate failure; use clap::{App, Arg}; use fatcat::entity_crud::*; -use fatcat::errors::*; -use fatcat::identifiers::*; -use fatcat::server::*; +use fatcat::errors::Result; +use fatcat::identifiers::FatcatId; +use fatcat::server::{DbConn, self}; use fatcat_api_spec::models::*; use std::str::FromStr; use uuid::Uuid; use std::thread; -//use std::io::{Stdout,StdoutLock}; use crossbeam_channel as channel; -//use num_cpus; TODO: use std::io::prelude::*; use std::io::{BufReader, BufWriter}; @@ -158,7 +156,7 @@ pub fn do_export( entity_type: ExportEntityType, redirects: bool, ) -> Result<()> { - let db_pool = database_worker_pool()?; + let db_pool = server::database_worker_pool()?; let buf_input = BufReader::new(std::io::stdin()); let (row_sender, row_receiver) = channel::bounded(CHANNEL_BUFFER_LEN); let (output_sender, output_receiver) = channel::bounded(CHANNEL_BUFFER_LEN); |