From d8fa3cdcc47fae344188b3222e15c984d3829985 Mon Sep 17 00:00:00 2001 From: vinayada1 <28875764+vinayada1@users.noreply.github.com> Date: Wed, 11 Nov 2020 09:57:35 -0800 Subject: [PATCH] update proto files for rc release (#468) --- .../dapr/proto/dapr/v1/appcallback.proto | 12 ++++++ .../Protos/dapr/proto/dapr/v1/dapr.proto | 42 ++++++++++++++++++- 2 files changed, 53 insertions(+), 1 deletion(-) diff --git a/src/Dapr.Client/Protos/dapr/proto/dapr/v1/appcallback.proto b/src/Dapr.Client/Protos/dapr/proto/dapr/v1/appcallback.proto index cff336472..13d0e71bd 100644 --- a/src/Dapr.Client/Protos/dapr/proto/dapr/v1/appcallback.proto +++ b/src/Dapr.Client/Protos/dapr/proto/dapr/v1/appcallback.proto @@ -74,6 +74,18 @@ message TopicEventRequest { // TopicEventResponse is response from app on published message message TopicEventResponse { + // TopicEventResponseStatus allows apps to have finer control over handling of the message. + enum TopicEventResponseStatus { + // SUCCESS is the default behavior: message is acknowledged and not retried or logged. + SUCCESS = 0; + // RETRY status signals Dapr to retry the message as part of an expected scenario (no warning is logged). + RETRY = 1; + // DROP status signals Dapr to drop the message as part of an unexpected scenario (warning is logged). + DROP = 2; + } + + // The list of output bindings. + TopicEventResponseStatus status = 1; } // BindingEventRequest represents input bindings event. diff --git a/src/Dapr.Client/Protos/dapr/proto/dapr/v1/dapr.proto b/src/Dapr.Client/Protos/dapr/proto/dapr/v1/dapr.proto index 6d6665bff..a4ae55ccb 100644 --- a/src/Dapr.Client/Protos/dapr/proto/dapr/v1/dapr.proto +++ b/src/Dapr.Client/Protos/dapr/proto/dapr/v1/dapr.proto @@ -43,6 +43,15 @@ service Dapr { // Gets secrets from secret stores. rpc GetSecret(GetSecretRequest) returns (GetSecretResponse) {} + + // Register an actor timer. + rpc RegisterActorTimer(RegisterActorTimerRequest) returns (google.protobuf.Empty) {} + + // Unregister an actor timer. + rpc UnregisterActorTimer(UnregisterActorTimerRequest) returns (google.protobuf.Empty) {} + + // InvokeActor calls a method on an actor. + rpc InvokeActor (InvokeActorRequest) returns (InvokeActorResponse) {} } // InvokeServiceRequest represents the request message for Service invocation. @@ -226,4 +235,35 @@ message ExecuteStateTransactionRequest { // The metadata used for transactional operations. map metadata = 3; -} \ No newline at end of file +} + +// RegisterActorTimerRequest is the message to register a timer for an actor of a given type and id. +message RegisterActorTimerRequest { + string actor_type = 1; + string actor_id = 2; + string name = 3; + string due_time = 4; + string period = 5; + string callback = 6; + bytes data = 7; +} + +// UnregisterActorTimerRequest is the message to unregister an actor timer +message UnregisterActorTimerRequest { + string actor_type = 1; + string actor_id = 2; + string name = 3; +} + +// InvokeActorRequest is the message to call an actor. +message InvokeActorRequest { + string actor_type = 1; + string actor_id = 2; + string method = 3; + bytes data = 4; +} + +// InvokeActorResponse is the method that returns an actor invocation response. +message InvokeActorResponse { + bytes data = 1; +}