Commit 14cda12
authored
File tree
- src/Temporalio
- Api/Cloud
- CloudService/V1
- Identity/V1
- Namespace/V1
- Bridge
- Client
Lines changed: 2368 additions & 7 deletions
Large diffs are not rendered by default.
Large diffs are not rendered by default.
Large diffs are not rendered by default.
Large diffs are not rendered by default.
- crates/client/Cargo.toml+3-2
- crates/client/src/grpc.rs+10
- crates/common/Cargo.toml+8-11
- crates/common/protos/api_cloud_upstream/README.md+1-1
- crates/common/protos/api_cloud_upstream/VERSION+1-1
- crates/common/protos/api_cloud_upstream/temporal/api/cloud/cloudservice/v1/request_response.proto+75-1
- crates/common/protos/api_cloud_upstream/temporal/api/cloud/cloudservice/v1/service.proto+87
- crates/common/protos/api_cloud_upstream/temporal/api/cloud/identity/v1/message.proto+53
- crates/common/protos/api_cloud_upstream/temporal/api/cloud/namespace/v1/message.proto+62-2
- crates/common/src/data_converters.rs+133-39
- crates/common/src/data_converters/failure_converter.rs+1.5k
- crates/common/src/error.rs+1.2k
- crates/common/src/lib.rs+1
- crates/common/src/payload_visitor.rs+50-16
- crates/common/src/protos/mod.rs+8-16
- crates/common/src/telemetry.rs+14-14
- crates/common/src/telemetry/metrics.rs+3-3
- crates/macros/Cargo.toml+1-1
- crates/macros/src/workflow_definitions.rs+1-1
- crates/sdk-core-c-bridge/Cargo.toml+3-3
- crates/sdk-core-c-bridge/src/client.rs+11
- crates/sdk-core/Cargo.toml+22-8
- crates/sdk-core/benches/workflow_replay_bench.rs+5-5
- crates/sdk-core/src/core_tests/activity_tasks.rs+2-3
- crates/sdk-core/src/core_tests/mod.rs+1-1
- crates/sdk-core/src/core_tests/queries.rs+3-3
- crates/sdk-core/src/core_tests/replay_flag.rs+5-3
- crates/sdk-core/src/core_tests/updates.rs+1-1
- crates/sdk-core/src/core_tests/workers.rs+18-17
- crates/sdk-core/src/core_tests/workflow_cancels.rs+6-9
- crates/sdk-core/src/core_tests/workflow_tasks.rs+11-7
- crates/sdk-core/src/replay/canned_histories.rs+5-5
- crates/sdk-core/src/replay/history_builder.rs+20-12
- crates/sdk-core/src/replay/history_info.rs+5-4
- crates/sdk-core/src/replay/mod.rs+19-3
- crates/sdk-core/src/test_help/mod.rs+4
- crates/sdk-core/src/test_help/test_utils.rs+3-13
- crates/sdk-core/src/worker/workflow/history_update.rs+4-7
- crates/sdk-core/src/worker/workflow/machines/upsert_search_attributes_state_machine.rs+1-4
- crates/sdk-core/tests/common/activity_functions.rs+2-1
- crates/sdk-core/tests/common/workflows.rs+2-1
- crates/sdk-core/tests/integ_tests/async_activity_client_tests.rs+2-2
- crates/sdk-core/tests/integ_tests/data_converter_tests.rs+579-6
- crates/sdk-core/tests/integ_tests/heartbeat_tests.rs+24-25
- crates/sdk-core/tests/integ_tests/metrics_tests.rs+1-2
- crates/sdk-core/tests/integ_tests/pagination_tests.rs+9-9
- crates/sdk-core/tests/integ_tests/polling_tests.rs+2-4
- crates/sdk-core/tests/integ_tests/queries_tests.rs+4-3
- crates/sdk-core/tests/integ_tests/update_tests.rs+2-4
- crates/sdk-core/tests/integ_tests/worker_heartbeat_tests.rs+1-2
- crates/sdk-core/tests/integ_tests/worker_tests.rs+1-1
- crates/sdk-core/tests/integ_tests/workflow_tests.rs+5-6
- crates/sdk-core/tests/integ_tests/workflow_tests/activities.rs+180-13
- crates/sdk-core/tests/integ_tests/workflow_tests/cancel_external.rs+4-2
- crates/sdk-core/tests/integ_tests/workflow_tests/cancel_wf.rs+4-2
- crates/sdk-core/tests/integ_tests/workflow_tests/child_workflows.rs+250-8
- crates/sdk-core/tests/integ_tests/workflow_tests/continue_as_new.rs+5-2
- crates/sdk-core/tests/integ_tests/workflow_tests/determinism.rs+3-4
- crates/sdk-core/tests/integ_tests/workflow_tests/local_activities.rs+62-52
- crates/sdk-core/tests/integ_tests/workflow_tests/modify_wf_properties.rs+4-2
- crates/sdk-core/tests/integ_tests/workflow_tests/nexus.rs+1-1
- crates/sdk-core/tests/integ_tests/workflow_tests/patches.rs+8-14
- crates/sdk-core/tests/integ_tests/workflow_tests/queries.rs+5-3
- crates/sdk-core/tests/integ_tests/workflow_tests/replay.rs+12-13
- crates/sdk-core/tests/integ_tests/workflow_tests/signals.rs+1-1
- crates/sdk-core/tests/integ_tests/workflow_tests/timers.rs+5-4
- crates/sdk-core/tests/integ_tests/workflow_tests/upsert_search_attrs.rs+4-2
- crates/sdk/Cargo.toml+12-8
- crates/sdk/README.md+32-2
- crates/sdk/examples/saga/workflows.rs+6-4
- crates/sdk/src/activities.rs+73-16
- crates/sdk/src/error.rs+7
- crates/sdk/src/lib.rs+62-46
- crates/sdk/src/workflow_context.rs+143-155
- crates/sdk/src/workflow_future.rs+58-32
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
75 | 75 | | |
76 | 76 | | |
77 | 77 | | |
| 78 | + | |
| 79 | + | |
| 80 | + | |
| 81 | + | |
| 82 | + | |
| 83 | + | |
| 84 | + | |
| 85 | + | |
| 86 | + | |
| 87 | + | |
| 88 | + | |
78 | 89 | | |
79 | 90 | | |
80 | 91 | | |
| |||
174 | 185 | | |
175 | 186 | | |
176 | 187 | | |
| 188 | + | |
| 189 | + | |
| 190 | + | |
| 191 | + | |
| 192 | + | |
| 193 | + | |
| 194 | + | |
| 195 | + | |
| 196 | + | |
| 197 | + | |
| 198 | + | |
177 | 199 | | |
178 | 200 | | |
179 | 201 | | |
| |||
383 | 405 | | |
384 | 406 | | |
385 | 407 | | |
| 408 | + | |
| 409 | + | |
| 410 | + | |
| 411 | + | |
| 412 | + | |
| 413 | + | |
| 414 | + | |
| 415 | + | |
| 416 | + | |
| 417 | + | |
| 418 | + | |
| 419 | + | |
| 420 | + | |
| 421 | + | |
| 422 | + | |
| 423 | + | |
| 424 | + | |
| 425 | + | |
| 426 | + | |
| 427 | + | |
| 428 | + | |
| 429 | + | |
386 | 430 | | |
387 | 431 | | |
388 | 432 | | |
| |||
658 | 702 | | |
659 | 703 | | |
660 | 704 | | |
| 705 | + | |
| 706 | + | |
| 707 | + | |
| 708 | + | |
| 709 | + | |
| 710 | + | |
| 711 | + | |
| 712 | + | |
| 713 | + | |
| 714 | + | |
| 715 | + | |
661 | 716 | | |
662 | 717 | | |
663 | 718 | | |
| |||
0 commit comments