temporalio-sdk-core 0.3.0

Library for building new Temporal SDKs
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49

use temporalio_macros::{workflow, workflow_methods};
use temporalio_sdk::{SyncWorkflowContext, WorkflowContext, WorkflowContextView, WorkflowResult};

#[workflow]
pub struct MyWorkflow {
    counter: u32,
}

#[workflow_methods]
impl MyWorkflow {
    #[init]
    pub fn new(_ctx: &WorkflowContextView, _input: String) -> Self {
        Self { counter: 0 }
    }

    // Async run uses &self
    #[run]
    pub async fn run(_ctx: &mut WorkflowContext<Self>) -> WorkflowResult<String> {
        Ok("hi".to_owned())
    }

    // Sync signal uses &mut self
    #[signal(name = "increment")]
    pub fn increment_counter(&mut self, _ctx: &mut SyncWorkflowContext<Self>, amount: u32) {
        self.counter += amount;
    }

    #[signal]
    pub async fn async_signal(_ctx: &mut WorkflowContext<Self>) {}

    // Query uses &self with read-only context
    #[query]
    pub fn get_counter(&self, _ctx: &WorkflowContextView) -> u32 {
        self.counter
    }

    #[update(name = "double")]
    pub fn double_counter(&mut self, _ctx: &mut SyncWorkflowContext<Self>) -> u32 {
        self.counter *= 2;
        self.counter
    }

    #[update]
    pub async fn async_update(_ctx: &mut WorkflowContext<Self>, val: i32) -> i32 {
        val * 2
    }
}

fn main() {}