Struct JournalTallies 

pub struct JournalTallies {

    pub streams: usize,
    pub events: usize,
    pub written: u64,
    pub received: u64,
    pub duplicates: u64,
    pub rejected: u64,
    pub pending: usize,
    pub compacted: u64,
    pub opaque: usize,
    pub lamport: u64,
    pub write_failures: u64,
    pub unreadable: u64,
    pub unread_bytes: u64,
}

The journal’s counters since start: how much it holds, how much it has written, received, absorbed, refused, held back and compacted away. They are what makes a replication problem diagnosable from one machine — a runtime whose received never rises is not linked, one whose rejected rises is being sent something it will not take, and one whose pending stays high is missing an event ahead of what it has.

use std::sync::Arc;
use majordomus_cli::mesh::identity::NodeIdentity;
use majordomus_cli::mesh::journal::{EventBody, Journal, JournalTallies};

let j = Journal::open(Arc::new(NodeIdentity::ephemeral().unwrap()), "0000000000000001",
    "repo".into(), None).unwrap();
let before: JournalTallies = j.tallies();
assert_eq!((before.written, before.events), (0, 0));

j.append_own(EventBody::SessionClosed { session: "s1".into() }).unwrap();
let after = j.tallies();
assert_eq!((after.written, after.events, after.streams), (1, 1, 1));
assert!(after.lamport > before.lamport);

Fields

streams: usize

Streams tracked.

events: usize

Events held.

written: u64

Events written by this runtime since start.

received: u64

Events received and stored.

duplicates: u64

Duplicate deliveries absorbed.

rejected: u64

Events refused.

pending: usize

Events held for a gap right now.

compacted: u64

Events dropped by compaction since start.

opaque: usize

Events of a kind this executable does not interpret, held and relayed.

lamport: u64

The highest Lamport stamp seen.

write_failures: u64

Appends to the journal file that failed since start: the events were held in memory and replicated, and are not on this machine’s disk. Nonzero fails mesh doctor.

unreadable: u64

Lines of the journal file the last reload could not read: torn, corrupt, or written by something that is not this journal. Counted, never silently dropped.

unread_bytes: u64

Bytes of the journal file the last reload left unread because they lie beyond MAX_RELOAD_BYTES: on disk and kept by compaction, and not in memory. Nonzero fails mesh doctor.

Trait Implementations

impl Clone for JournalTallies

fn clone(&self) -> JournalTallies

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for JournalTallies

impl Debug for JournalTallies

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

Formats the value using the given formatter.

impl Default for JournalTallies

fn default() -> JournalTallies

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for JournalTallies

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for JournalTallies

impl JsonSchema for JournalTallies

fn schema_name() -> Cow<'static, str>

The name of the generated JSON Schema.

fn schema_id() -> Cow<'static, str>

Returns a string that uniquely identifies the schema produced by this type.

fn json_schema(generator: &mut SchemaGenerator) -> Schema

Generates a JSON Schema for this type.

fn inline_schema() -> bool

Whether JSON Schemas generated for this type should be included directly in parent schemas, rather than being re-used where possible using the $ref keyword.

impl PartialEq for JournalTallies

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for JournalTallies

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 JournalTallies