search

cartesi / rollups

Cartesi Rollups
30 stars 12 forks source link

feature(offchain): add Redis Cluster support #154

Closed torives closed 1 year ago

torives commented 1 year ago

Closes #12

endersonmaia commented 1 year ago

After starting a validator-node based on this branch connected to a AWS MemoryDB Redis cluster endpoint, I get the following errors:

indexer

2023-07-18T17:49:16.897126Z  INFO indexer::indexer: connected to database; connecting to broker
2023-07-18T17:49:17.008070Z  INFO indexer::indexer: connected to broker; starting main loop
2023-07-18T17:49:17.008109Z  INFO indexer::indexer: waiting for next event self.state=IndexerState { inputs_last_id: "0", outputs_last_id: "0", inputs_stream: RollupsInputsStream { key: "chain-0:dapp-a057811d929
1cea1a6e7c0ff1eca12d6924b1de2:rollups-inputs" }, outputs_stream: RollupsOutputsStream { key: "chain-0:dapp-a057811d9291cea1a6e7c0ff1eca12d6924b1de2:rollups-outputs" } }
Error: BrokerError { source: ConnectionError { source: An error was signalled by the server: Keys in request don't hash to the same slot } }

dispatcher

2023-07-18T17:49:15.918153Z  INFO dispatcher::dispatcher: Setting up dispatcher with config: DispatcherConfig { sc_config: SCConfig { grpc_endpoint: "http://localhost:50051", default_confirmations: 1 }, tx_confi
g: TxManagerConfig { default_confirmations: 2, provider_http_endpoint: "https://eth-goerli.g.alchemy.com/v2/4eeMGl2u3ALzBEsohk3IuvNxSIPb0r0U", chain_id: 5, chain_is_legacy: false, database_path: "./default_tx_da
tabase", gas_oracle_api_key: "" }, broker_config: BrokerConfig { redis_endpoint: Cluster([rediss://clustercfg.rollups.gp1e3k.memorydb.us-east-1.amazonaws.com]), consume_timeout: 5000, backoff: ExponentialBackoff
 { current_interval: 500ms, initial_interval: 500ms, randomization_factor: 0.5, multiplier: 1.5, max_interval: 60s, start_time: Instant { tv_sec: 13176, tv_nsec: 860213054 }, max_elapsed_time: Some(120s), clock:
 SystemClock } }, auth_config: AWS { key_id: "2a313b66-752b-4787-bddf-bd59309fcdd1", region: UsEast1 }, dapp_deployment: DappDeployment { dapp_address: 0xa057811d9291cea1a6e7c0ff1eca12d6924b1de2, deploy_block_ha
sh: 0xd1e0419a922501c497feb4928d19f8acc4b123ff59218663bae0dd53b8cd5d54 }, rollups_deployment: RollupsDeployment { history_address: 0xa860738792a1e216cf57e7375d5a8637762538f5, authority_address: 0x5ba88473ac88ae1
55c1bd28cdd05f1a80e3bba18, input_box_address: 0x5a723220579c0dcb8c9253e6b4c62e572e379945 }, epoch_duration: 86400, priority: Normal }
Error: ConnectError { source: tonic::transport::Error(Transport, hyper::Error(Connect, ConnectError("tcp connect error", Os { code: 111, kind: ConnectionRefused, message: "Connection refused" }))) }

advance-runner

This doesn't look related to redis, but the container got restarted after the error, I don't know if should. In case it's really not related, we could open an issue to track that message.

2023-07-18T16:05:22.550177Z  INFO advance_runner: starting advance runner config=AdvanceRunnerConfig { server_manager_config: ServerManagerConfig { server_manager_endpoint: "http://localhost:5001", session_id: "
2023-07-18T16:05:22.731748Z  INFO advance_runner::runner: got latest snapshot snapshot=Snapshot { path: "/var/opt/cartesi/machine-snapshots/0_0", epoch: 0, processed_input_count: 0 }
2023-07-18T16:05:40.783821Z  INFO advance_runner::runner: starting runner main loop last_id="0"
2023-07-18T17:35:49.951759Z  INFO advance_runner::runner: consumed input event event=Event { id: "1689701749946-0", payload: RollupsInput { parent_id: "0", epoch_index: 0, inputs_sent_count: 1, data: AdvanceStat
2023-07-18T17:35:51.978968Z  INFO advance_runner::runner: waiting for the next input event last_id="1689701749946-0"
2023-07-18T17:35:51.979562Z  INFO advance_runner::runner: consumed input event event=Event { id: "1689701749953-0", payload: RollupsInput { parent_id: "1689701749946-0", epoch_index: 0, inputs_sent_count: 1, dat
2023-07-18T17:35:52.430664Z  INFO advance_runner::runner: produced epoch claim
2023-07-18T17:35:52.445187Z  INFO advance_runner::runner: waiting for the next input event last_id="1689701749953-0"
Error: RunnerFSSnapshotError { source: ParentIdMismatchError { expected: "1689701749953-0", got: "0" } }