diff --git a/src/lib.rs b/src/lib.rs index 885e2ec..ff46685 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -280,9 +280,10 @@ extern crate derive_builder; pub use near_indexer_primitives; pub use aws_credential_types::Credentials; +pub use providers::fastnear::client as fastnear_client; pub use providers::fastnear::types::{FastNearConfig, FastNearConfigBuilder}; +pub use providers::s3::client as s3_client; pub use providers::s3::types::{LakeConfig, LakeConfigBuilder}; - pub mod providers; pub(crate) const LAKE_FRAMEWORK: &str = "near_lake_framework"; diff --git a/src/providers/fastnear/client.rs b/src/providers/fastnear/client.rs index 103884a..1d25d37 100644 --- a/src/providers/fastnear/client.rs +++ b/src/providers/fastnear/client.rs @@ -9,9 +9,9 @@ pub struct FastNearClient { } impl FastNearClient { - pub fn new(config: &types::FastNearConfig) -> Self { + pub fn new(endpoint: String) -> Self { Self { - endpoint: config.endpoint.clone(), + endpoint, client: reqwest::Client::new(), } } diff --git a/src/providers/fastnear/mod.rs b/src/providers/fastnear/mod.rs index 7bfd008..6ec9ff0 100644 --- a/src/providers/fastnear/mod.rs +++ b/src/providers/fastnear/mod.rs @@ -12,7 +12,7 @@ pub async fn start( blocks_sink: tokio::sync::mpsc::Sender, config: types::FastNearConfig, ) -> anyhow::Result<()> { - let client = client::FastNearClient::new(&config); + let client = client::FastNearClient::new(config.endpoint); let max_num_threads = config.num_threads; let next_sink_block = std::sync::Arc::new(std::sync::atomic::AtomicU64::new(config.start_block_height));