Struct SwfData 

pub struct SwfData {
    pub account_id: String,
    pub region: String,
    pub domains: BTreeMap<String, Domain>,
    pub activity_types: BTreeMap<String, TypeRecord>,
    pub workflow_types: BTreeMap<String, TypeRecord>,
    pub executions: BTreeMap<String, Execution>,
    pub decision_tokens: BTreeMap<String, String>,
    pub activity_tokens: BTreeMap<String, ActivityRef>,
    pub tags: BTreeMap<String, BTreeMap<String, String>>,
}

Per-account Amazon SWF state.

Fields

account_id: String

region: String

domains: BTreeMap<String, Domain>

Domains keyed by name.

activity_types: BTreeMap<String, TypeRecord>

Activity types keyed by "{domain}\u{1}{name}\u{1}{version}".

workflow_types: BTreeMap<String, TypeRecord>

Workflow types keyed by "{domain}\u{1}{name}\u{1}{version}".

executions: BTreeMap<String, Execution>

Workflow executions keyed by runId.

decision_tokens: BTreeMap<String, String>

Decision task token -> owning runId.

activity_tokens: BTreeMap<String, ActivityRef>

Activity task token -> (runId, activityId).

tags: BTreeMap<String, BTreeMap<String, String>>

Resource tags keyed by domain ARN.

Implementations

impl SwfData

pub fn type_map_key(domain: &str, name: &str, version: &str) -> String

Composite key for a type record within a domain.

pub fn find_execution<'a>( &'a self, workflow_id: &str, run_id: Option<&str>, ) -> Option<&'a Execution>

Find the currently-open execution for a workflow_id (SWF allows only one open execution per workflow id at a time), preferring an exact run_id when supplied.

pub fn find_execution_mut<'a>( &'a mut self, workflow_id: &str, run_id: Option<&str>, ) -> Option<&'a mut Execution>

Trait Implementations

impl AccountState for SwfData

fn new_for_account(account_id: &str, region: &str, _endpoint: &str) -> Self

Create a fresh, empty state for the given account.

fn inherit_from(&mut self, _sibling: &Self)

Called after a new account state is created via MultiAccountState::get_or_create, with a reference to an existing sibling state. Services can override this to propagate shared resources (e.g. body caches) to the new state.

impl Clone for SwfData

fn clone(&self) -> SwfData

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SwfData

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

Formats the value using the given formatter.

impl Default for SwfData

fn default() -> SwfData

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for SwfData

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for SwfData

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

where __S: Serializer,

Serialize this value into the given Serde serializer.