| 8 | use tokio_util::sync::CancellationToken; |
| 9 | |
| 10 | #[derive(Clone)] |
| 11 | pub struct ApplicationConfig<C: EngineClient, ES: Epocher> { |
| 12 | pub engine_client: C, |
| 13 | |
| 14 | /// Number of messages from consensus to hold in our backlog |
| 15 | /// before blocking. |
| 16 | pub mailbox_size: usize, |
| 17 | |
| 18 | pub partition_prefix: String, |
| 19 | |
| 20 | pub genesis_hash: [u8; 32], |
| 21 | |
| 22 | /// Maximum P2P message size from genesis. |
| 23 | pub max_message_size_bytes: u32, |
| 24 | |
| 25 | /// Epocher for determining epoch boundaries. |
| 26 | pub epocher: ES, |
| 27 | |
| 28 | pub cancellation_token: CancellationToken, |
| 29 | |
| 30 | /// Consensus leader timeout. A proposal whose timestamp cannot enter the |
| 31 | /// verifier future window within this window is abandoned rather than waited |
| 32 | /// out, since it could not be notarized before the leader rotates. |
| 33 | pub leader_timeout: Duration, |
nothing calls this directly
no outgoing calls
no test coverage detected