Struct DisklessWalCapture 

pub struct DisklessWalCapture {
    pub format_version: u16,
    pub captured_at_ms: u64,
    pub source_cutoffs: Vec<i64>,
    pub partitions: Vec<DisklessPartitionCapture>,
    pub metadata_snapshot_sha256: Option<Sha256Digest>,
    pub rlmm_snapshot_sha256: Option<Sha256Digest>,
    pub group_offsets_sha256: Option<Sha256Digest>,
    pub authentication: Option<SegmentManifest>,
}

Portable committed diskless-WAL capture.

Fields

format_version: u16

captured_at_ms: u64

source_cutoffs: Vec<i64>

partitions: Vec<DisklessPartitionCapture>

metadata_snapshot_sha256: Option<Sha256Digest>

Digest of the controller checkpoint captured beside this boundary.

rlmm_snapshot_sha256: Option<Sha256Digest>

Digest of the RLMM cache snapshot captured beside this boundary.

group_offsets_sha256: Option<Sha256Digest>

Digest of the consumer-group offsets captured beside this boundary.

authentication: Option<SegmentManifest>

Optional signed WORM boundary covering this capture and its WAL objects.

Implementations

impl DisklessWalCapture

pub fn seal( &mut self, objects: Vec<ObjectEntry>, signer: &FileEd25519Signer, ) -> Result<ChainHead, String>

Sign the exact capture state and referenced WAL object claims.

Errors

Returns an error when capture state is invalid, object claims do not exactly cover it, or its deterministic encoding fails.

pub fn authenticate( &self, trusted: &TrustedManifestKeys, expected_head: Option<&str>, ) -> Result<BTreeMap<String, ObjectEntry>, String>

Verify the embedded signed boundary and return trusted WAL claims.

Errors

Returns an error for invalid capture state, missing or untrusted evidence, a bad signature, a head mismatch, or incomplete object claims.

impl DisklessWalCapture

pub const FORMAT_VERSION: u16 = 1

Version of diskless-wal-index.json, its required top-level "format_version" field.

Part of the 1.x on-disk contract: a 1.x restore reads every capture that any earlier 1.x build wrote.

pub fn from_slice(bytes: &[u8]) -> Result<Self, String>

Decode JSON and reject a missing or unknown capture version.

The version is read on its own first, so a capture of another version is reported as that, and not as whatever field its shape lacks.

Errors

Returns an error for malformed JSON, a missing or unsupported version, or invalid state.

pub fn validate(&self) -> Result<(), String>

Validate all state that controls restore selection and boundaries.

Errors

Returns an error for invalid partitions, ranges, floors, or cutoffs.

Trait Implementations

impl Clone for DisklessWalCapture

fn clone(&self) -> DisklessWalCapture

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for DisklessWalCapture

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for DisklessWalCapture

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for DisklessWalCapture

impl PartialEq for DisklessWalCapture

fn eq(&self, other: &DisklessWalCapture) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for DisklessWalCapture

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for DisklessWalCapture