Enum latticeclient::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 of ActorStarting

actor: Stringhost: String

ActorStarted

An actor has started and is ready to receive messages

Fields of ActorStarted

actor: Stringhost: String

ActorStopped

An actor has stopped in a predictable manner

Fields of ActorStopped

actor: Stringhost: String

ActorUpdating

A live update/hot swap has begun on this actor

Fields of ActorUpdating

actor: Stringhost: String

ActorUpdateComplete

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

Fields of ActorUpdateComplete

actor: Stringsuccess: boolhost: String

ProviderLoaded

A capability provider has been loaded on a host

Fields of ProviderLoaded

capid: Stringinstance_name: Stringhost: String

ProviderRemoved

A capability provider has been removed from a host

Fields of ProviderRemoved

capid: Stringinstance_name: Stringhost: 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 of ActorBindingCreated

host: Stringactor: Stringcapid: Stringinstance_name: String

ActorBindingRemoved

A binding was removed

Fields of ActorBindingRemoved

host: Stringactor: Stringcapid: Stringinstance_name: String

ActorBecameHealthy

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

Fields of ActorBecameHealthy

actor: Stringhost: String

ActorBecameUnhealthy

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

Fields of ActorBecameUnhealthy

actor: Stringhost: 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

Performs the conversion.

impl PartialEq<BusEvent> for BusEvent

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

This method tests for self and other values to be equal, and is used by ==.

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

This method tests for !=.

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