squads-temporal-sdk 0.1.0-alpha.1

Temporal Rust SDK
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
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66

//! Prelude for easy importing of required types when defining workflow and activity definitions

/// Registry prelude
#[allow(unused_imports)]
pub mod registry {
    pub use crate::workflow::into_workflow;
}

/// Activity prelude
#[allow(unused_imports)]
pub mod activity {
    pub use crate::{ActContext, ActExitValue, ActivityError};
    pub use serde::{Deserialize, Serialize};
    pub use squads_temporal_sdk_core_protos::temporal::api::failure::v1::Failure;
}

/// Workflow prelude
#[allow(unused_imports)]
pub mod workflow {
    pub use crate::workflow::AsyncFn;
    pub use crate::workflow::{execute_activity, execute_child_workflow, sleep};
    pub use crate::{
        ActivityOptions, ChildWorkflowOptions, LocalActivityOptions, Signal, SignalData,
        SignalWorkflowOptions, WfContext, WfExitValue, WorkflowResult,
    };
    pub use futures::FutureExt;
    pub use serde::{Deserialize, Serialize};
    pub use std::{
        fmt::{Debug, Display},
        future::Future,
        time::Duration,
    };
    pub use squads_temporal_sdk_core_protos::{
        coresdk::{
            AsJsonPayloadExt, FromPayloadsExt,
            activity_result::{self, activity_resolution},
            child_workflow::{Failure, Success, child_workflow_result},
            workflow_commands::ActivityCancellationType,
        },
        temporal::api::common::v1::Payload,
    };
}

/// Worker prelude
#[allow(unused_imports)]
pub mod worker {
    pub use crate::{Worker, sdk_client_options};
    pub use squads_temporal_sdk_core::{CoreRuntime, Url, init_worker};
    pub use squads_temporal_sdk_core_api::{
        errors::WorkflowErrorType,
        telemetry::TelemetryOptionsBuilder,
        worker::{
            PollerBehavior, WorkerConfigBuilder, WorkerDeploymentOptions, WorkerDeploymentVersion,
            WorkerTuner, WorkerVersioningStrategy,
        },
    };
}

/// Client prelude
#[allow(unused_imports)]
pub mod client {
    pub use crate::sdk_client_options;
    pub use squads_temporal_client::{
        Client, RetryClient, WfClientExt, WorkflowClientTrait, WorkflowOptions,
    };
}