File tree Expand file tree Collapse file tree 4 files changed +49
-2
lines changed Expand file tree Collapse file tree 4 files changed +49
-2
lines changed Original file line number Diff line number Diff line change @@ -10,7 +10,8 @@ fn main() -> Result<()> {
10
10
"flow.proto" ,
11
11
"action.proto" ,
12
12
"transfer.proto" ,
13
- "ping.proto"
13
+ "ping.proto" ,
14
+ "action_execute.proto"
14
15
] ;
15
16
16
17
let inclusions = & [
Original file line number Diff line number Diff line change
1
+ syntax = "proto3" ;
2
+
3
+ option ruby_package = "Tucana::Aquila" ;
4
+
5
+ package aquila ;
6
+
7
+ message ActionCallRequest {
8
+ string identifier = 1 ;
9
+ repeated string parameters = 2 ;
10
+ }
11
+
12
+ message ActionCallResponse {
13
+ string execution_identifier = 1 ;
14
+ }
15
+
16
+ message ActionResult {
17
+ repeated string result = 1 ;
18
+ }
19
+
20
+ message ActionResultRequest {
21
+ string execution_identifier = 1 ;
22
+ }
23
+
24
+ message ActionResultResponse {
25
+ optional ActionResult action_result = 1 ;
26
+ }
27
+
28
+ service ActionCallService {
29
+ rpc Call (ActionCallRequest ) returns (ActionCallResponse );
30
+ }
31
+
32
+ service ActionResultService {
33
+ rpc GetResult (ActionResultRequest ) returns (ActionResultResponse );
34
+ }
Original file line number Diff line number Diff line change @@ -16,6 +16,18 @@ message InformationResponse {
16
16
bool success = 1 ;
17
17
}
18
18
19
+ message ActionExecuteRequest {
20
+ string execution_identifier = 1 ;
21
+ string function_identifier = 2 ;
22
+ repeated string parameters = 3 ;
23
+ }
24
+
25
+ message ActionExecuteResponse {
26
+ string execution_identifier = 1 ;
27
+ repeated string result = 2 ;
28
+ }
29
+
19
30
service ActionTransferService {
20
31
rpc Transfer (stream InformationRequest ) returns (InformationResponse );
32
+ rpc Execute (stream ActionExecuteRequest ) returns (stream ActionExecuteResponse );
21
33
}
You can’t perform that action at this time.
0 commit comments