Struct RepTestBase 

pub struct RepTestBase { /* private fields */ }

JE-style replication group test fixture.

Mirrors JE’s RepTestBase (com.sleepycat.je.rep.impl.RepTestBase). Encapsulates a group of N nodes that share a group name, port range, and election policy, and provides the lifecycle / replication / assertion helpers that the JE rep TCK uses.

Use RepTestBase::builder to construct one; call RepTestBase::create_group to bring up all nodes; call RepTestBase::shutdown_all (or rely on Drop) to tear them down.

Implementations

impl RepTestBase

pub fn builder(group_name: impl Into<String>) -> RepTestBaseBuilder

Start building a new group with the given group name.

pub fn group_size(&self) -> usize

Number of nodes in the group.

pub fn node(&self, idx: usize) -> &RepEnvInfo

Borrow node at index idx (0-based — JE’s repEnvInfo[i]).

pub fn node_mut(&mut self, idx: usize) -> &mut RepEnvInfo

Borrow node at index idx mutably.

pub fn nodes(&self) -> &[RepEnvInfo]

Borrow all nodes.

pub fn nodes_mut(&mut self) -> &mut [RepEnvInfo]

Borrow all nodes mutably.

pub fn group_name(&self) -> &str

Returns the group name.

pub fn create_group(&mut self, term: u64) -> Result<()>

Open every node’s env, elect node 0 as master with term, and join nodes 1..N as replicas pointing at node 0.

Mirrors JE’s RepTestBase.createGroup (which opens N nodes and expects the first to become master, the rest replicas).

pub fn create_group_of_size(&mut self, first_n: usize, term: u64) -> Result<()>

Same as Self::create_group but only brings up the first first_n nodes — JE’s createGroup(int firstn) overload.

pub fn shutdown_all(&mut self)

Close every node’s env (master last, to avoid spurious elections — matches JE’s closeNodes).

pub fn find_master(&self) -> Option<&RepEnvInfo>

Find the unique master, or None if no node is currently master. Mirrors JE’s RepTestBase.findMaster.

pub fn find_master_mut(&mut self) -> Option<&mut RepEnvInfo>

Find the master, or None — mutable variant.

pub fn find_master_idx(&self) -> Option<usize>

Index of the unique master, or None.

pub fn replicas(&self) -> Vec<&RepEnvInfo>

All replica nodes.

pub fn await_master(&self, timeout: Duration) -> Result<usize>

Wait up to timeout for some node to be master, polling at Duration::from_millis(20) intervals. Returns the master’s index on success. Mirrors JE’s findMasterWait.

pub fn await_state( &self, idx: usize, target: NodeState, timeout: Duration, ) -> Result<()>

Wait up to timeout for node idx to enter target state.

pub fn await_vlsn_at_least( &self, idx: usize, vlsn: u64, timeout: Duration, ) -> Result<()>

Wait up to timeout for node idx’s VLSN to reach at least vlsn.

pub fn replicate_one( &self, vlsn: u64, file: u32, offset: u32, entry_type: u8, ) -> Result<()>

Register a single VLSN on the master and apply it to every other node (acting as replicas). This is the in-process moral equivalent of “the master commits the txn, and the feeder streams it”.

entry_type is the replica-side apply_entry discriminator (a u8 that on the JE side selects between LN / commit / abort entries).

pub fn populate_db(&self, start_vlsn: u64, count: u64) -> Result<()>

Replicate count VLSN entries starting at start_vlsn. Mirrors JE’s populateDB(rep, dbName, start, n) for the harness layer: the master records each VLSN and replicas apply it in order.

pub fn populate_master_only(&self, start_vlsn: u64, count: u64) -> Result<()>

Same as Self::populate_db but only writes to the master and leaves replicas in the dust — useful for partition / catch-up tests.

pub fn catch_up_replica( &self, replica_idx: usize, start_vlsn: u64, count: u64, ) -> Result<()>

Replay start_vlsn..start_vlsn+count on a single replica — used to simulate a replica catching up after a partition.

pub fn close_master(&mut self) -> Result<usize>

Close the current master; mirrors JE’s leaveGroupAllButMaster’s inverse — kill the master, leaving replicas in NodeState::Replica until a Self::failover_to call drives a new election.

Returns the index of the closed master.

pub fn failover_to(&mut self, replica_idx: usize) -> Result<()>

Drive replica replica_idx through Replica → Unknown → Master using a fresh term, then point all other live replicas at the new master. Mirrors JE’s transferMaster for the in-process harness.

pub fn assert_all_at_vlsn(&self, vlsn: u64)

Assert every node currently in NodeState::Master or NodeState::Replica reports vlsn as its current_vlsn. Panics on mismatch.

pub fn assert_state(&self, idx: usize, state: NodeState)

Assert node idx is in state.

Trait Implementations

impl Drop for RepTestBase

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.