Accumulator Step (#164)

Author: just-in-chang

aptos-indexer-processors-sdk/Cargo.toml

@@ -21,8 +21,8 @@ rust-version = "1.78"
 [workspace.dependencies]
 aptos-indexer-processor-sdk = { path = "sdk" }
 aptos-indexer-transaction-stream = { path = "transaction-stream" }
-instrumented-channel = { path = "instrumented-channel" }
 aptos-moving-average = { path = "moving-average" }
+instrumented-channel = { path = "instrumented-channel" }
 sample = { path = "sample" }
 
 ahash = { version = "0.8.7", features = ["serde"] }
@@ -38,6 +38,8 @@ bcs = { git = "https://github.com/aptos-labs/bcs.git", rev = "d31fab9d81748e2594
 bigdecimal = { version = "0.4.0", features = ["serde"] }
 chrono = { version = "0.4.19", features = ["clock", "serde"] }
 clap = { version = "4.3.5", features = ["derive", "unstable-styles"] }
+delegate = "0.12.0"
+derive_builder = "0.20.0"
 # Do NOT enable the postgres feature here, it is conditionally enabled in a feature
 # block in the Cargo.toml file for the processor crate.
 # https://github.com/aptos-labs/aptos-indexer-processors/pull/325
@@ -54,8 +56,6 @@ diesel-async = { version = "0.7.4", features = [
     "tokio",
 ] }
 diesel_migrations = { version = "2.1.0", features = ["postgres"] }
-delegate = "0.12.0"
-derive_builder = "0.20.0"
 field_count = "0.1.1"
 futures = "0.3.30"
 futures-util = "0.3.21"
@@ -84,7 +84,6 @@ tempfile = "3.3.0"
 testcontainers = "0.20.1"
 thiserror = "1.0.61"
 tiny-keccak = { version = "2.0.2", features = ["keccak", "sha3"] }
-tracing = "0.1.34"
 tokio = { version = "1.37.0", features = [
     "rt",
     "rt-multi-thread",
@@ -102,6 +101,7 @@ tonic = { version = "0.12.3", features = [
     "codegen",
     "zstd",
 ] }
+tracing = "0.1.34"
 tracing-subscriber = { version = "0.3.17", features = ["json", "env-filter"] }
 url = { version = "2.5.1", features = ["serde"] }
 

aptos-indexer-processors-sdk/sdk/Cargo.toml

@@ -11,6 +11,41 @@ publish = { workspace = true }
 repository = { workspace = true }
 rust-version = { workspace = true }
 
+[features]
+# Server framework feature enables the HTTP server with metrics and health check endpoints.
+# This requires tokio net features for the TCP listener.
+server_framework = [
+    "autometrics",
+    "axum",
+    "backtrace",
+    "clap",
+    "toml",
+    "tracing-subscriber",
+    "tokio/net",
+]
+postgres_partial = [
+    "diesel",
+    "diesel-async",
+    "diesel_migrations",
+    "field_count",
+    "postgres-native-tls",
+    "native-tls",
+    "server_framework",
+    "tokio-postgres",
+]
+# When using the postgres_full features we enable the diesel/postgres feature. We configure
+# it in a feature so the CLI can opt out, since it cannot tolerate the libpq dep.
+# Recall that features should always be additive.
+postgres_full = ["postgres_partial", "diesel/postgres"]
+testing_framework = [
+    "testcontainers",
+    "tonic",
+    "tokio-retry",
+    "tokio-stream",
+    "tokio/net",
+]
+default = []
+
 [dependencies]
 ahash = { workspace = true }
 anyhow = { workspace = true }
@@ -64,38 +99,3 @@ url = { workspace = true }
 
 [target.'cfg(target_os = "linux")'.dependencies]
 aptos-system-utils = { workspace = true }
-
-[features]
-# Server framework feature enables the HTTP server with metrics and health check endpoints.
-# This requires tokio net features for the TCP listener.
-server_framework = [
-    "autometrics",
-    "axum",
-    "backtrace",
-    "clap",
-    "toml",
-    "tracing-subscriber",
-    "tokio/net",
-]
-postgres_partial = [
-    "diesel",
-    "diesel-async",
-    "diesel_migrations",
-    "field_count",
-    "postgres-native-tls",
-    "native-tls",
-    "server_framework",
-    "tokio-postgres",
-]
-# When using the postgres_full features we enable the diesel/postgres feature. We configure
-# it in a feature so the CLI can opt out, since it cannot tolerate the libpq dep.
-# Recall that features should always be additive.
-postgres_full = ["postgres_partial", "diesel/postgres"]
-testing_framework = [
-    "testcontainers",
-    "tonic",
-    "tokio-retry",
-    "tokio-stream",
-    "tokio/net",
-]
-default = []