MCPcopy Create free account

hub / github.com/cosm-public/temporal-samples-rust / functions

Functions29 in github.com/cosm-public/temporal-samples-rust

⨍ Functions 29◇ Types & classes 2
↓ 9 callersFunctionget_client
()
temporal-helpers/src/client.rs:6
↓ 1 callersFunctiondo_some_work
(token_ref: Arc<Mutex<Option<Vec<u8>>>>)
activities-examples/src/activities/async_completion.rs:43
↓ 1 callersFunctionping
(ctx: ActContext, starting_point: u64, sleep_interval_ms: u64)
activities-cancellation-heartbeating/src/activities/fake_progress_activity.rs:35
↓ 1 callersFunctionsample_timer_workflow
( ctx: WfContext, processing_threshold_seconds: u64, )
timer/src/workflows.rs:8
↓ 1 callersFunctionstart_worker
()
activities-examples/src/worker.rs:9
↓ 1 callersFunctionstart_worker
()
activities-cancellation-heartbeating/src/worker.rs:9
↓ 1 callersFunctionstart_worker
()
timer/src/worker.rs:11
↓ 1 callersFunctionstart_worker
()
schedule/src/worker.rs:9
Functionasync_activity_workflow
(ctx: WfContext)
activities-examples/src/workflows.rs:41
Functioncleanup_activity
( _ctx: ActContext, _payload: Option<String>, )
activities-cancellation-heartbeating/src/activities/cleanup_activity.rs:4
Functiondo_something_async
( ctx: ActContext, _payload: Option<String>, )
activities-examples/src/activities/async_completion.rs:20
Functionfake_progress_activity
( ctx: ActContext, sleep_interval_ms: u64, )
activities-cancellation-heartbeating/src/activities/fake_progress_activity.rs:5
Functionhttp_workflow
(ctx: WfContext)
activities-examples/src/workflows.rs:10
Functionmain
()
activities-examples/src/bin/main.rs:6
Functionmain
()
activities-examples/src/bin/client.rs:9
Functionmain
()
activities-cancellation-heartbeating/src/bin/main.rs:6
Functionmain
()
activities-cancellation-heartbeating/src/bin/client.rs:10
Functionmain
()
timer/src/bin/main.rs:6
Functionmain
()
timer/src/bin/client.rs:9
Functionmain
()
schedule/src/bin/main.rs:6
Functionmain
()
schedule/src/bin/client.rs:24
Functionmake_http_request
( _ctx: ActContext, _payload: Option<String>, )
activities-examples/src/activities/make_http_request.rs:12
Functionorder_processing_activity
( _ctx: ActContext, _payload: Option<String>, )
timer/src/activities/order_processing_activity.rs:5
Functionparse_activity_result
(result: &'a ActivityResolution)
temporal-helpers/src/parse_activity_result.rs:7
Functionrun_cancellable_activity
(mut ctx: WfContext)
activities-cancellation-heartbeating/src/workflows.rs:10
Functionsample_schedule_workflow
(ctx: WfContext)
schedule/src/workflows.rs:5
Functionsend_email_activity
( _ctx: ActContext, _payload: Option<String>, )
timer/src/activities/send_email_activity.rs:4
Functionskipped_activity
( _ctx: ActContext, _payload: Option<String>, )
activities-cancellation-heartbeating/src/activities/skipped_activity.rs:4
Functionwf_function
(ctx: WfContext)
timer/src/worker.rs:40