Skip to content

Commit

Permalink
feat: revert changes
Browse files Browse the repository at this point in the history
  • Loading branch information
n00m4d committed Jan 13, 2025
1 parent ddac9e9 commit 2d8f4d0
Show file tree
Hide file tree
Showing 3 changed files with 7 additions and 6 deletions.
2 changes: 1 addition & 1 deletion Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -84,7 +84,7 @@ num-traits = "0.2.17"

# Configuration, env-vars and cli parsing
figment = { version = "0.10.6", features = ["env", "toml", "yaml"] }
clap = { version = "4.2.2", features = ["derive", "cargo", "env"] }
clap = { version = "4.2.2", features = ["derive", "cargo"] }
dotenvy = "0.15.7"
indicatif = "0.17"

Expand Down
1 change: 1 addition & 0 deletions ingester.Dockerfile
Original file line number Diff line number Diff line change
Expand Up @@ -61,6 +61,7 @@ COPY --from=builder-with-profiling /rust/target/release/ingester ${APP}/profilin
COPY --from=builder-with-profiling /rust/target/release/backfill ${APP}/profiling_backfill
COPY --from=builder-with-profiling /rust/target/release/api ${APP}/profiling_api
COPY --from=builder-with-profiling /rust/target/release/synchronizer ${APP}/profiling_synchronizer
COPY --from=builder-with-profiling /rust/target/release/slot_persister ${APP}/profiling_slot_persister

WORKDIR ${APP}
STOPSIGNAL SIGINT
10 changes: 5 additions & 5 deletions nft_ingester/src/bin/slot_persister/main.rs
Original file line number Diff line number Diff line change
Expand Up @@ -49,15 +49,15 @@ struct Args {
rpc_host: String,

/// Optional starting slot number, this will override the last saved slot in the RocksDB
#[arg(short, long, env="SLOT_PERSISTER_START_SLOT")]
#[arg(short, long)]
start_slot: Option<u64>,

/// Big table credentials file path
#[arg(short, long, env = "BIG_TABLE_CREDENTIALS")]
big_table_credentials: Option<String>,

/// Optional big table timeout (default: 1000)
#[arg(short = 'B', long, env="BIG_TABLE_TIMEOUT", default_value_t = 1000)]
#[arg(short = 'B', long, default_value_t = 1000)]
big_table_timeout: u32,

/// Metrics port
Expand All @@ -66,15 +66,15 @@ struct Args {
metrics_port: u16,

/// Number of slots to process in each batch
#[arg(short, long, env="SLOT_PERSISTER_CHUNK_SIZE", default_value_t = 200)]
#[arg(short, long, default_value_t = 200)]
chunk_size: usize,

/// Maximum number of concurrent requests
#[arg(short = 'M', long, env="SLOT_PERSISTER_MAX_CONCURRENCY", default_value_t = 20)]
#[arg(short = 'M', long, default_value_t = 20)]
max_concurrency: usize,

/// Optional comma-separated list of slot numbers to check
#[arg(long, env="SLOT_PERSISTER_SLOTS")]
#[arg(long)]
slots: Option<String>,
}

Expand Down

0 comments on commit 2d8f4d0

Please sign in to comment.