@@ -15,6 +15,7 @@ syntax = "proto3";
15
15
16
16
package dapr.proto.runtime.v1 ;
17
17
18
+ import "google/protobuf/any.proto" ;
18
19
import "google/protobuf/empty.proto" ;
19
20
import "dapr/proto/common/v1/common.proto" ;
20
21
import "google/protobuf/struct.proto" ;
@@ -59,8 +60,37 @@ service AppCallbackHealthCheck {
59
60
service AppCallbackAlpha {
60
61
// Subscribes bulk events from Pubsub
61
62
rpc OnBulkTopicEventAlpha1 (TopicEventBulkRequest ) returns (TopicEventBulkResponse ) {}
63
+
64
+ // Sends job back to the app's endpoint at trigger time.
65
+ rpc OnJobEventAlpha1 (JobEventRequest ) returns (JobEventResponse );
66
+ }
67
+
68
+ message JobEventRequest {
69
+ // Job name.
70
+ string name = 1 ;
71
+
72
+ // Job data to be sent back to app.
73
+ google.protobuf.Any data = 2 ;
74
+
75
+ // Required. method is a method name which will be invoked by caller.
76
+ string method = 3 ;
77
+
78
+ // The type of data content.
79
+ //
80
+ // This field is required if data delivers http request body
81
+ // Otherwise, this is optional.
82
+ string content_type = 4 ;
83
+
84
+ // HTTP specific fields if request conveys http-compatible request.
85
+ //
86
+ // This field is required for http-compatible request. Otherwise,
87
+ // this field is optional.
88
+ common.v1.HTTPExtension http_extension = 5 ;
62
89
}
63
90
91
+ // JobEventResponse is the response from the app when a job is triggered.
92
+ message JobEventResponse {}
93
+
64
94
// TopicEventRequest message is compatible with CloudEvent spec v1.0
65
95
// https://github.com/cloudevents/spec/blob/v1.0/spec.md
66
96
message TopicEventRequest {
@@ -310,4 +340,4 @@ message ListInputBindingsResponse {
310
340
311
341
// HealthCheckResponse is the message with the response to the health check.
312
342
// This message is currently empty as used as placeholder.
313
- message HealthCheckResponse {}
343
+ message HealthCheckResponse {}
0 commit comments