refactor(dataset-store): rename dataset-store crate to amp-dataset-store

crates/bin/ampctl/Cargo.toml

@@ -20,7 +20,7 @@ anyhow.workspace = true
 clap.workspace = true
 common = { path = "../../core/common" }
 console = "0.16.1"
-dataset-store = { path = "../../core/dataset-store" }
+amp-dataset-store = { path = "../../core/dataset-store" }
 datasets-common = { path = "../../core/datasets-common" }
 dump = { path = "../../core/dump" }
 eth-beacon-datasets = { path = "../../extractors/eth-beacon" }

crates/bin/ampctl/src/cmd/manifest/generate.rs

@@ -24,7 +24,7 @@
 
 use std::path::PathBuf;
 
-use dataset_store::DatasetKind;
+use amp_dataset_store::DatasetKind;
 use datasets_common::manifest::{ArrowSchema, Field, TableSchema};
 use monitoring::logging;
 
@@ -96,7 +96,7 @@ where
     let kind = kind.into();
 
     let dataset_bytes = match kind {
-        dataset_store::DatasetKind::EvmRpc => {
+        DatasetKind::EvmRpc => {
             let tables = evm_rpc_datasets::tables::all(&network)
                 .iter()
                 .map(|table| {
@@ -114,7 +114,7 @@ where
             };
             serde_json::to_vec_pretty(&manifest).map_err(Error::Serialization)?
         }
-        dataset_store::DatasetKind::Solana => {
+        DatasetKind::Solana => {
             let tables = solana_datasets::tables::all(&network)
                 .iter()
                 .map(|table| {
@@ -132,7 +132,7 @@ where
             };
             serde_json::to_vec_pretty(&manifest).map_err(Error::Serialization)?
         }
-        dataset_store::DatasetKind::EthBeacon => {
+        DatasetKind::EthBeacon => {
             let tables = eth_beacon_datasets::all_tables(network.clone())
                 .iter()
                 .map(|table| {
@@ -150,7 +150,7 @@ where
             };
             serde_json::to_vec_pretty(&manifest).map_err(Error::Serialization)?
         }
-        dataset_store::DatasetKind::Firehose => {
+        DatasetKind::Firehose => {
             let tables = firehose_datasets::evm::tables::all(&network)
                 .iter()
                 .map(|table| {
@@ -169,7 +169,7 @@ where
             };
             serde_json::to_vec_pretty(&manifest).map_err(Error::Serialization)?
         }
-        dataset_store::DatasetKind::Derived => {
+        DatasetKind::Derived => {
             return Err(Error::DerivedNotSupported);
         }
     };

crates/bin/ampd/Cargo.toml

@@ -20,7 +20,7 @@ common = { path = "../../core/common" }
 config = { path = "../../config" }
 console-subscriber = { version = "0.4.1", default-features = false, optional = true }
 controller = { path = "../../services/controller" }
-dataset-store = { path = "../../core/dataset-store" }
+amp-dataset-store = { path = "../../core/dataset-store" }
 metadata-db = { path = "../../core/metadata-db" }
 monitoring = { path = "../../core/monitoring" }
 server = { path = "../../services/server" }

crates/bin/ampd/src/controller_cmd.rs

@@ -1,12 +1,12 @@
 use std::{net::SocketAddr, sync::Arc};
 
+use amp_dataset_store::{
+    DatasetStore, manifests::DatasetManifestsStore, providers::ProviderConfigsStore,
+};
 use amp_object_store::ObjectStoreCreationError;
 use common::{BoxError, store::Store};
 use config::Config as CommonConfig;
 use controller::config::Config;
-use dataset_store::{
-    DatasetStore, manifests::DatasetManifestsStore, providers::ProviderConfigsStore,
-};
 use monitoring::telemetry::metrics::Meter;
 
 /// Run the controller service (Admin API server)

crates/bin/ampd/src/server_cmd.rs

@@ -1,11 +1,11 @@
 use std::sync::Arc;
 
+use amp_dataset_store::{
+    DatasetStore, manifests::DatasetManifestsStore, providers::ProviderConfigsStore,
+};
 use amp_object_store::ObjectStoreCreationError;
 use common::{BoxError, store::Store};
 use config::{Addrs, Config as CommonConfig};
-use dataset_store::{
-    DatasetStore, manifests::DatasetManifestsStore, providers::ProviderConfigsStore,
-};
 use monitoring::telemetry::metrics::Meter;
 use server::config::Config as ServerConfig;
 

crates/bin/ampd/src/solo_cmd.rs

@@ -1,11 +1,11 @@
 use std::{future::Future, pin::Pin, sync::Arc};
 
+use amp_dataset_store::{
+    DatasetStore, manifests::DatasetManifestsStore, providers::ProviderConfigsStore,
+};
 use amp_object_store::ObjectStoreCreationError;
 use common::{BoxError, store::Store};
 use config::Config as CommonConfig;
-use dataset_store::{
-    DatasetStore, manifests::DatasetManifestsStore, providers::ProviderConfigsStore,
-};
 use monitoring::telemetry::metrics::Meter;
 
 use crate::{controller_cmd, server_cmd, worker_cmd};

crates/bin/ampd/src/worker_cmd.rs

@@ -1,9 +1,9 @@
+use amp_dataset_store::{
+    DatasetStore, manifests::DatasetManifestsStore, providers::ProviderConfigsStore,
+};
 use amp_object_store::ObjectStoreCreationError;
 use common::store::Store;
 use config::Config;
-use dataset_store::{
-    DatasetStore, manifests::DatasetManifestsStore, providers::ProviderConfigsStore,
-};
 use monitoring::telemetry::metrics::Meter;
 use worker::node_id::NodeId;
 

crates/core/dataset-store/Cargo.toml

@@ -1,5 +1,5 @@
 [package]
-name = "dataset-store"
+name = "amp-dataset-store"
 edition.workspace = true
 version.workspace = true
 license-file.workspace = true

crates/core/dump/Cargo.toml

@@ -9,7 +9,7 @@ async-stream.workspace = true
 metadata-db = { path = "../metadata-db" }
 common = { path = "../common" }
 datafusion.workspace = true
-dataset-store = { path = "../dataset-store" }
+amp-dataset-store = { path = "../dataset-store" }
 datasets-derived = { path = "../datasets-derived" }
 datasets-common = { path = "../datasets-common" }
 futures.workspace = true

crates/core/dump/src/derived_dataset.rs

@@ -243,7 +243,7 @@ pub enum Error {
     ///
     /// The manifest is required to determine table definitions and SQL queries.
     #[error("Failed to get derived manifest")]
-    GetDerivedManifest(#[source] dataset_store::GetDerivedManifestError),
+    GetDerivedManifest(#[source] amp_dataset_store::GetDerivedManifestError),
 
     /// Failed to dump individual table
     ///

crates/core/dump/src/lib.rs

@@ -2,12 +2,12 @@
 
 use std::sync::Arc;
 
+use amp_dataset_store::{DatasetKind, DatasetStore};
 use common::{
     catalog::physical::PhysicalTable,
     parquet::file::properties::WriterProperties as ParquetWriterProperties,
     store::Store as DataStore,
 };
-use dataset_store::{DatasetKind, DatasetStore};
 use datasets_common::hash_reference::HashReference;
 use metadata_db::{MetadataDb, NotificationMultiplexerHandle};
 

crates/core/dump/src/raw_dataset.rs

@@ -220,7 +220,7 @@ pub enum Error {
     /// - Manifest not registered in metadata database
     /// - Network connectivity issues to provider
     #[error("Failed to get blockchain client for dataset")]
-    GetClient(#[source] dataset_store::GetClientError),
+    GetClient(#[source] amp_dataset_store::GetClientError),
 
     /// Failed to resolve end block number
     ///

crates/core/dump/src/streaming_query.rs

@@ -7,6 +7,7 @@ use std::{
 };
 
 use alloy::{hex::ToHexExt as _, primitives::BlockHash};
+use amp_dataset_store::DatasetStore;
 use common::{
     BlockNum, BoxError, Dataset, DetachedLogicalPlan, LogicalCatalog, PlanningContext,
     QueryContext, SPECIAL_BLOCK_NUM, Store,
@@ -19,7 +20,6 @@ use common::{
     sql_str::SqlStr,
 };
 use datafusion::{common::cast::as_fixed_size_binary_array, error::DataFusionError};
-use dataset_store::DatasetStore;
 use datasets_common::{
     hash::Hash, name::Name, partial_reference::PartialReference, revision::Revision,
 };

crates/core/monitoring/src/logging.rs

@@ -66,6 +66,7 @@ const AMP_CRATES: &[&str] = &[
     "admin_api",
     "admin_client",
     "amp_client",
+    "amp_dataset_store",
     "amp_object_store",
     "ampcc",
     "ampctl",
@@ -77,7 +78,6 @@ const AMP_CRATES: &[&str] = &[
     "common",
     "config",
     "controller",
-    "dataset_store",
     "datasets_common",
     "datasets_derived",
     "datasets_raw",