Enum BusEvent

pub enum BusEvent {
    HostStarted(String),
    HostStopped(String),
    ActorStarting {
        actor: String,
        host: String,
    },
    ActorStarted {
        actor: String,
        host: String,
    },
    ActorStopped {
        actor: String,
        host: String,
    },
    ActorUpdating {
        actor: String,
        host: String,
    },
    ActorUpdateComplete {
        actor: String,
        success: bool,
        host: String,
    },
    ProviderLoaded {
        capid: String,
        instance_name: String,
        host: String,
    },
    ProviderRemoved {
        capid: String,
        instance_name: String,
        host: String,
    },
    ActorBindingCreated {
        host: String,
        actor: String,
        capid: String,
        instance_name: String,
    },
    ActorBindingRemoved {
        host: String,
        actor: String,
        capid: String,
        instance_name: String,
    },
    ActorBecameHealthy {
        actor: String,
        host: String,
    },
    ActorBecameUnhealthy {
        actor: String,
        host: String,
    },
}

Represents an event that may occur on a bus of connected hosts. Timestamps, identifiers, and other metadata will be provided by a CloudEvent envelope.

Variants

HostStarted(String)

A host process has fully started and is ready for work

HostStopped(String)

A host has stopped on a predictable manner

ActorStarting

An actor has begun the loading/parsing phase

Fields

actor: String

host: String

ActorStarted

An actor has started and is ready to receive messages

Fields

actor: String

host: String

ActorStopped

An actor has stopped in a predictable manner

Fields

actor: String

host: String

ActorUpdating

A live update/hot swap has begun on this actor

Fields

actor: String

host: String

ActorUpdateComplete

A live update/hot swap has completed (or failed)

Fields

actor: String

success: bool

host: String

ProviderLoaded

A capability provider has been loaded on a host

Fields

capid: String

instance_name: String

host: String

ProviderRemoved

A capability provider has been removed from a host

Fields

capid: String

instance_name: String

host: String

ActorBindingCreated

A binding between an actor and a named capability provider instance was created. For security reasons the raw data of the individual bound configuration values is not published in this event and must be queried via lattice protocol

Fields

host: String

actor: String

capid: String

instance_name: String

ActorBindingRemoved

A binding was removed

Fields

host: String

actor: String

capid: String

instance_name: String

ActorBecameHealthy

A previously unhealthy actor became healthy. This is a higher-order event, not generated from inside wascc host

Fields

actor: String

host: String

ActorBecameUnhealthy

A previously healthy actor became unhealthy. This is a higher-order event, not generated from inside wascc host

Fields

actor: String

host: String

Implementations

impl BusEvent

pub fn event_type(&self) -> String

pub fn subject(&self) -> String

Trait Implementations

impl Clone for BusEvent

fn clone(&self) -> BusEvent

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for BusEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for BusEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for BusEvent

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

Formats the value using the given formatter.

impl From<BusEvent> for CloudEvent

fn from(event: BusEvent) -> CloudEvent

Converts to this type from the input type.

impl PartialEq for BusEvent

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

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 BusEvent