This is an automated email from the ASF dual-hosted git repository. gkoszyk pushed a commit to branch plane_demuxer in repository https://gitbox.apache.org/repos/asf/iggy.git
commit 3d0e6be3a0c3cd162c3a99cb29ba6fb111a00741 Author: numinex <[email protected]> AuthorDate: Thu Feb 19 11:30:52 2026 +0100 cargo fmt --- core/consensus/src/lib.rs | 4 ++-- core/metadata/src/stm/mux.rs | 2 +- core/simulator/src/deps.rs | 2 +- core/simulator/src/replica.rs | 8 ++++++-- 4 files changed, 10 insertions(+), 6 deletions(-) diff --git a/core/consensus/src/lib.rs b/core/consensus/src/lib.rs index d9fc41e6e..d02963b0e 100644 --- a/core/consensus/src/lib.rs +++ b/core/consensus/src/lib.rs @@ -19,7 +19,6 @@ use iggy_common::header::ConsensusHeader; use iggy_common::message::ConsensusMessage; use message_bus::MessageBus; - pub trait Project<T, C: Consensus> { type Consensus: Consensus; fn project(self, consensus: &Self::Consensus) -> T; @@ -104,7 +103,8 @@ where C: Consensus, { fn is_applicable<H>(&self, message: &C::Message<H>) -> bool - where H: ConsensusHeader; + where + H: ConsensusHeader; } mod impls; diff --git a/core/metadata/src/stm/mux.rs b/core/metadata/src/stm/mux.rs index 52a3c8bdc..648d8893e 100644 --- a/core/metadata/src/stm/mux.rs +++ b/core/metadata/src/stm/mux.rs @@ -17,8 +17,8 @@ use crate::stm::snapshot::{FillSnapshot, RestoreSnapshot, SnapshotError}; use iggy_common::Either; -use iggy_common::{header::PrepareHeader, message::Message}; use iggy_common::variadic; +use iggy_common::{header::PrepareHeader, message::Message}; use crate::stm::{State, StateMachine}; diff --git a/core/simulator/src/deps.rs b/core/simulator/src/deps.rs index d6fab8623..a0b251e3a 100644 --- a/core/simulator/src/deps.rs +++ b/core/simulator/src/deps.rs @@ -18,9 +18,9 @@ use crate::bus::SharedMemBus; use bytes::Bytes; use consensus::{MuxPlane, VsrConsensus}; -use iggy_common::variadic; use iggy_common::header::PrepareHeader; use iggy_common::message::Message; +use iggy_common::variadic; use journal::{Journal, JournalHandle, Storage}; use metadata::stm::consumer_group::ConsumerGroups; use metadata::stm::stream::Streams; diff --git a/core/simulator/src/replica.rs b/core/simulator/src/replica.rs index c975ce8d6..db894ec86 100644 --- a/core/simulator/src/replica.rs +++ b/core/simulator/src/replica.rs @@ -23,10 +23,10 @@ use consensus::{LocalPipeline, MuxPlane, VsrConsensus}; use iggy_common::IggyByteSize; use iggy_common::sharding::ShardId; use iggy_common::variadic; +use metadata::IggyMetadata; use metadata::stm::consumer_group::{ConsumerGroups, ConsumerGroupsInner}; use metadata::stm::stream::{Streams, StreamsInner}; use metadata::stm::user::{Users, UsersInner}; -use metadata::IggyMetadata; use partitions::PartitionsConfig; use std::sync::Arc; @@ -101,6 +101,10 @@ impl Replica { pub fn init_partition_in_memory(&mut self, namespace: iggy_common::sharding::IggyNamespace) { // TODO: create an accessor for the partitions within mux plane, same for metadata. - self.plane.inner_mut().1.0.init_partition_in_memory(namespace); + self.plane + .inner_mut() + .1 + .0 + .init_partition_in_memory(namespace); } }
