Commit c3779da
authored
File tree
29 files changed
+583
-163
lines changed- temporalio
- ext
- src
- lib/temporalio
- api
- batch/v1
- cloud
- cloudservice/v1
- connectivityrule/v1
- identity/v1
- namespace/v1
- operation/v1
- common/v1
- enums/v1
- history/v1
- sdk/v1
- taskqueue/v1
- worker/v1
- workflowservice/v1
- client/connection
- sig/temporalio
- client/connection
- test
- sig
29 files changed
+583
-163
lines changedSome generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.
- .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-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/pollers/poll_buffer.rs+62-14
- 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 | |
|---|---|---|---|
| |||
115 | 115 | | |
116 | 116 | | |
117 | 117 | | |
| 118 | + | |
| 119 | + | |
| 120 | + | |
118 | 121 | | |
119 | 122 | | |
120 | 123 | | |
| |||
480 | 483 | | |
481 | 484 | | |
482 | 485 | | |
| 486 | + | |
| 487 | + | |
| 488 | + | |
| 489 | + | |
| 490 | + | |
| 491 | + | |
| 492 | + | |
483 | 493 | | |
484 | 494 | | |
485 | 495 | | |
486 | 496 | | |
487 | 497 | | |
488 | 498 | | |
489 | 499 | | |
| 500 | + | |
| 501 | + | |
| 502 | + | |
490 | 503 | | |
491 | 504 | | |
492 | 505 | | |
| |||
574 | 587 | | |
575 | 588 | | |
576 | 589 | | |
| 590 | + | |
| 591 | + | |
| 592 | + | |
577 | 593 | | |
578 | 594 | | |
579 | 595 | | |
| |||
595 | 611 | | |
596 | 612 | | |
597 | 613 | | |
| 614 | + | |
| 615 | + | |
| 616 | + | |
598 | 617 | | |
599 | 618 | | |
600 | 619 | | |
| |||
631 | 650 | | |
632 | 651 | | |
633 | 652 | | |
| 653 | + | |
| 654 | + | |
| 655 | + | |
| 656 | + | |
| 657 | + | |
| 658 | + | |
634 | 659 | | |
635 | 660 | | |
636 | 661 | | |
| |||
705 | 730 | | |
706 | 731 | | |
707 | 732 | | |
| 733 | + | |
| 734 | + | |
| 735 | + | |
708 | 736 | | |
709 | 737 | | |
710 | 738 | | |
| |||
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.
Lines changed: 12 additions & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.
0 commit comments