9 files changed
+14
-11
lines changedLines changed: 6 additions & 3 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
33 | 33 |
| |
34 | 34 |
| |
35 | 35 |
| |
| 36 | + | |
| 37 | + | |
36 | 38 |
| |
37 | 39 |
| |
38 | 40 |
| |
| |||
45 | 47 |
| |
46 | 48 |
| |
47 | 49 |
| |
48 |
| - | |
| 50 | + | |
49 | 51 |
| |
50 |
| - | |
51 |
| - | |
| 52 | + | |
| 53 | + | |
| 54 | + | |
52 | 55 |
| |
53 | 56 |
| |
54 | 57 |
| |
|
- .github/workflows/validate_examples.yaml+4-3
- client/client.go+15-8
- client/client_test.go+14-4
- client/conversation.go+3-1
- client/jobs.go+232
- client/jobs_test.go+119
- client/scheduling.go-90
- client/scheduling_test.go-57
- client/state.go-20
- client/state_test.go+2-1
- client/utils.go+3-1
- daprdocs/content/en/go-sdk-contributing/go-contributing.md+2-2
- daprdocs/content/en/go-sdk-docs/_index.md+2-2
- daprdocs/content/en/go-sdk-docs/go-client/_index.md+139-36
- daprdocs/content/en/go-sdk-docs/go-service/_index.md+2-2
- examples/go.mod+14-14
- examples/go.sum+26-26
- examples/jobs/README.md+5-5
- examples/jobs/api/backup.go
- examples/jobs/main.go+12-10
- examples/workflow-taskexecutionid/README.md+61
- examples/workflow-taskexecutionid/config/redis.yaml+14
- examples/workflow-taskexecutionid/main.go+108
- examples/workflow/main.go+4
- go.mod+13-13
- go.sum+24-24
- version/sdk-version+1-1
- workflow/activity_context.go+4
- workflow/activity_context_test.go+27-2
- workflow/client.go+4-1
- workflow/worker.go+16-9
Submodule java updated 1284 files
- daprdocs/content/en/js-sdk-contributing/js-contributing.md+2-2
- daprdocs/content/en/js-sdk-docs/_index.md+5-5
- daprdocs/content/en/js-sdk-docs/js-actors/_index.md+5-5
- daprdocs/content/en/js-sdk-docs/js-client/_index.md+9-9
- daprdocs/content/en/js-sdk-docs/js-logger/_index.md+2-2
- daprdocs/content/en/js-sdk-docs/js-server/_index.md+6-6
- daprdocs/content/en/js-sdk-docs/js-workflow/_index.md+2-2
- scripts/fetch-proto.sh+1-1
- scripts/src/proto/dapr/proto/common/v1/common.proto+27-3
- scripts/src/proto/dapr/proto/internals/v1/service_invocation.proto+4
- scripts/src/proto/dapr/proto/runtime/v1/dapr.proto+380-22
- .codecov.yml+11
- .github/workflows/build.yaml+77-4
- Dapr.PluggableComponents.Complete.sln+7
- Directory.Packages.props+26
- NuGet.Config+7
- README.md+10-2
- daprdocs/content/en/dotnet-sdk-docs/_index.md+25-6
- daprdocs/content/en/dotnet-sdk-docs/dotnet-advanced/dotnet-application-environment.md+9
- daprdocs/content/en/dotnet-sdk-docs/dotnet-advanced/dotnet-component-lifetime.md+8
- daprdocs/content/en/dotnet-sdk-docs/dotnet-advanced/dotnet-multiple-services.md+9
- daprdocs/content/en/dotnet-sdk-docs/dotnet-bindings/_index.md+7
- daprdocs/content/en/dotnet-sdk-docs/dotnet-pub-sub/_index.md+7
- daprdocs/content/en/dotnet-sdk-docs/dotnet-state-store/_index.md+7
- samples/AzureStorageQueuesPubSubSample/AzureStorageQueuesPubSub.cs+4-4
- samples/AzureStorageQueuesPubSubSample/AzureStorageQueuesPubSubSample.csproj+2-2
- samples/DiscordBindingSample/DiscordBinding.cs+2-2
- samples/DiscordBindingSample/DiscordBindingSample.csproj+3-3
- src/Dapr.PluggableComponents.AspNetCore/Dapr.PluggableComponents.AspNetCore.csproj+18-3
- src/Dapr.PluggableComponents.AspNetCore/DaprPluggableComponentsApplication.cs+95-23
- src/Dapr.PluggableComponents.AspNetCore/DaprPluggableComponentsRegistry.cs+13-20
- src/Dapr.PluggableComponents.AspNetCore/RegisteredComponentProvider.cs+4-2
- src/Dapr.PluggableComponents.AspNetCore/Resources.Designer.cs+135
- src/Dapr.PluggableComponents.AspNetCore/Resources.resx+149
- src/Dapr.PluggableComponents.AspNetCore/WebApplicationBuilderExtensions.cs+7-7
- src/Dapr.PluggableComponents.Protos/.gitignore-4
- src/Dapr.PluggableComponents.Protos/Dapr.PluggableComponents.Protos.csproj+11-11
- src/Dapr.PluggableComponents.Tests/Adaptors/AdaptorFixture.cs+159
- src/Dapr.PluggableComponents.Tests/Adaptors/AsyncStreamReader.cs+54
- src/Dapr.PluggableComponents.Tests/Adaptors/InputBindingAdaptorTests.cs+195
- src/Dapr.PluggableComponents.Tests/Adaptors/OutputBindingAdaptorTests.cs+82
- src/Dapr.PluggableComponents.Tests/Adaptors/PubSubAdaptorTests.cs+373
- src/Dapr.PluggableComponents.Tests/Adaptors/StateStoreAdaptorTests.cs+243
- src/Dapr.PluggableComponents.Tests/Adaptors/TestServerCallContext.cs+69
- src/Dapr.PluggableComponents.Tests/Adaptors/TransactionalStateStoreAdaptorTests.cs+63
- src/Dapr.PluggableComponents.Tests/AssemblyInfo.cs+16
- src/Dapr.PluggableComponents.Tests/Components/Bindings/InputBindingReadRequestTests.cs+47
- src/Dapr.PluggableComponents.Tests/Components/Bindings/InputBindingReadResponseTests.cs+43
- src/Dapr.PluggableComponents.Tests/Components/Bindings/MockCombinedBinding.cs+62
- src/Dapr.PluggableComponents.Tests/Components/Bindings/MockInputBinding.cs+45
- src/Dapr.PluggableComponents.Tests/Components/Bindings/MockOutputBinding.cs+49
- src/Dapr.PluggableComponents.Tests/Components/Bindings/OutputBindingInvokeRequestTests.cs+48
- src/Dapr.PluggableComponents.Tests/Components/Bindings/OutputBindingInvokeResponseTests.cs+38
- src/Dapr.PluggableComponents.Tests/Components/IMockPluggableComponent.cs+19
- src/Dapr.PluggableComponents.Tests/Components/PubSub/MockPubSub.cs+49
- src/Dapr.PluggableComponents.Tests/Components/PubSub/PubSubPublishRequestTests.cs+65
- src/Dapr.PluggableComponents.Tests/Components/PubSub/PubSubPullMessagesResponseTests.cs+43
- src/Dapr.PluggableComponents.Tests/Components/PubSub/PubSubPullMessagesTopicTests.cs+42
- src/Dapr.PluggableComponents.Tests/Components/StateStore/MockBulkStateStore.cs+48
- src/Dapr.PluggableComponents.Tests/Components/StateStore/MockQueryableStateStore.cs+38
- src/Dapr.PluggableComponents.Tests/Components/StateStore/MockStateStore.cs+54
- src/Dapr.PluggableComponents.Tests/Components/StateStore/MockTransactionalStateStore.cs+38
- src/Dapr.PluggableComponents.Tests/Components/StateStore/StateStoreBulkStateItemTests.cs+141
- src/Dapr.PluggableComponents.Tests/Components/StateStore/StateStoreDeleteRequestTests.cs+113
- src/Dapr.PluggableComponents.Tests/Components/StateStore/StateStoreGetRequestTests.cs+80
- src/Dapr.PluggableComponents.Tests/Components/StateStore/StateStoreGetResponseTests.cs+106
- src/Dapr.PluggableComponents.Tests/Components/StateStore/StateStoreQueryItemTests.cs+50
- src/Dapr.PluggableComponents.Tests/Components/StateStore/StateStoreQueryPaginationTests.cs+36
- src/Dapr.PluggableComponents.Tests/Components/StateStore/StateStoreQueryRequestTests.cs+60
- src/Dapr.PluggableComponents.Tests/Components/StateStore/StateStoreQueryResponseTests.cs+48
- src/Dapr.PluggableComponents.Tests/Components/StateStore/StateStoreQuerySortingTests.cs+58
- src/Dapr.PluggableComponents.Tests/Components/StateStore/StateStoreQueryTests.cs+102
- src/Dapr.PluggableComponents.Tests/Components/StateStore/StateStoreSetRequestTests.cs+73
- src/Dapr.PluggableComponents.Tests/Components/StateStore/StateStoreStateOptionsTests.cs+77
- src/Dapr.PluggableComponents.Tests/Components/StateStore/StateStoreTransactOperationTests.cs+68
- src/Dapr.PluggableComponents.Tests/Components/StateStore/StateStoreTransactRequestTests.cs+60
- src/Dapr.PluggableComponents.Tests/ConversionAssert.cs+193
- src/Dapr.PluggableComponents.Tests/Dapr.PluggableComponents.Tests.csproj+35
- src/Dapr.PluggableComponents.Tests/DaprPluggableComponentsApplicationTests.cs+67
- src/Dapr.PluggableComponents.Tests/DaprPluggableComponentsServiceBuilderTests.cs+393
- src/Dapr.PluggableComponents.Tests/SocketFixture.cs+85
- src/Dapr.PluggableComponents.Tests/TestConstants.cs+22
- src/Dapr.PluggableComponents.Tests/Unit.cs+34
- src/Dapr.PluggableComponents.sln+6
- src/Dapr.PluggableComponents/Adaptors/InputBindingAdaptor.cs+65-34
- src/Dapr.PluggableComponents/Adaptors/OutputBindingAdaptor.cs+1-1
- src/Dapr.PluggableComponents/Adaptors/PubSubAdaptor.cs+71-45
- src/Dapr.PluggableComponents/Adaptors/QueryableStateStoreAdaptor.cs+1-1
- src/Dapr.PluggableComponents/Adaptors/StateStoreAdaptor.cs+3-27
- src/Dapr.PluggableComponents/AssemblyInfo.cs+16
- src/Dapr.PluggableComponents/Components/Bindings/IOutputBinding.cs+1-1
- src/Dapr.PluggableComponents/Components/PubSub/PubSubPublishRequest.cs+13-1
- src/Dapr.PluggableComponents/Components/PubSub/PubSubPullMessagesTopic.cs+10
- src/Dapr.PluggableComponents/Components/StateStore/BulkDeleteRowMismatchException.cs+2-2
- src/Dapr.PluggableComponents/Components/StateStore/ETagInvalidException.cs+3-3
- src/Dapr.PluggableComponents/Components/StateStore/ETagMismatchException.cs+3-3
- src/Dapr.PluggableComponents/Components/StateStore/StateStoreGetResponse.cs+24
- src/Dapr.PluggableComponents/Components/StateStore/StateStoreQueryResponse.cs+1-1
- src/Dapr.PluggableComponents/Components/StateStore/StateStoreQuerySorting.cs+2-2
- src/Dapr.PluggableComponents/Components/StateStore/StateStoreStateOptions.cs+30-7
- src/Dapr.PluggableComponents/Components/StateStore/StateStoreTransactOperation.cs+1-1
- src/Dapr.PluggableComponents/Constants.cs+2-5
- src/Dapr.PluggableComponents/Dapr.PluggableComponents.csproj+15
- src/Dapr.PluggableComponents/Resources.Designer.cs+144
- src/Dapr.PluggableComponents/Resources.resx+153
- src/Directory.Build.props+4-4
- .github/workflows/ci.yaml+4-4
- .golangci.yml+21
- bindings/v1/input_wrapper.go+1-1
- bindings/v1/output_wrapper.go+1-1
- daprdocs/content/en/go-sdk-docs/_index.md+17-12
- daprdocs/content/en/go-sdk-docs/go-advanced/_index.md+3-3
- daprdocs/content/en/go-sdk-docs/go-bindings/_index.md+3-3
- daprdocs/content/en/go-sdk-docs/go-pub-sub/_index.md+3-3
- daprdocs/content/en/go-sdk-docs/go-state-store/_index.md+4-4
- examples/bindings.kafka/go.mod+26-19
- examples/bindings.kafka/go.sum+76-39
- examples/mesh/go.mod+26-20
- examples/mesh/go.sum+77-43
- examples/pubsub.kafka/go.mod+26-19
- examples/pubsub.kafka/go.sum+76-39
- examples/pubsub.memory/go.mod+19-12
- examples/pubsub.memory/go.sum+46-24
- examples/pubsub.redis/go.mod+22-13
- examples/pubsub.redis/go.sum+55-26
- examples/state.memory/go.mod+17-12
- examples/state.memory/go.sum+40-24
- examples/state.redis/go.mod+19-13
- examples/state.redis/go.sum+48-28
- go.mod+20-13
- go.sum+50-30
- go.work+1-1
- go.work.sum+2.3k-9
- pubsub/v1/pubsub.go+4
- pubsub/v1/wrapper.go+42-3
- pubsub/v1/wrapper_test.go+3-3
- socket_unix.go+1-2
- state/v1/wrapper.go+9-20
- README.md+2
- dapr/aio/clients/__init__.py+5
- dapr/aio/clients/grpc/client.py+106
- dapr/clients/__init__.py+5
- dapr/clients/grpc/_jobs.py+184
- dapr/clients/grpc/_request.py+27
- dapr/clients/grpc/client.py+103
- dapr/proto/common/v1/common_pb2.py+34-27
- dapr/proto/common/v1/common_pb2.pyi+65
- dapr/proto/runtime/v1/dapr_pb2.py+338-285
- dapr/proto/runtime/v1/dapr_pb2.pyi+641-8
- dapr/proto/runtime/v1/dapr_pb2_grpc.py+34
- daprdocs/content/en/python-sdk-contributing/python-contributing.md+2-2
- daprdocs/content/en/python-sdk-docs/_index.md+16-16
- daprdocs/content/en/python-sdk-docs/python-actor.md+5-5
- daprdocs/content/en/python-sdk-docs/python-client.md+14-14
- daprdocs/content/en/python-sdk-docs/python-sdk-extensions/python-fastapi.md+7-7
- daprdocs/content/en/python-sdk-docs/python-sdk-extensions/python-flask.md+7-7
- daprdocs/content/en/python-sdk-docs/python-sdk-extensions/python-grpc.md+6-6
- daprdocs/content/en/python-sdk-docs/python-sdk-extensions/python-workflow-ext/_index.md+9-9
- daprdocs/content/en/python-sdk-docs/python-sdk-extensions/python-workflow-ext/python-workflow.md+5-5
- examples/demo_workflow/README.md+3-2
- examples/demo_workflow/app.py+8-6
- examples/jobs/README.md+259
- examples/jobs/job_management.py+128
- examples/jobs/job_processing.py+138
- ext/dapr-ext-grpc/dapr/ext/grpc/__init__.py+7-1
- ext/dapr-ext-grpc/dapr/ext/grpc/_servicer.py+55-3
- ext/dapr-ext-grpc/dapr/ext/grpc/app.py+27
- py.typed
- setup.py+1
- tests/clients/fake_dapr_server.py+45
- tests/clients/test_dapr_grpc_client.py+169
- tests/clients/test_dapr_grpc_client_async.py+236
- tests/clients/test_jobs.py+190
- tox.ini+1
0 commit comments