File tree Expand file tree Collapse file tree 3 files changed +212
-107
lines changed
datasources/rpc-transaction-crawler-datasource/src
examples/meteora-activities/src Expand file tree Collapse file tree 3 files changed +212
-107
lines changed Original file line number Diff line number Diff line change @@ -80,14 +80,19 @@ pub async fn main() -> CarbonResult<()> {
8080 {%- endif %}
8181
8282 {%- if data_source.module_name == "rpc_transaction_crawler" %}
83+ let connection_config = ConnectionConfig::new(
84+ 100, // Batch limit
85+ Duration::from_secs(5), // Polling interval
86+ 5, // Max Concurrent Requests
87+ RetryConfig::default(), // Retry config
88+ );
89+
8390 let datasource = RpcTransactionCrawler::new(
8491 env::var("RPC_URL").unwrap_or_default(), // RPC URL
8592 METEORA_PROGRAM_ID, // The test account
86- 100, // Batch limit
87- Duration::from_secs(5), // Polling interval
93+ connection_config, // Connection config
8894 filters, // Filters
8995 Some(solana_sdk::commitment_config::CommitmentConfig::finalized()), // Commitment config
90- 5, // Max Concurrent Requests
9196 );
9297 {%- endif %}
9398
You can’t perform that action at this time.
0 commit comments