Struct Message

pub struct Message {

    pub id: String,
    pub tid: String,
    pub name: String,
    pub state: MessageState,
    pub type: String,
    pub source: String,
    pub model: Model,
    pub pid: String,
    pub nid: String,
    pub mid: String,
    pub key: String,
    pub inputs: Vars,
    pub outputs: Vars,
    pub tag: String,
    pub start_time: i64,
    pub end_time: i64,
    pub retry_times: i32,
}

Fields

id: String

message id

tid: String

task id

name: String

node name or action name

state: MessageState

task action state

type: String

message type workflow | step | branch | msg | irq

source: String

model: Model

pid: String

process id

nid: String

node id

mid: String

model id

key: String

node id or act key if the key is empty, just using nid as the key

inputs: Vars

from the task inputs

outputs: Vars

set the outputs vars when complete the action

tag: String

tag to distinguish different message it is from node tag or group tag

start_time: i64

task start time in million second

end_time: i64

task end time in million second

retry_times: i32

record the message retry times

Implementations

impl Message

pub fn state(&self) -> MessageState

pub fn is_key(&self, key: &str) -> bool

pub fn is_state(&self, state: MessageState) -> bool

pub fn is_type(&self, t: &str) -> bool

pub fn is_source(&self, t: &str) -> bool

pub fn is_tag(&self, tag: &str) -> bool

pub fn type_of(&self, mtype: &str) -> Option<&Self>

pub fn tag_of(&self, tag: &str) -> Option<&Self>

pub fn key_of(&self, key: &str) -> Option<&Self>

pub fn cost(&self) -> i64

workflow cost in million seconds

pub fn into(&self, emit_id: &str, pat: &str) -> Message

Trait Implementations

impl Clone for Message

fn clone(&self) -> Message

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Message

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

Formats the value using the given formatter.

impl Default for Message

fn default() -> Message

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for Message

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<Message> for Message

fn from(v: Message) -> Self

Converts to this type from the input type.

impl Serialize for Message

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

where __S: Serializer,

Serialize this value into the given Serde serializer.