2 files changed
+6
-1
lines changed- .cargo/config.toml+1-1
- client/src/callback_based.rs+123
- client/src/lib.rs+96-28
- client/src/metrics.rs+33-5
- client/src/raw.rs+40-1
- client/src/retry.rs+12-3
- core-api/src/worker.rs+2-2
- core-c-bridge/Cargo.toml+2
- core-c-bridge/include/temporal-sdk-core-c-bridge.h+105
- core-c-bridge/src/client.rs+265-8
- core-c-bridge/src/tests/context.rs+11
- core-c-bridge/src/tests/mod.rs+179-3
- core/src/lib.rs+4-2
- core/src/pollers/poll_buffer.rs+62-14
- core/src/worker/client.rs+9-5
- core/src/worker/heartbeat.rs+3-1
- sdk-core-protos/protos/api_cloud_upstream/CODEOWNERS+1-1
- sdk-core-protos/protos/api_cloud_upstream/README.md+1-1
- sdk-core-protos/protos/api_cloud_upstream/VERSION+1-1
- sdk-core-protos/protos/api_cloud_upstream/buf.yaml+1
- sdk-core-protos/protos/api_cloud_upstream/temporal/api/cloud/cloudservice/v1/request_response.proto+83
- sdk-core-protos/protos/api_cloud_upstream/temporal/api/cloud/cloudservice/v1/service.proto+37
- sdk-core-protos/protos/api_cloud_upstream/temporal/api/cloud/connectivityrule/v1/message.proto+64
- sdk-core-protos/protos/api_cloud_upstream/temporal/api/cloud/identity/v1/message.proto+3-1
- sdk-core-protos/protos/api_cloud_upstream/temporal/api/cloud/namespace/v1/message.proto+10
- sdk-core-protos/protos/api_cloud_upstream/temporal/api/cloud/operation/v1/message.proto+1
- sdk-core-protos/protos/api_upstream/openapi/openapiv2.json+644-9
- sdk-core-protos/protos/api_upstream/openapi/openapiv3.yaml+635-21
- sdk-core-protos/protos/api_upstream/temporal/api/batch/v1/message.proto+60-2
- sdk-core-protos/protos/api_upstream/temporal/api/common/v1/message.proto+84-15
- sdk-core-protos/protos/api_upstream/temporal/api/enums/v1/batch_operation.proto+3
- sdk-core-protos/protos/api_upstream/temporal/api/enums/v1/task_queue.proto+11
- sdk-core-protos/protos/api_upstream/temporal/api/history/v1/message.proto+5
- sdk-core-protos/protos/api_upstream/temporal/api/sdk/v1/task_complete_metadata.proto+1-1
- sdk-core-protos/protos/api_upstream/temporal/api/sdk/v1/worker_config.proto+36
- sdk-core-protos/protos/api_upstream/temporal/api/taskqueue/v1/message.proto+29
- sdk-core-protos/protos/api_upstream/temporal/api/worker/v1/message.proto+11-1
- sdk-core-protos/protos/api_upstream/temporal/api/workflowservice/v1/request_response.proto+122-4
- sdk-core-protos/protos/api_upstream/temporal/api/workflowservice/v1/service.proto+41
- sdk-core-protos/src/lib.rs+5-1
- test-utils/Cargo.toml+1
- test-utils/src/lib.rs+90-3
- tests/cloud_tests.rs+11-74
- tests/integ_tests/client_tests.rs+14-10
- tests/integ_tests/worker_tests.rs+8-2
- tests/integ_tests/workflow_tests/activities.rs+13
- tests/integ_tests/workflow_tests/priority.rs+2-108
- tests/main.rs+3
- tests/shared_tests/mod.rs+43
- tests/shared_tests/priority.rs+155
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
220 | 220 | | |
221 | 221 | | |
222 | 222 | | |
| 223 | + | |
223 | 224 | | |
224 | 225 | | |
225 | 226 | | |
| |||
399 | 400 | | |
400 | 401 | | |
401 | 402 | | |
| 403 | + | |
402 | 404 | | |
403 | 405 | | |
404 | 406 | | |
405 | 407 | | |
406 | 408 | | |
407 | 409 | | |
408 | 410 | | |
| 411 | + | |
| 412 | + | |
| 413 | + | |
409 | 414 | | |
410 | 415 | | |
411 | 416 | | |
| |||
0 commit comments