Commit 1af275a
authored
6 files changed
+10
-6
lines changedLines changed: 5 additions & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
10 | 10 | | |
11 | 11 | | |
12 | 12 | | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
13 | 17 | | |
14 | 18 | | |
15 | 19 | | |
| |||
1356 | 1360 | | |
1357 | 1361 | | |
1358 | 1362 | | |
1359 | | - | |
| 1363 | + | |
- .github/workflows/validate_examples.yaml+4-4
- Makefile+1-1
- client/subscribe.go+20-6
- examples/go.mod+3-3
- examples/go.sum+4-4
- examples/streamsub/README.md+1-1
- examples/streamsub/config/pubsub.yaml
- examples/streamsub/pub/pub.go
- examples/streamsub/sub/sub.go+5-5
- examples/workflow/README.md+1-8
- examples/workflow/main.go+28-160
- go.mod+3-3
- go.sum+4-4
- service/http/topic.go+6
- version/sdk-version+1-1
- workflow/client.go+41-3
- workflow/client_test.go+4-1
- workflow/context.go+5
- workflow/state.go+30
Submodule java updated 1432 files
- .github/workflows/test-e2e.yml+3-3
- README.md-17
- documentation/development.md+20-5
- examples/distributedLock/README.md+1-1
- examples/workflow/authoring/package-lock.json+2-2
- examples/workflow/management/package-lock.json+2-2
- package-lock.json+9-9
- package.json+2-2
- scripts/fetch-proto.sh+1-1
- scripts/src/proto/dapr/proto/common/v1/common.proto+160
- scripts/src/proto/dapr/proto/internals/v1/apiversion.proto+27
- scripts/src/proto/dapr/proto/internals/v1/service_invocation.proto+125
- scripts/src/proto/dapr/proto/internals/v1/status.proto+32
- scripts/src/proto/dapr/proto/operator/v1/operator.proto+172
- scripts/src/proto/dapr/proto/placement/v1/placement.proto+56
- scripts/src/proto/dapr/proto/runtime/v1/appcallback.proto+343
- scripts/src/proto/dapr/proto/runtime/v1/dapr.proto+1.3k
- scripts/src/proto/dapr/proto/sentry/v1/sentry.proto+60
- scripts/src/proto/google/protobuf/any.proto+162
- scripts/src/proto/google/protobuf/empty.proto+51
- scripts/src/proto/google/protobuf/timestamp.proto+144
- src/actors/runtime/AbstractActor.ts+1-1
- src/proto/dapr/proto/common/v1/common_pb.js+11-3
- src/proto/dapr/proto/internals/v1/apiversion_pb.js+7-1
- src/proto/dapr/proto/internals/v1/service_invocation.proto+5
- src/proto/dapr/proto/internals/v1/service_invocation_grpc_pb.d.ts-77
- src/proto/dapr/proto/internals/v1/service_invocation_grpc_pb.js-125
- src/proto/dapr/proto/internals/v1/service_invocation_pb.d.ts-189
- src/proto/dapr/proto/internals/v1/service_invocation_pb.js-1.4k
- src/proto/dapr/proto/internals/v1/status_pb.js+7-1
- src/proto/dapr/proto/operator/v1/operator.proto+17
- src/proto/dapr/proto/operator/v1/operator_grpc_pb.d.ts+15
- src/proto/dapr/proto/operator/v1/operator_grpc_pb.js+34
- src/proto/dapr/proto/operator/v1/operator_pb.d.ts+48
- src/proto/dapr/proto/operator/v1/operator_pb.js+395-1
- src/proto/dapr/proto/placement/v1/placement.proto+1
- src/proto/dapr/proto/placement/v1/placement_pb.d.ts+3
- src/proto/dapr/proto/placement/v1/placement_pb.js+44-5
- src/proto/dapr/proto/runtime/v1/appcallback.proto+30
- src/proto/dapr/proto/runtime/v1/appcallback_grpc_pb.d.ts+18
- src/proto/dapr/proto/runtime/v1/appcallback_grpc_pb.js+35
- src/proto/dapr/proto/runtime/v1/appcallback_pb.d.ts+56
- src/proto/dapr/proto/runtime/v1/appcallback_pb.js+455-6
- src/proto/dapr/proto/runtime/v1/dapr.proto+184-18
- src/proto/dapr/proto/runtime/v1/dapr_grpc_pb.d.ts+68
- src/proto/dapr/proto/runtime/v1/dapr_grpc_pb.js+138
- src/proto/dapr/proto/runtime/v1/dapr_pb.d.ts+334
- src/proto/dapr/proto/runtime/v1/dapr_pb.js+8.2k-5.8k
- src/proto/dapr/proto/sentry/v1/sentry_pb.js+7-1
- src/proto/google/protobuf/any_pb.js+7-1
- src/proto/google/protobuf/empty_pb.js+7-1
- src/proto/google/protobuf/timestamp_pb.js+7-1
- src/utils/HttpVerb.util.ts+4
- src/workflow/client/DaprWorkflowClient.ts+4-3
- src/workflow/internal/index.ts+11-1
- src/workflow/runtime/WorkflowRuntime.ts+4-3
- test/components/binding-mqtt.yaml+3-1
- test/e2e/grpc/server.test.ts+4-1
- .github/workflows/fossa.yaml+2-2
- README.md+1-1
- dapr/aio/clients/grpc/client.py+70-1
- dapr/aio/clients/grpc/interceptors.py+19-3
- dapr/aio/clients/grpc/subscription.py+116
- dapr/clients/grpc/client.py+75-1
- dapr/clients/grpc/interceptors.py+22-5
- dapr/clients/grpc/subscription.py+145
- dapr/common/pubsub/subscription.py+92
- dapr/proto/common/v1/common_pb2.py+8-8
- dapr/proto/common/v1/common_pb2.pyi+31-39
- dapr/proto/common/v1/common_pb2_grpc.py-25
- dapr/proto/runtime/v1/appcallback_pb2.py+12-12
- dapr/proto/runtime/v1/appcallback_pb2.pyi+69-87
- dapr/proto/runtime/v1/appcallback_pb2_grpc.py+32-137
- dapr/proto/runtime/v1/dapr_pb2.py+280-256
- dapr/proto/runtime/v1/dapr_pb2.pyi+575-375
- dapr/proto/runtime/v1/dapr_pb2_grpc.py+269-841
- daprdocs/content/en/python-sdk-docs/python-client.md+122-2
- examples/invoke-binding/README.md+3-3
- examples/pubsub-streaming-async/README.md+122
- examples/pubsub-streaming-async/publisher.py+52
- examples/pubsub-streaming-async/subscriber-handler.py+50
- examples/pubsub-streaming-async/subscriber.py+67
- examples/pubsub-streaming/README.md+121
- examples/pubsub-streaming/publisher.py+43
- examples/pubsub-streaming/subscriber-handler.py+44
- examples/pubsub-streaming/subscriber.py+76
- tests/clients/fake_dapr_server.py+55-2
- tests/clients/test_dapr_grpc_client.py+125
- tests/clients/test_dapr_grpc_client_async.py+123-2
- tests/clients/test_subscription.py+109
- tools/requirements.txt+1-1
- tox.ini+2
0 commit comments