diff --git a/src/compression_engine.rs b/src/compression_engine.rs index 970197d..98a78ea 100755 --- a/src/compression_engine.rs +++ b/src/compression_engine.rs @@ -128,7 +128,7 @@ lazy_static! { }; } -pub fn get_engine(compression_type: CompressionType) -> Result> { +pub fn get_compression_engine(compression_type: CompressionType) -> Result> { match compression_type { CompressionType::LZ4 => Ok(Box::new(CompressionEngineLZ4::new())), CompressionType::GZip => Ok(Box::new(CompressionEngineGZip::new())), diff --git a/src/modes/get.rs b/src/modes/get.rs index e8b64e2..a5c4c90 100644 --- a/src/modes/get.rs +++ b/src/modes/get.rs @@ -38,7 +38,7 @@ pub fn mode_get( item_path.push(item.id.unwrap().to_string()); let compression_type = CompressionType::from_str(&item.compression)?; - let compression_engine = crate::compression_engine::get_engine(compression_type)?; + let compression_engine = crate::compression_engine::get_compression_engine(compression_type)?; compression_engine.cat(item_path.clone())?; Ok(()) diff --git a/src/modes/info.rs b/src/modes/info.rs index 02b3fed..b1ac04c 100644 --- a/src/modes/info.rs +++ b/src/modes/info.rs @@ -110,7 +110,7 @@ pub fn mode_info( ])); let compression_engine = - get_engine(compression_type).expect("Unable to get compression engine"); + get_compression_engine(compression_type).expect("Unable to get compression engine"); let magic = compression_engine.magic(item_path.clone()); let file_magic_cell = match magic { diff --git a/src/modes/save.rs b/src/modes/save.rs index 5dd49e5..b2086e3 100644 --- a/src/modes/save.rs +++ b/src/modes/save.rs @@ -131,7 +131,7 @@ pub fn mode_save( let mut stdout = io::stdout().lock(); let mut buffer = [0; libc::BUFSIZ as usize]; - let compression_engine = crate::compression_engine::get_engine(compression_type.clone()) + let compression_engine = crate::compression_engine::get_compression_engine(compression_type.clone()) .expect("Unable to get compression engine"); let mut item_out: Box = compression_engine diff --git a/src/modes/update.rs b/src/modes/update.rs index 0256f52..b53a9fb 100644 --- a/src/modes/update.rs +++ b/src/modes/update.rs @@ -47,7 +47,7 @@ pub fn mode_update( if item_file_metadata.is_ok() { debug!("MAIN: Updating stream size of {:?}", item_path); let compression_type = CompressionType::from_str(&item.compression)?; - let compression_engine = crate::compression_engine::get_engine(compression_type) + let compression_engine = crate::compression_engine::get_compression_engine(compression_type) .expect("Unable to get compression engine"); let size = compression_engine.size(item_path)? as i64; item.size = Some(size);