commonwarexyz · BrendanChou · Jun 10, 2025 · Jun 10, 2025 · Jun 10, 2025 · Jun 10, 2025
diff --git a/consensus/src/aggregation/config.rs b/consensus/src/aggregation/config.rs
@@ -0,0 +1,74 @@
+use super::types::{Activity, Epoch, Index};
+use crate::{Automaton, Monitor, Reporter, ThresholdSupervisor};
+use commonware_cryptography::{bls12381::primitives::variant::Variant, Digest};
+use commonware_p2p::Blocker;
+use commonware_utils::{Array, NonZeroDuration};
+use std::num::{NonZeroU64, NonZeroUsize};
+
+/// Configuration for the [Engine](super::Engine).
+pub struct Config<
+    P: Array,
+    V: Variant,
+    D: Digest,
+    A: Automaton<Context = Index, Digest = D>,
+    Z: Reporter<Activity = Activity<V, D>>,
+    M: Monitor<Index = Epoch>,
+    B: Blocker<PublicKey = P>,
+    TSu: ThresholdSupervisor<Index = Epoch, PublicKey = P>,
+> {
+    /// Tracks the current state of consensus (to determine which participants should
+    /// be involved in the current broadcast attempt).
+    pub monitor: M,
+
+    /// Manages the set of validators and the group identity.
+    /// Also manages the cryptographic partial share if the engine is a validator.
+    pub validators: TSu,
+
+    /// Proposes and verifies digests.
+    pub automaton: A,
+
+    /// Notified when a chunk receives a threshold of acks.
+    pub reporter: Z,
+
+    /// Blocker for the network.
+    ///
+    /// Blocking is handled by [commonware_p2p].
+    pub blocker: B,
+
+    /// The application namespace used to sign over different types of messages.
+    /// Used to prevent replay attacks on other applications.
+    pub namespace: Vec<u8>,
+
+    /// Whether acks are sent as priority.
+    pub priority_acks: bool,
+
+    /// How often an ack is rebroadcast to all validators if no threshold is reached.
+    pub rebroadcast_timeout: NonZeroDuration,
+
+    /// A tuple representing the epochs to keep in memory.
+    /// The first element is the number of old epochs to keep.
+    /// The second element is the number of future epochs to accept.
+    ///
+    /// For example, if the current epoch is 10, and the bounds are (1, 2), then
+    /// epochs 9, 10, 11, and 12 are kept (and accepted);
+    /// all others are pruned or rejected.
+    pub epoch_bounds: (u64, u64),
+
+    /// The concurrent number of chunks to process.
+    pub window: NonZeroU64,
+
+    /// Partition for the journal.
+    pub partition: String,
+
+    /// The size of the write buffer to use for each blob in the journal.
+    pub journal_write_buffer: NonZeroUsize,
+
+    /// Number of bytes to buffer when replaying a journal.
+    pub journal_replay_buffer: NonZeroUsize,
+
+    /// The number of entries to keep per journal section.
+    pub journal_heights_per_section: NonZeroU64,
+
+    /// Compression level for the journal.
+    pub journal_compression: Option<u8>,
+}