Skip to content

Commit 2ef93a7

Browse files
committed
Add runtime status service
1 parent 5fa6b02 commit 2ef93a7

File tree

2 files changed

+110
-0
lines changed

2 files changed

+110
-0
lines changed
Lines changed: 55 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,55 @@
1+
syntax = "proto3";
2+
3+
package aquila;
4+
5+
option ruby_package = "Tucana::Aquila";
6+
7+
message AdapaterStatusInformation {
8+
oneof data {
9+
string endpoint = 1; // e.g. URL, cron expression, ...
10+
}
11+
}
12+
13+
enum Status {
14+
UNKNOWN = 0;
15+
NOT_RESPONDING = 1;
16+
NOT_READY = 2;
17+
RUNNING = 3;
18+
STOPPED = 4;
19+
}
20+
21+
message AdapterRuntimeStatus {
22+
Status status = 1;
23+
string timestamp = 2; // epoch timestamp in milliseconds
24+
25+
string identifier = 3; // unique identifier of the adapter
26+
27+
// All the supported features: e.g. ['http'] / ['cron'] / ['http', 'cron']
28+
repeated string feature_set = 4;
29+
repeated AdapaterStatusInformation informations = 5;
30+
}
31+
32+
message ExecutionRuntimeStatus {
33+
Status status = 1;
34+
string timestamp = 2; // epoch timestamp in milliseconds
35+
36+
string identifier = 3; // unique identifier of the adapter
37+
38+
// All the supported features: e.g. ['http'] / ['cron'] / ['http', 'cron']
39+
repeated string feature_set = 4;
40+
}
41+
42+
message RuntimeStatusUpdateRequest {
43+
oneof status {
44+
AdapterRuntimeStatus adapter_runtime_status = 1;
45+
ExecutionRuntimeStatus execution_runtime_status = 2;
46+
}
47+
}
48+
49+
message RuntimeStatusUpdateResponse {
50+
bool success = 1;
51+
}
52+
53+
service RuntimeStatusService {
54+
rpc Update(RuntimeStatusUpdateRequest) returns (RuntimeStatusUpdateResponse) {}
55+
}
Lines changed: 55 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,55 @@
1+
syntax = "proto3";
2+
3+
package sagittarius;
4+
5+
option ruby_package = "Tucana::Sagittarius";
6+
7+
message AdapaterStatusInformation {
8+
oneof data {
9+
string endpoint = 1; // e.g. URL, cron expression, ...
10+
}
11+
}
12+
13+
enum Status {
14+
UNKNOWN = 0;
15+
NOT_RESPONDING = 1;
16+
NOT_READY = 2;
17+
RUNNING = 3;
18+
STOPPED = 4;
19+
}
20+
21+
message AdapterRuntimeStatus {
22+
Status status = 1;
23+
string timestamp = 2; // epoch timestamp in milliseconds
24+
25+
string identifier = 3; // unique identifier of the adapter
26+
27+
// All the supported features: e.g. ['http'] / ['cron'] / ['http', 'cron']
28+
repeated string feature_set = 4;
29+
repeated AdapaterStatusInformation informations = 5;
30+
}
31+
32+
message ExecutionRuntimeStatus {
33+
Status status = 1;
34+
string timestamp = 2; // epoch timestamp in milliseconds
35+
36+
string identifier = 3; // unique identifier of the adapter
37+
38+
// All the supported features: e.g. ['http'] / ['cron'] / ['http', 'cron']
39+
repeated string feature_set = 4;
40+
}
41+
42+
message RuntimeStatusUpdateRequest {
43+
oneof status {
44+
AdapterRuntimeStatus adapter_runtime_status = 1;
45+
ExecutionRuntimeStatus execution_runtime_status = 2;
46+
}
47+
}
48+
49+
message RuntimeStatusUpdateResponse {
50+
bool success = 1;
51+
}
52+
53+
service RuntimeStatusService {
54+
rpc Update(RuntimeStatusUpdateRequest) returns (RuntimeStatusUpdateResponse) {}
55+
}

0 commit comments

Comments
 (0)