pub struct MetaGroupConfig {
pub node_data: PathBuf,
pub meta_group_id: RaftGroupId,
pub node_id: NodeId,
pub registry: FeatureRegistry,
pub storage: StorageConfig,
pub idempotency_retention: usize,
}Expand description
Static layout and identity of one meta-group member.
§Directory layout (mirrors the engine sink’s single-group layout)
node-data/
groups/
<meta-group-id>/
raft/ log segments, vote, state machine checkpoint + snapshots
raft/state/meta-state.json the sink's durable MetaState checkpointThe applied meta state is durable in the sink’s checkpoint file (see
MetaApplySink) and travels inside raft snapshots for catch-up.
Fields§
§node_data: PathBufThe node’s local data root (node-data).
meta_group_id: RaftGroupIdThe dedicated meta group’s durable identifier (minted at cluster bootstrap; never a tablet group).
node_id: NodeIdThis node’s durable id.
registry: FeatureRegistryThe binary’s feature registry gating MetaCommand::ActivateFeature
at apply (identical on every replica of one deployment).
storage: StorageConfigDurable log storage configuration.
idempotency_retention: usizeBound on the apply idempotency set (S2B-004).
Implementations§
Source§impl MetaGroupConfig
impl MetaGroupConfig
Sourcepub fn new(
node_data: PathBuf,
meta_group_id: RaftGroupId,
node_id: NodeId,
) -> Self
pub fn new( node_data: PathBuf, meta_group_id: RaftGroupId, node_id: NodeId, ) -> Self
Required identities; registry, storage, and retention default to production values.
Sourcepub fn group_dir(&self) -> PathBuf
pub fn group_dir(&self) -> PathBuf
<node-data>/groups/<meta-group-id> — the group directory handed to
ConsensusGroup.
Sourcepub fn cluster_name(&self) -> String
pub fn cluster_name(&self) -> String
The group’s text identifier (meta-<hex>).
Sourcepub fn group_config(&self) -> GroupConfig
pub fn group_config(&self) -> GroupConfig
The default GroupConfig for this member (production timings;
callers may tune it before passing it to MetaGroup::create).
Trait Implementations§
Source§impl Clone for MetaGroupConfig
impl Clone for MetaGroupConfig
Source§fn clone(&self) -> MetaGroupConfig
fn clone(&self) -> MetaGroupConfig
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreAuto Trait Implementations§
impl Freeze for MetaGroupConfig
impl RefUnwindSafe for MetaGroupConfig
impl Send for MetaGroupConfig
impl Sync for MetaGroupConfig
impl Unpin for MetaGroupConfig
impl UnsafeUnpin for MetaGroupConfig
impl UnwindSafe for MetaGroupConfig
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T in a tonic::Request