Enum InstanceState 

pub enum InstanceState {
    Creating(Timestamp),
    Loaded(Timestamp),
    Running(Timestamp),
    Aborted(Timestamp),
    Failed((Timestamp, String)),
}

The different states of a DataFlowInstance.

Note that a state is tied to a Zenoh-Flow runtime: if a data flow is distributed across multiple Zenoh-Flow runtimes, their respective state for the same instance could be different (but should eventually converge).

Variants

Creating(Timestamp)

A runtime listing a DataFlowInstance in the Creating state is in the process of loading all the nodes it manages.

Loaded(Timestamp)

A runtime listing a DataFlowInstance in the Loaded state successfully instantiated all the nodes it manages and is ready to start them.

A Loaded data flow can be started or deleted.

Running(Timestamp)

A runtime listing a DataFlowInstance in the Running state has (re)started all the nodes it manages.

A Running data flow can be aborted or deleted.

Aborted(Timestamp)

A runtime listing a DataFlowInstance in the Aborted state has abruptly stopped all the nodes it manages.

An Aborted data flow can be restarted or deleted.

Failed((Timestamp, String))

A runtime listing a DataFlowInstance in the Failed state failed to load at least one of the nodes of this instance it manages.

A data flow in the Failed state can only be deleted.

Trait Implementations

impl Clone for InstanceState

fn clone(&self) -> InstanceState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InstanceState

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for InstanceState

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for InstanceState

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

Formats the value using the given formatter.

impl Serialize for InstanceState

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

where __S: Serializer,

Serialize this value into the given Serde serializer.