Enum StreamLiveness 

pub enum StreamLiveness {
    Own,
    Live,
    Expired,
}

Whether a stream is speaking now, on this runtime’s clock. It is a verdict about a stream and not about a link: a runtime reachable only through a relay is alive, and a runtime that crashed stops beating for everyone at once. Own is kept apart from Live because a runtime’s own stream needs no evidence — it is the thing doing the beating.

use majordomus_cli::mesh::journal::StreamLiveness;

assert!(StreamLiveness::Own.is_alive() && StreamLiveness::Live.is_alive());
assert!(!StreamLiveness::Expired.is_alive());
assert_eq!(
    serde_json::to_value(StreamLiveness::Expired).unwrap(),
    serde_json::json!("expired"),
);

Variants

Own

This runtime’s own current stream.

Live

Its beat rose within the expiry.

Expired

Its beat has not risen within the expiry, or was never heard.

Implementations

impl StreamLiveness

pub fn is_alive(self) -> bool

Whether the stream counts as alive: its claims hold, its sessions are present. The two living verdicts are collapsed here because everything downstream treats them alike — a claim of this runtime’s own and a claim of a peer that still beats both exclude — while the distinction is kept in the enum for anything that reports it.

use majordomus_cli::mesh::journal::StreamLiveness;

assert!(StreamLiveness::Own.is_alive(), "no evidence needed for one's own stream");
assert!(StreamLiveness::Live.is_alive());
assert!(!StreamLiveness::Expired.is_alive(), "its claims end without anyone releasing them");

Trait Implementations

impl Clone for StreamLiveness

fn clone(&self) -> StreamLiveness

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for StreamLiveness

impl Debug for StreamLiveness

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for StreamLiveness

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for StreamLiveness

impl JsonSchema for StreamLiveness

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 StreamLiveness

fn eq(&self, other: &StreamLiveness) -> 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 StreamLiveness

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 StreamLiveness