|
|
|
@ -51,10 +51,10 @@ service JobsV1Beta3 { |
|
|
|
|
// in `us-central1`. |
|
|
|
|
rpc CreateJob(CreateJobRequest) returns (Job) { |
|
|
|
|
option (google.api.http) = { |
|
|
|
|
post: "/v1b3/projects/{project_id}/jobs" |
|
|
|
|
post: "/v1b3/projects/{project_id}/locations/{location}/jobs" |
|
|
|
|
body: "job" |
|
|
|
|
additional_bindings { |
|
|
|
|
post: "/v1b3/projects/{project_id}/locations/{location}/jobs" |
|
|
|
|
post: "/v1b3/projects/{project_id}/jobs" |
|
|
|
|
body: "job" |
|
|
|
|
} |
|
|
|
|
}; |
|
|
|
@ -69,9 +69,9 @@ service JobsV1Beta3 { |
|
|
|
|
// jobs that are running in `us-central1`. |
|
|
|
|
rpc GetJob(GetJobRequest) returns (Job) { |
|
|
|
|
option (google.api.http) = { |
|
|
|
|
get: "/v1b3/projects/{project_id}/jobs/{job_id}" |
|
|
|
|
get: "/v1b3/projects/{project_id}/locations/{location}/jobs/{job_id}" |
|
|
|
|
additional_bindings { |
|
|
|
|
get: "/v1b3/projects/{project_id}/locations/{location}/jobs/{job_id}" |
|
|
|
|
get: "/v1b3/projects/{project_id}/jobs/{job_id}" |
|
|
|
|
} |
|
|
|
|
}; |
|
|
|
|
} |
|
|
|
@ -85,10 +85,10 @@ service JobsV1Beta3 { |
|
|
|
|
// of jobs that are running in `us-central1`. |
|
|
|
|
rpc UpdateJob(UpdateJobRequest) returns (Job) { |
|
|
|
|
option (google.api.http) = { |
|
|
|
|
put: "/v1b3/projects/{project_id}/jobs/{job_id}" |
|
|
|
|
put: "/v1b3/projects/{project_id}/locations/{location}/jobs/{job_id}" |
|
|
|
|
body: "job" |
|
|
|
|
additional_bindings { |
|
|
|
|
put: "/v1b3/projects/{project_id}/locations/{location}/jobs/{job_id}" |
|
|
|
|
put: "/v1b3/projects/{project_id}/jobs/{job_id}" |
|
|
|
|
body: "job" |
|
|
|
|
} |
|
|
|
|
}; |
|
|
|
@ -104,9 +104,9 @@ service JobsV1Beta3 { |
|
|
|
|
// jobs that are running in `us-central1`. |
|
|
|
|
rpc ListJobs(ListJobsRequest) returns (ListJobsResponse) { |
|
|
|
|
option (google.api.http) = { |
|
|
|
|
get: "/v1b3/projects/{project_id}/jobs" |
|
|
|
|
get: "/v1b3/projects/{project_id}/locations/{location}/jobs" |
|
|
|
|
additional_bindings { |
|
|
|
|
get: "/v1b3/projects/{project_id}/locations/{location}/jobs" |
|
|
|
|
get: "/v1b3/projects/{project_id}/jobs" |
|
|
|
|
} |
|
|
|
|
}; |
|
|
|
|
} |
|
|
|
@ -125,10 +125,10 @@ service JobsV1Beta3 { |
|
|
|
|
// Snapshot the state of a streaming job. |
|
|
|
|
rpc SnapshotJob(SnapshotJobRequest) returns (Snapshot) { |
|
|
|
|
option (google.api.http) = { |
|
|
|
|
post: "/v1b3/projects/{project_id}/jobs/{job_id}:snapshot" |
|
|
|
|
post: "/v1b3/projects/{project_id}/locations/{location}/jobs/{job_id}:snapshot" |
|
|
|
|
body: "*" |
|
|
|
|
additional_bindings { |
|
|
|
|
post: "/v1b3/projects/{project_id}/locations/{location}/jobs/{job_id}:snapshot" |
|
|
|
|
post: "/v1b3/projects/{project_id}/jobs/{job_id}:snapshot" |
|
|
|
|
body: "*" |
|
|
|
|
} |
|
|
|
|
}; |
|
|
|
@ -136,7 +136,6 @@ service JobsV1Beta3 { |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
// Defines a job to be run by the Cloud Dataflow service. |
|
|
|
|
// nextID: 26 |
|
|
|
|
message Job { |
|
|
|
|
// The unique ID of this job. |
|
|
|
|
// |
|
|
|
|