Skip to content

feat: add optimus replay list #25

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
arinda-arif merged 7 commits into from
Sep 6, 2021
Merged

feat: add optimus replay list #25

Changes from all commits
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
55b0dc6
feat: add get replay list
arinda-arif Aug 20, 2021
5e972d9
fix: change get replay list url
arinda-arif Aug 20, 2021
2948d74
refactor: rearrange optimus replay path
arinda-arif Aug 24, 2021
728e88f
refactor: use proper http mapping on optimus replay custom method (dr…
arinda-arif Aug 24, 2021
5723ffe
refactor: change optimus GetReplayList to ListReplays to follow metho…
arinda-arif Aug 24, 2021
dbb519a
refactor: change optimus replay dry run method name to follow custom …
arinda-arif Aug 25, 2021
f5401d0
fix: solve optimus api conflict, change replayspec field type, remove…
arinda-arif Aug 25, 2021
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
50 changes: 40 additions & 10 deletions odpf/optimus/runtime_service.proto
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -177,21 +177,26 @@ service RuntimeService {
body: "*"
};
}
rpc ReplayDryRun(ReplayRequest) returns (ReplayDryRunResponse) {
rpc DryRunReplay(DryRunReplayRequest) returns (DryRunReplayResponse) {
option (google.api.http) = {
post: "/v1/project/{project_name}/job/{job_name}/replay-dry-run"
post: "/v1/project/{project_name}/replay/dryrun"
body: "*"
};
}
rpc Replay(ReplayRequest) returns (ReplayResponse) {
option (google.api.http) = {
post: "/v1/project/{project_name}/job/{job_name}/replay"
post: "/v1/project/{project_name}/replay"
body: "*"
};
}
rpc GetReplayStatus(GetReplayStatusRequest) returns (GetReplayStatusResponse) {
option (google.api.http) = {
get: "/v1/project/{project_name}/job/{job_name}/replay/{id}"
get: "/v1/project/{project_name}/replay/{id}"
};
}
rpc ListReplays(ListReplaysRequest) returns (ListReplaysResponse) {
option (google.api.http) = {
get: "/v1/project/{project_name}/replay"
};
}
// TODO(kush.sharma): disabled ATM
Expand Down Expand Up @@ -614,7 +619,19 @@ message ReplayRequest {
bool force = 6;
}

message ReplayDryRunResponse {
message ReplayResponse {
string id = 1;
}

message DryRunReplayRequest {
string project_name = 1;
string job_name = 2;
string namespace = 3;
string start_date = 4;
string end_date = 5;
}

message DryRunReplayResponse {
bool success = 1;
ReplayExecutionTreeNode response = 2;
}
Expand All @@ -625,10 +642,6 @@ message ReplayExecutionTreeNode {
repeated google.protobuf.Timestamp runs = 3;
}

message ReplayResponse {
string id = 1;
}

message GetReplayStatusResponse {
string state = 1;
ReplayStatusTreeNode response = 2;
Expand Down Expand Up @@ -660,4 +673,21 @@ message RegisterJobEventRequest {
JobEvent event = 4;
}

message RegisterJobEventResponse {}
message RegisterJobEventResponse {}

message ListReplaysRequest {
string project_name = 1;
}

message ListReplaysResponse {
repeated ReplaySpec replay_list = 1;
}

message ReplaySpec {
string id = 1;
string job_name = 2;
google.protobuf.Timestamp start_date = 3;
google.protobuf.Timestamp end_date = 4;
string state = 5;
google.protobuf.Timestamp created_at = 6;
}