• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
1 /*
2  * Copyright 2020 Google LLC
3  *
4  * Licensed under the Apache License, Version 2.0 (the "License");
5  * you may not use this file except in compliance with the License.
6  * You may obtain a copy of the License at
7  *
8  *     https://www.apache.org/licenses/LICENSE-2.0
9  *
10  * Unless required by applicable law or agreed to in writing, software
11  * distributed under the License is distributed on an "AS IS" BASIS,
12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13  * See the License for the specific language governing permissions and
14  * limitations under the License.
15  */
16 package com.google.cloud.dataproc.v1;
17 
18 import static io.grpc.MethodDescriptor.generateFullMethodName;
19 
20 /**
21  *
22  *
23  * <pre>
24  * The JobController provides methods to manage jobs.
25  * </pre>
26  */
27 @javax.annotation.Generated(
28     value = "by gRPC proto compiler",
29     comments = "Source: google/cloud/dataproc/v1/jobs.proto")
30 @io.grpc.stub.annotations.GrpcGenerated
31 public final class JobControllerGrpc {
32 
JobControllerGrpc()33   private JobControllerGrpc() {}
34 
35   public static final String SERVICE_NAME = "google.cloud.dataproc.v1.JobController";
36 
37   // Static method descriptors that strictly reflect the proto.
38   private static volatile io.grpc.MethodDescriptor<
39           com.google.cloud.dataproc.v1.SubmitJobRequest, com.google.cloud.dataproc.v1.Job>
40       getSubmitJobMethod;
41 
42   @io.grpc.stub.annotations.RpcMethod(
43       fullMethodName = SERVICE_NAME + '/' + "SubmitJob",
44       requestType = com.google.cloud.dataproc.v1.SubmitJobRequest.class,
45       responseType = com.google.cloud.dataproc.v1.Job.class,
46       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
47   public static io.grpc.MethodDescriptor<
48           com.google.cloud.dataproc.v1.SubmitJobRequest, com.google.cloud.dataproc.v1.Job>
getSubmitJobMethod()49       getSubmitJobMethod() {
50     io.grpc.MethodDescriptor<
51             com.google.cloud.dataproc.v1.SubmitJobRequest, com.google.cloud.dataproc.v1.Job>
52         getSubmitJobMethod;
53     if ((getSubmitJobMethod = JobControllerGrpc.getSubmitJobMethod) == null) {
54       synchronized (JobControllerGrpc.class) {
55         if ((getSubmitJobMethod = JobControllerGrpc.getSubmitJobMethod) == null) {
56           JobControllerGrpc.getSubmitJobMethod =
57               getSubmitJobMethod =
58                   io.grpc.MethodDescriptor
59                       .<com.google.cloud.dataproc.v1.SubmitJobRequest,
60                           com.google.cloud.dataproc.v1.Job>
61                           newBuilder()
62                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
63                       .setFullMethodName(generateFullMethodName(SERVICE_NAME, "SubmitJob"))
64                       .setSampledToLocalTracing(true)
65                       .setRequestMarshaller(
66                           io.grpc.protobuf.ProtoUtils.marshaller(
67                               com.google.cloud.dataproc.v1.SubmitJobRequest.getDefaultInstance()))
68                       .setResponseMarshaller(
69                           io.grpc.protobuf.ProtoUtils.marshaller(
70                               com.google.cloud.dataproc.v1.Job.getDefaultInstance()))
71                       .setSchemaDescriptor(new JobControllerMethodDescriptorSupplier("SubmitJob"))
72                       .build();
73         }
74       }
75     }
76     return getSubmitJobMethod;
77   }
78 
79   private static volatile io.grpc.MethodDescriptor<
80           com.google.cloud.dataproc.v1.SubmitJobRequest, com.google.longrunning.Operation>
81       getSubmitJobAsOperationMethod;
82 
83   @io.grpc.stub.annotations.RpcMethod(
84       fullMethodName = SERVICE_NAME + '/' + "SubmitJobAsOperation",
85       requestType = com.google.cloud.dataproc.v1.SubmitJobRequest.class,
86       responseType = com.google.longrunning.Operation.class,
87       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
88   public static io.grpc.MethodDescriptor<
89           com.google.cloud.dataproc.v1.SubmitJobRequest, com.google.longrunning.Operation>
getSubmitJobAsOperationMethod()90       getSubmitJobAsOperationMethod() {
91     io.grpc.MethodDescriptor<
92             com.google.cloud.dataproc.v1.SubmitJobRequest, com.google.longrunning.Operation>
93         getSubmitJobAsOperationMethod;
94     if ((getSubmitJobAsOperationMethod = JobControllerGrpc.getSubmitJobAsOperationMethod) == null) {
95       synchronized (JobControllerGrpc.class) {
96         if ((getSubmitJobAsOperationMethod = JobControllerGrpc.getSubmitJobAsOperationMethod)
97             == null) {
98           JobControllerGrpc.getSubmitJobAsOperationMethod =
99               getSubmitJobAsOperationMethod =
100                   io.grpc.MethodDescriptor
101                       .<com.google.cloud.dataproc.v1.SubmitJobRequest,
102                           com.google.longrunning.Operation>
103                           newBuilder()
104                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
105                       .setFullMethodName(
106                           generateFullMethodName(SERVICE_NAME, "SubmitJobAsOperation"))
107                       .setSampledToLocalTracing(true)
108                       .setRequestMarshaller(
109                           io.grpc.protobuf.ProtoUtils.marshaller(
110                               com.google.cloud.dataproc.v1.SubmitJobRequest.getDefaultInstance()))
111                       .setResponseMarshaller(
112                           io.grpc.protobuf.ProtoUtils.marshaller(
113                               com.google.longrunning.Operation.getDefaultInstance()))
114                       .setSchemaDescriptor(
115                           new JobControllerMethodDescriptorSupplier("SubmitJobAsOperation"))
116                       .build();
117         }
118       }
119     }
120     return getSubmitJobAsOperationMethod;
121   }
122 
123   private static volatile io.grpc.MethodDescriptor<
124           com.google.cloud.dataproc.v1.GetJobRequest, com.google.cloud.dataproc.v1.Job>
125       getGetJobMethod;
126 
127   @io.grpc.stub.annotations.RpcMethod(
128       fullMethodName = SERVICE_NAME + '/' + "GetJob",
129       requestType = com.google.cloud.dataproc.v1.GetJobRequest.class,
130       responseType = com.google.cloud.dataproc.v1.Job.class,
131       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
132   public static io.grpc.MethodDescriptor<
133           com.google.cloud.dataproc.v1.GetJobRequest, com.google.cloud.dataproc.v1.Job>
getGetJobMethod()134       getGetJobMethod() {
135     io.grpc.MethodDescriptor<
136             com.google.cloud.dataproc.v1.GetJobRequest, com.google.cloud.dataproc.v1.Job>
137         getGetJobMethod;
138     if ((getGetJobMethod = JobControllerGrpc.getGetJobMethod) == null) {
139       synchronized (JobControllerGrpc.class) {
140         if ((getGetJobMethod = JobControllerGrpc.getGetJobMethod) == null) {
141           JobControllerGrpc.getGetJobMethod =
142               getGetJobMethod =
143                   io.grpc.MethodDescriptor
144                       .<com.google.cloud.dataproc.v1.GetJobRequest,
145                           com.google.cloud.dataproc.v1.Job>
146                           newBuilder()
147                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
148                       .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetJob"))
149                       .setSampledToLocalTracing(true)
150                       .setRequestMarshaller(
151                           io.grpc.protobuf.ProtoUtils.marshaller(
152                               com.google.cloud.dataproc.v1.GetJobRequest.getDefaultInstance()))
153                       .setResponseMarshaller(
154                           io.grpc.protobuf.ProtoUtils.marshaller(
155                               com.google.cloud.dataproc.v1.Job.getDefaultInstance()))
156                       .setSchemaDescriptor(new JobControllerMethodDescriptorSupplier("GetJob"))
157                       .build();
158         }
159       }
160     }
161     return getGetJobMethod;
162   }
163 
164   private static volatile io.grpc.MethodDescriptor<
165           com.google.cloud.dataproc.v1.ListJobsRequest,
166           com.google.cloud.dataproc.v1.ListJobsResponse>
167       getListJobsMethod;
168 
169   @io.grpc.stub.annotations.RpcMethod(
170       fullMethodName = SERVICE_NAME + '/' + "ListJobs",
171       requestType = com.google.cloud.dataproc.v1.ListJobsRequest.class,
172       responseType = com.google.cloud.dataproc.v1.ListJobsResponse.class,
173       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
174   public static io.grpc.MethodDescriptor<
175           com.google.cloud.dataproc.v1.ListJobsRequest,
176           com.google.cloud.dataproc.v1.ListJobsResponse>
getListJobsMethod()177       getListJobsMethod() {
178     io.grpc.MethodDescriptor<
179             com.google.cloud.dataproc.v1.ListJobsRequest,
180             com.google.cloud.dataproc.v1.ListJobsResponse>
181         getListJobsMethod;
182     if ((getListJobsMethod = JobControllerGrpc.getListJobsMethod) == null) {
183       synchronized (JobControllerGrpc.class) {
184         if ((getListJobsMethod = JobControllerGrpc.getListJobsMethod) == null) {
185           JobControllerGrpc.getListJobsMethod =
186               getListJobsMethod =
187                   io.grpc.MethodDescriptor
188                       .<com.google.cloud.dataproc.v1.ListJobsRequest,
189                           com.google.cloud.dataproc.v1.ListJobsResponse>
190                           newBuilder()
191                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
192                       .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListJobs"))
193                       .setSampledToLocalTracing(true)
194                       .setRequestMarshaller(
195                           io.grpc.protobuf.ProtoUtils.marshaller(
196                               com.google.cloud.dataproc.v1.ListJobsRequest.getDefaultInstance()))
197                       .setResponseMarshaller(
198                           io.grpc.protobuf.ProtoUtils.marshaller(
199                               com.google.cloud.dataproc.v1.ListJobsResponse.getDefaultInstance()))
200                       .setSchemaDescriptor(new JobControllerMethodDescriptorSupplier("ListJobs"))
201                       .build();
202         }
203       }
204     }
205     return getListJobsMethod;
206   }
207 
208   private static volatile io.grpc.MethodDescriptor<
209           com.google.cloud.dataproc.v1.UpdateJobRequest, com.google.cloud.dataproc.v1.Job>
210       getUpdateJobMethod;
211 
212   @io.grpc.stub.annotations.RpcMethod(
213       fullMethodName = SERVICE_NAME + '/' + "UpdateJob",
214       requestType = com.google.cloud.dataproc.v1.UpdateJobRequest.class,
215       responseType = com.google.cloud.dataproc.v1.Job.class,
216       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
217   public static io.grpc.MethodDescriptor<
218           com.google.cloud.dataproc.v1.UpdateJobRequest, com.google.cloud.dataproc.v1.Job>
getUpdateJobMethod()219       getUpdateJobMethod() {
220     io.grpc.MethodDescriptor<
221             com.google.cloud.dataproc.v1.UpdateJobRequest, com.google.cloud.dataproc.v1.Job>
222         getUpdateJobMethod;
223     if ((getUpdateJobMethod = JobControllerGrpc.getUpdateJobMethod) == null) {
224       synchronized (JobControllerGrpc.class) {
225         if ((getUpdateJobMethod = JobControllerGrpc.getUpdateJobMethod) == null) {
226           JobControllerGrpc.getUpdateJobMethod =
227               getUpdateJobMethod =
228                   io.grpc.MethodDescriptor
229                       .<com.google.cloud.dataproc.v1.UpdateJobRequest,
230                           com.google.cloud.dataproc.v1.Job>
231                           newBuilder()
232                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
233                       .setFullMethodName(generateFullMethodName(SERVICE_NAME, "UpdateJob"))
234                       .setSampledToLocalTracing(true)
235                       .setRequestMarshaller(
236                           io.grpc.protobuf.ProtoUtils.marshaller(
237                               com.google.cloud.dataproc.v1.UpdateJobRequest.getDefaultInstance()))
238                       .setResponseMarshaller(
239                           io.grpc.protobuf.ProtoUtils.marshaller(
240                               com.google.cloud.dataproc.v1.Job.getDefaultInstance()))
241                       .setSchemaDescriptor(new JobControllerMethodDescriptorSupplier("UpdateJob"))
242                       .build();
243         }
244       }
245     }
246     return getUpdateJobMethod;
247   }
248 
249   private static volatile io.grpc.MethodDescriptor<
250           com.google.cloud.dataproc.v1.CancelJobRequest, com.google.cloud.dataproc.v1.Job>
251       getCancelJobMethod;
252 
253   @io.grpc.stub.annotations.RpcMethod(
254       fullMethodName = SERVICE_NAME + '/' + "CancelJob",
255       requestType = com.google.cloud.dataproc.v1.CancelJobRequest.class,
256       responseType = com.google.cloud.dataproc.v1.Job.class,
257       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
258   public static io.grpc.MethodDescriptor<
259           com.google.cloud.dataproc.v1.CancelJobRequest, com.google.cloud.dataproc.v1.Job>
getCancelJobMethod()260       getCancelJobMethod() {
261     io.grpc.MethodDescriptor<
262             com.google.cloud.dataproc.v1.CancelJobRequest, com.google.cloud.dataproc.v1.Job>
263         getCancelJobMethod;
264     if ((getCancelJobMethod = JobControllerGrpc.getCancelJobMethod) == null) {
265       synchronized (JobControllerGrpc.class) {
266         if ((getCancelJobMethod = JobControllerGrpc.getCancelJobMethod) == null) {
267           JobControllerGrpc.getCancelJobMethod =
268               getCancelJobMethod =
269                   io.grpc.MethodDescriptor
270                       .<com.google.cloud.dataproc.v1.CancelJobRequest,
271                           com.google.cloud.dataproc.v1.Job>
272                           newBuilder()
273                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
274                       .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CancelJob"))
275                       .setSampledToLocalTracing(true)
276                       .setRequestMarshaller(
277                           io.grpc.protobuf.ProtoUtils.marshaller(
278                               com.google.cloud.dataproc.v1.CancelJobRequest.getDefaultInstance()))
279                       .setResponseMarshaller(
280                           io.grpc.protobuf.ProtoUtils.marshaller(
281                               com.google.cloud.dataproc.v1.Job.getDefaultInstance()))
282                       .setSchemaDescriptor(new JobControllerMethodDescriptorSupplier("CancelJob"))
283                       .build();
284         }
285       }
286     }
287     return getCancelJobMethod;
288   }
289 
290   private static volatile io.grpc.MethodDescriptor<
291           com.google.cloud.dataproc.v1.DeleteJobRequest, com.google.protobuf.Empty>
292       getDeleteJobMethod;
293 
294   @io.grpc.stub.annotations.RpcMethod(
295       fullMethodName = SERVICE_NAME + '/' + "DeleteJob",
296       requestType = com.google.cloud.dataproc.v1.DeleteJobRequest.class,
297       responseType = com.google.protobuf.Empty.class,
298       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
299   public static io.grpc.MethodDescriptor<
300           com.google.cloud.dataproc.v1.DeleteJobRequest, com.google.protobuf.Empty>
getDeleteJobMethod()301       getDeleteJobMethod() {
302     io.grpc.MethodDescriptor<
303             com.google.cloud.dataproc.v1.DeleteJobRequest, com.google.protobuf.Empty>
304         getDeleteJobMethod;
305     if ((getDeleteJobMethod = JobControllerGrpc.getDeleteJobMethod) == null) {
306       synchronized (JobControllerGrpc.class) {
307         if ((getDeleteJobMethod = JobControllerGrpc.getDeleteJobMethod) == null) {
308           JobControllerGrpc.getDeleteJobMethod =
309               getDeleteJobMethod =
310                   io.grpc.MethodDescriptor
311                       .<com.google.cloud.dataproc.v1.DeleteJobRequest, com.google.protobuf.Empty>
312                           newBuilder()
313                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
314                       .setFullMethodName(generateFullMethodName(SERVICE_NAME, "DeleteJob"))
315                       .setSampledToLocalTracing(true)
316                       .setRequestMarshaller(
317                           io.grpc.protobuf.ProtoUtils.marshaller(
318                               com.google.cloud.dataproc.v1.DeleteJobRequest.getDefaultInstance()))
319                       .setResponseMarshaller(
320                           io.grpc.protobuf.ProtoUtils.marshaller(
321                               com.google.protobuf.Empty.getDefaultInstance()))
322                       .setSchemaDescriptor(new JobControllerMethodDescriptorSupplier("DeleteJob"))
323                       .build();
324         }
325       }
326     }
327     return getDeleteJobMethod;
328   }
329 
330   /** Creates a new async stub that supports all call types for the service */
newStub(io.grpc.Channel channel)331   public static JobControllerStub newStub(io.grpc.Channel channel) {
332     io.grpc.stub.AbstractStub.StubFactory<JobControllerStub> factory =
333         new io.grpc.stub.AbstractStub.StubFactory<JobControllerStub>() {
334           @java.lang.Override
335           public JobControllerStub newStub(
336               io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
337             return new JobControllerStub(channel, callOptions);
338           }
339         };
340     return JobControllerStub.newStub(factory, channel);
341   }
342 
343   /**
344    * Creates a new blocking-style stub that supports unary and streaming output calls on the service
345    */
newBlockingStub(io.grpc.Channel channel)346   public static JobControllerBlockingStub newBlockingStub(io.grpc.Channel channel) {
347     io.grpc.stub.AbstractStub.StubFactory<JobControllerBlockingStub> factory =
348         new io.grpc.stub.AbstractStub.StubFactory<JobControllerBlockingStub>() {
349           @java.lang.Override
350           public JobControllerBlockingStub newStub(
351               io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
352             return new JobControllerBlockingStub(channel, callOptions);
353           }
354         };
355     return JobControllerBlockingStub.newStub(factory, channel);
356   }
357 
358   /** Creates a new ListenableFuture-style stub that supports unary calls on the service */
newFutureStub(io.grpc.Channel channel)359   public static JobControllerFutureStub newFutureStub(io.grpc.Channel channel) {
360     io.grpc.stub.AbstractStub.StubFactory<JobControllerFutureStub> factory =
361         new io.grpc.stub.AbstractStub.StubFactory<JobControllerFutureStub>() {
362           @java.lang.Override
363           public JobControllerFutureStub newStub(
364               io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
365             return new JobControllerFutureStub(channel, callOptions);
366           }
367         };
368     return JobControllerFutureStub.newStub(factory, channel);
369   }
370 
371   /**
372    *
373    *
374    * <pre>
375    * The JobController provides methods to manage jobs.
376    * </pre>
377    */
378   public interface AsyncService {
379 
380     /**
381      *
382      *
383      * <pre>
384      * Submits a job to a cluster.
385      * </pre>
386      */
submitJob( com.google.cloud.dataproc.v1.SubmitJobRequest request, io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job> responseObserver)387     default void submitJob(
388         com.google.cloud.dataproc.v1.SubmitJobRequest request,
389         io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job> responseObserver) {
390       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getSubmitJobMethod(), responseObserver);
391     }
392 
393     /**
394      *
395      *
396      * <pre>
397      * Submits job to a cluster.
398      * </pre>
399      */
submitJobAsOperation( com.google.cloud.dataproc.v1.SubmitJobRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)400     default void submitJobAsOperation(
401         com.google.cloud.dataproc.v1.SubmitJobRequest request,
402         io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
403       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
404           getSubmitJobAsOperationMethod(), responseObserver);
405     }
406 
407     /**
408      *
409      *
410      * <pre>
411      * Gets the resource representation for a job in a project.
412      * </pre>
413      */
getJob( com.google.cloud.dataproc.v1.GetJobRequest request, io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job> responseObserver)414     default void getJob(
415         com.google.cloud.dataproc.v1.GetJobRequest request,
416         io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job> responseObserver) {
417       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetJobMethod(), responseObserver);
418     }
419 
420     /**
421      *
422      *
423      * <pre>
424      * Lists regions/{region}/jobs in a project.
425      * </pre>
426      */
listJobs( com.google.cloud.dataproc.v1.ListJobsRequest request, io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.ListJobsResponse> responseObserver)427     default void listJobs(
428         com.google.cloud.dataproc.v1.ListJobsRequest request,
429         io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.ListJobsResponse>
430             responseObserver) {
431       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getListJobsMethod(), responseObserver);
432     }
433 
434     /**
435      *
436      *
437      * <pre>
438      * Updates a job in a project.
439      * </pre>
440      */
updateJob( com.google.cloud.dataproc.v1.UpdateJobRequest request, io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job> responseObserver)441     default void updateJob(
442         com.google.cloud.dataproc.v1.UpdateJobRequest request,
443         io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job> responseObserver) {
444       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getUpdateJobMethod(), responseObserver);
445     }
446 
447     /**
448      *
449      *
450      * <pre>
451      * Starts a job cancellation request. To access the job resource
452      * after cancellation, call
453      * [regions/{region}/jobs.list](https://cloud.google.com/dataproc/docs/reference/rest/v1/projects.regions.jobs/list)
454      * or
455      * [regions/{region}/jobs.get](https://cloud.google.com/dataproc/docs/reference/rest/v1/projects.regions.jobs/get).
456      * </pre>
457      */
cancelJob( com.google.cloud.dataproc.v1.CancelJobRequest request, io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job> responseObserver)458     default void cancelJob(
459         com.google.cloud.dataproc.v1.CancelJobRequest request,
460         io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job> responseObserver) {
461       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getCancelJobMethod(), responseObserver);
462     }
463 
464     /**
465      *
466      *
467      * <pre>
468      * Deletes the job from the project. If the job is active, the delete fails,
469      * and the response returns `FAILED_PRECONDITION`.
470      * </pre>
471      */
deleteJob( com.google.cloud.dataproc.v1.DeleteJobRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)472     default void deleteJob(
473         com.google.cloud.dataproc.v1.DeleteJobRequest request,
474         io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) {
475       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getDeleteJobMethod(), responseObserver);
476     }
477   }
478 
479   /**
480    * Base class for the server implementation of the service JobController.
481    *
482    * <pre>
483    * The JobController provides methods to manage jobs.
484    * </pre>
485    */
486   public abstract static class JobControllerImplBase
487       implements io.grpc.BindableService, AsyncService {
488 
489     @java.lang.Override
bindService()490     public final io.grpc.ServerServiceDefinition bindService() {
491       return JobControllerGrpc.bindService(this);
492     }
493   }
494 
495   /**
496    * A stub to allow clients to do asynchronous rpc calls to service JobController.
497    *
498    * <pre>
499    * The JobController provides methods to manage jobs.
500    * </pre>
501    */
502   public static final class JobControllerStub
503       extends io.grpc.stub.AbstractAsyncStub<JobControllerStub> {
JobControllerStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions)504     private JobControllerStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
505       super(channel, callOptions);
506     }
507 
508     @java.lang.Override
build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)509     protected JobControllerStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
510       return new JobControllerStub(channel, callOptions);
511     }
512 
513     /**
514      *
515      *
516      * <pre>
517      * Submits a job to a cluster.
518      * </pre>
519      */
submitJob( com.google.cloud.dataproc.v1.SubmitJobRequest request, io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job> responseObserver)520     public void submitJob(
521         com.google.cloud.dataproc.v1.SubmitJobRequest request,
522         io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job> responseObserver) {
523       io.grpc.stub.ClientCalls.asyncUnaryCall(
524           getChannel().newCall(getSubmitJobMethod(), getCallOptions()), request, responseObserver);
525     }
526 
527     /**
528      *
529      *
530      * <pre>
531      * Submits job to a cluster.
532      * </pre>
533      */
submitJobAsOperation( com.google.cloud.dataproc.v1.SubmitJobRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)534     public void submitJobAsOperation(
535         com.google.cloud.dataproc.v1.SubmitJobRequest request,
536         io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
537       io.grpc.stub.ClientCalls.asyncUnaryCall(
538           getChannel().newCall(getSubmitJobAsOperationMethod(), getCallOptions()),
539           request,
540           responseObserver);
541     }
542 
543     /**
544      *
545      *
546      * <pre>
547      * Gets the resource representation for a job in a project.
548      * </pre>
549      */
getJob( com.google.cloud.dataproc.v1.GetJobRequest request, io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job> responseObserver)550     public void getJob(
551         com.google.cloud.dataproc.v1.GetJobRequest request,
552         io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job> responseObserver) {
553       io.grpc.stub.ClientCalls.asyncUnaryCall(
554           getChannel().newCall(getGetJobMethod(), getCallOptions()), request, responseObserver);
555     }
556 
557     /**
558      *
559      *
560      * <pre>
561      * Lists regions/{region}/jobs in a project.
562      * </pre>
563      */
listJobs( com.google.cloud.dataproc.v1.ListJobsRequest request, io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.ListJobsResponse> responseObserver)564     public void listJobs(
565         com.google.cloud.dataproc.v1.ListJobsRequest request,
566         io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.ListJobsResponse>
567             responseObserver) {
568       io.grpc.stub.ClientCalls.asyncUnaryCall(
569           getChannel().newCall(getListJobsMethod(), getCallOptions()), request, responseObserver);
570     }
571 
572     /**
573      *
574      *
575      * <pre>
576      * Updates a job in a project.
577      * </pre>
578      */
updateJob( com.google.cloud.dataproc.v1.UpdateJobRequest request, io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job> responseObserver)579     public void updateJob(
580         com.google.cloud.dataproc.v1.UpdateJobRequest request,
581         io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job> responseObserver) {
582       io.grpc.stub.ClientCalls.asyncUnaryCall(
583           getChannel().newCall(getUpdateJobMethod(), getCallOptions()), request, responseObserver);
584     }
585 
586     /**
587      *
588      *
589      * <pre>
590      * Starts a job cancellation request. To access the job resource
591      * after cancellation, call
592      * [regions/{region}/jobs.list](https://cloud.google.com/dataproc/docs/reference/rest/v1/projects.regions.jobs/list)
593      * or
594      * [regions/{region}/jobs.get](https://cloud.google.com/dataproc/docs/reference/rest/v1/projects.regions.jobs/get).
595      * </pre>
596      */
cancelJob( com.google.cloud.dataproc.v1.CancelJobRequest request, io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job> responseObserver)597     public void cancelJob(
598         com.google.cloud.dataproc.v1.CancelJobRequest request,
599         io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job> responseObserver) {
600       io.grpc.stub.ClientCalls.asyncUnaryCall(
601           getChannel().newCall(getCancelJobMethod(), getCallOptions()), request, responseObserver);
602     }
603 
604     /**
605      *
606      *
607      * <pre>
608      * Deletes the job from the project. If the job is active, the delete fails,
609      * and the response returns `FAILED_PRECONDITION`.
610      * </pre>
611      */
deleteJob( com.google.cloud.dataproc.v1.DeleteJobRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)612     public void deleteJob(
613         com.google.cloud.dataproc.v1.DeleteJobRequest request,
614         io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) {
615       io.grpc.stub.ClientCalls.asyncUnaryCall(
616           getChannel().newCall(getDeleteJobMethod(), getCallOptions()), request, responseObserver);
617     }
618   }
619 
620   /**
621    * A stub to allow clients to do synchronous rpc calls to service JobController.
622    *
623    * <pre>
624    * The JobController provides methods to manage jobs.
625    * </pre>
626    */
627   public static final class JobControllerBlockingStub
628       extends io.grpc.stub.AbstractBlockingStub<JobControllerBlockingStub> {
JobControllerBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions)629     private JobControllerBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
630       super(channel, callOptions);
631     }
632 
633     @java.lang.Override
build( io.grpc.Channel channel, io.grpc.CallOptions callOptions)634     protected JobControllerBlockingStub build(
635         io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
636       return new JobControllerBlockingStub(channel, callOptions);
637     }
638 
639     /**
640      *
641      *
642      * <pre>
643      * Submits a job to a cluster.
644      * </pre>
645      */
submitJob( com.google.cloud.dataproc.v1.SubmitJobRequest request)646     public com.google.cloud.dataproc.v1.Job submitJob(
647         com.google.cloud.dataproc.v1.SubmitJobRequest request) {
648       return io.grpc.stub.ClientCalls.blockingUnaryCall(
649           getChannel(), getSubmitJobMethod(), getCallOptions(), request);
650     }
651 
652     /**
653      *
654      *
655      * <pre>
656      * Submits job to a cluster.
657      * </pre>
658      */
submitJobAsOperation( com.google.cloud.dataproc.v1.SubmitJobRequest request)659     public com.google.longrunning.Operation submitJobAsOperation(
660         com.google.cloud.dataproc.v1.SubmitJobRequest request) {
661       return io.grpc.stub.ClientCalls.blockingUnaryCall(
662           getChannel(), getSubmitJobAsOperationMethod(), getCallOptions(), request);
663     }
664 
665     /**
666      *
667      *
668      * <pre>
669      * Gets the resource representation for a job in a project.
670      * </pre>
671      */
getJob( com.google.cloud.dataproc.v1.GetJobRequest request)672     public com.google.cloud.dataproc.v1.Job getJob(
673         com.google.cloud.dataproc.v1.GetJobRequest request) {
674       return io.grpc.stub.ClientCalls.blockingUnaryCall(
675           getChannel(), getGetJobMethod(), getCallOptions(), request);
676     }
677 
678     /**
679      *
680      *
681      * <pre>
682      * Lists regions/{region}/jobs in a project.
683      * </pre>
684      */
listJobs( com.google.cloud.dataproc.v1.ListJobsRequest request)685     public com.google.cloud.dataproc.v1.ListJobsResponse listJobs(
686         com.google.cloud.dataproc.v1.ListJobsRequest request) {
687       return io.grpc.stub.ClientCalls.blockingUnaryCall(
688           getChannel(), getListJobsMethod(), getCallOptions(), request);
689     }
690 
691     /**
692      *
693      *
694      * <pre>
695      * Updates a job in a project.
696      * </pre>
697      */
updateJob( com.google.cloud.dataproc.v1.UpdateJobRequest request)698     public com.google.cloud.dataproc.v1.Job updateJob(
699         com.google.cloud.dataproc.v1.UpdateJobRequest request) {
700       return io.grpc.stub.ClientCalls.blockingUnaryCall(
701           getChannel(), getUpdateJobMethod(), getCallOptions(), request);
702     }
703 
704     /**
705      *
706      *
707      * <pre>
708      * Starts a job cancellation request. To access the job resource
709      * after cancellation, call
710      * [regions/{region}/jobs.list](https://cloud.google.com/dataproc/docs/reference/rest/v1/projects.regions.jobs/list)
711      * or
712      * [regions/{region}/jobs.get](https://cloud.google.com/dataproc/docs/reference/rest/v1/projects.regions.jobs/get).
713      * </pre>
714      */
cancelJob( com.google.cloud.dataproc.v1.CancelJobRequest request)715     public com.google.cloud.dataproc.v1.Job cancelJob(
716         com.google.cloud.dataproc.v1.CancelJobRequest request) {
717       return io.grpc.stub.ClientCalls.blockingUnaryCall(
718           getChannel(), getCancelJobMethod(), getCallOptions(), request);
719     }
720 
721     /**
722      *
723      *
724      * <pre>
725      * Deletes the job from the project. If the job is active, the delete fails,
726      * and the response returns `FAILED_PRECONDITION`.
727      * </pre>
728      */
deleteJob( com.google.cloud.dataproc.v1.DeleteJobRequest request)729     public com.google.protobuf.Empty deleteJob(
730         com.google.cloud.dataproc.v1.DeleteJobRequest request) {
731       return io.grpc.stub.ClientCalls.blockingUnaryCall(
732           getChannel(), getDeleteJobMethod(), getCallOptions(), request);
733     }
734   }
735 
736   /**
737    * A stub to allow clients to do ListenableFuture-style rpc calls to service JobController.
738    *
739    * <pre>
740    * The JobController provides methods to manage jobs.
741    * </pre>
742    */
743   public static final class JobControllerFutureStub
744       extends io.grpc.stub.AbstractFutureStub<JobControllerFutureStub> {
JobControllerFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions)745     private JobControllerFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
746       super(channel, callOptions);
747     }
748 
749     @java.lang.Override
build( io.grpc.Channel channel, io.grpc.CallOptions callOptions)750     protected JobControllerFutureStub build(
751         io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
752       return new JobControllerFutureStub(channel, callOptions);
753     }
754 
755     /**
756      *
757      *
758      * <pre>
759      * Submits a job to a cluster.
760      * </pre>
761      */
762     public com.google.common.util.concurrent.ListenableFuture<com.google.cloud.dataproc.v1.Job>
submitJob(com.google.cloud.dataproc.v1.SubmitJobRequest request)763         submitJob(com.google.cloud.dataproc.v1.SubmitJobRequest request) {
764       return io.grpc.stub.ClientCalls.futureUnaryCall(
765           getChannel().newCall(getSubmitJobMethod(), getCallOptions()), request);
766     }
767 
768     /**
769      *
770      *
771      * <pre>
772      * Submits job to a cluster.
773      * </pre>
774      */
775     public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation>
submitJobAsOperation(com.google.cloud.dataproc.v1.SubmitJobRequest request)776         submitJobAsOperation(com.google.cloud.dataproc.v1.SubmitJobRequest request) {
777       return io.grpc.stub.ClientCalls.futureUnaryCall(
778           getChannel().newCall(getSubmitJobAsOperationMethod(), getCallOptions()), request);
779     }
780 
781     /**
782      *
783      *
784      * <pre>
785      * Gets the resource representation for a job in a project.
786      * </pre>
787      */
788     public com.google.common.util.concurrent.ListenableFuture<com.google.cloud.dataproc.v1.Job>
getJob(com.google.cloud.dataproc.v1.GetJobRequest request)789         getJob(com.google.cloud.dataproc.v1.GetJobRequest request) {
790       return io.grpc.stub.ClientCalls.futureUnaryCall(
791           getChannel().newCall(getGetJobMethod(), getCallOptions()), request);
792     }
793 
794     /**
795      *
796      *
797      * <pre>
798      * Lists regions/{region}/jobs in a project.
799      * </pre>
800      */
801     public com.google.common.util.concurrent.ListenableFuture<
802             com.google.cloud.dataproc.v1.ListJobsResponse>
listJobs(com.google.cloud.dataproc.v1.ListJobsRequest request)803         listJobs(com.google.cloud.dataproc.v1.ListJobsRequest request) {
804       return io.grpc.stub.ClientCalls.futureUnaryCall(
805           getChannel().newCall(getListJobsMethod(), getCallOptions()), request);
806     }
807 
808     /**
809      *
810      *
811      * <pre>
812      * Updates a job in a project.
813      * </pre>
814      */
815     public com.google.common.util.concurrent.ListenableFuture<com.google.cloud.dataproc.v1.Job>
updateJob(com.google.cloud.dataproc.v1.UpdateJobRequest request)816         updateJob(com.google.cloud.dataproc.v1.UpdateJobRequest request) {
817       return io.grpc.stub.ClientCalls.futureUnaryCall(
818           getChannel().newCall(getUpdateJobMethod(), getCallOptions()), request);
819     }
820 
821     /**
822      *
823      *
824      * <pre>
825      * Starts a job cancellation request. To access the job resource
826      * after cancellation, call
827      * [regions/{region}/jobs.list](https://cloud.google.com/dataproc/docs/reference/rest/v1/projects.regions.jobs/list)
828      * or
829      * [regions/{region}/jobs.get](https://cloud.google.com/dataproc/docs/reference/rest/v1/projects.regions.jobs/get).
830      * </pre>
831      */
832     public com.google.common.util.concurrent.ListenableFuture<com.google.cloud.dataproc.v1.Job>
cancelJob(com.google.cloud.dataproc.v1.CancelJobRequest request)833         cancelJob(com.google.cloud.dataproc.v1.CancelJobRequest request) {
834       return io.grpc.stub.ClientCalls.futureUnaryCall(
835           getChannel().newCall(getCancelJobMethod(), getCallOptions()), request);
836     }
837 
838     /**
839      *
840      *
841      * <pre>
842      * Deletes the job from the project. If the job is active, the delete fails,
843      * and the response returns `FAILED_PRECONDITION`.
844      * </pre>
845      */
deleteJob( com.google.cloud.dataproc.v1.DeleteJobRequest request)846     public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> deleteJob(
847         com.google.cloud.dataproc.v1.DeleteJobRequest request) {
848       return io.grpc.stub.ClientCalls.futureUnaryCall(
849           getChannel().newCall(getDeleteJobMethod(), getCallOptions()), request);
850     }
851   }
852 
853   private static final int METHODID_SUBMIT_JOB = 0;
854   private static final int METHODID_SUBMIT_JOB_AS_OPERATION = 1;
855   private static final int METHODID_GET_JOB = 2;
856   private static final int METHODID_LIST_JOBS = 3;
857   private static final int METHODID_UPDATE_JOB = 4;
858   private static final int METHODID_CANCEL_JOB = 5;
859   private static final int METHODID_DELETE_JOB = 6;
860 
861   private static final class MethodHandlers<Req, Resp>
862       implements io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
863           io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
864           io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
865           io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
866     private final AsyncService serviceImpl;
867     private final int methodId;
868 
MethodHandlers(AsyncService serviceImpl, int methodId)869     MethodHandlers(AsyncService serviceImpl, int methodId) {
870       this.serviceImpl = serviceImpl;
871       this.methodId = methodId;
872     }
873 
874     @java.lang.Override
875     @java.lang.SuppressWarnings("unchecked")
invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver)876     public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) {
877       switch (methodId) {
878         case METHODID_SUBMIT_JOB:
879           serviceImpl.submitJob(
880               (com.google.cloud.dataproc.v1.SubmitJobRequest) request,
881               (io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job>) responseObserver);
882           break;
883         case METHODID_SUBMIT_JOB_AS_OPERATION:
884           serviceImpl.submitJobAsOperation(
885               (com.google.cloud.dataproc.v1.SubmitJobRequest) request,
886               (io.grpc.stub.StreamObserver<com.google.longrunning.Operation>) responseObserver);
887           break;
888         case METHODID_GET_JOB:
889           serviceImpl.getJob(
890               (com.google.cloud.dataproc.v1.GetJobRequest) request,
891               (io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job>) responseObserver);
892           break;
893         case METHODID_LIST_JOBS:
894           serviceImpl.listJobs(
895               (com.google.cloud.dataproc.v1.ListJobsRequest) request,
896               (io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.ListJobsResponse>)
897                   responseObserver);
898           break;
899         case METHODID_UPDATE_JOB:
900           serviceImpl.updateJob(
901               (com.google.cloud.dataproc.v1.UpdateJobRequest) request,
902               (io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job>) responseObserver);
903           break;
904         case METHODID_CANCEL_JOB:
905           serviceImpl.cancelJob(
906               (com.google.cloud.dataproc.v1.CancelJobRequest) request,
907               (io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job>) responseObserver);
908           break;
909         case METHODID_DELETE_JOB:
910           serviceImpl.deleteJob(
911               (com.google.cloud.dataproc.v1.DeleteJobRequest) request,
912               (io.grpc.stub.StreamObserver<com.google.protobuf.Empty>) responseObserver);
913           break;
914         default:
915           throw new AssertionError();
916       }
917     }
918 
919     @java.lang.Override
920     @java.lang.SuppressWarnings("unchecked")
invoke( io.grpc.stub.StreamObserver<Resp> responseObserver)921     public io.grpc.stub.StreamObserver<Req> invoke(
922         io.grpc.stub.StreamObserver<Resp> responseObserver) {
923       switch (methodId) {
924         default:
925           throw new AssertionError();
926       }
927     }
928   }
929 
bindService(AsyncService service)930   public static final io.grpc.ServerServiceDefinition bindService(AsyncService service) {
931     return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
932         .addMethod(
933             getSubmitJobMethod(),
934             io.grpc.stub.ServerCalls.asyncUnaryCall(
935                 new MethodHandlers<
936                     com.google.cloud.dataproc.v1.SubmitJobRequest,
937                     com.google.cloud.dataproc.v1.Job>(service, METHODID_SUBMIT_JOB)))
938         .addMethod(
939             getSubmitJobAsOperationMethod(),
940             io.grpc.stub.ServerCalls.asyncUnaryCall(
941                 new MethodHandlers<
942                     com.google.cloud.dataproc.v1.SubmitJobRequest,
943                     com.google.longrunning.Operation>(service, METHODID_SUBMIT_JOB_AS_OPERATION)))
944         .addMethod(
945             getGetJobMethod(),
946             io.grpc.stub.ServerCalls.asyncUnaryCall(
947                 new MethodHandlers<
948                     com.google.cloud.dataproc.v1.GetJobRequest, com.google.cloud.dataproc.v1.Job>(
949                     service, METHODID_GET_JOB)))
950         .addMethod(
951             getListJobsMethod(),
952             io.grpc.stub.ServerCalls.asyncUnaryCall(
953                 new MethodHandlers<
954                     com.google.cloud.dataproc.v1.ListJobsRequest,
955                     com.google.cloud.dataproc.v1.ListJobsResponse>(service, METHODID_LIST_JOBS)))
956         .addMethod(
957             getUpdateJobMethod(),
958             io.grpc.stub.ServerCalls.asyncUnaryCall(
959                 new MethodHandlers<
960                     com.google.cloud.dataproc.v1.UpdateJobRequest,
961                     com.google.cloud.dataproc.v1.Job>(service, METHODID_UPDATE_JOB)))
962         .addMethod(
963             getCancelJobMethod(),
964             io.grpc.stub.ServerCalls.asyncUnaryCall(
965                 new MethodHandlers<
966                     com.google.cloud.dataproc.v1.CancelJobRequest,
967                     com.google.cloud.dataproc.v1.Job>(service, METHODID_CANCEL_JOB)))
968         .addMethod(
969             getDeleteJobMethod(),
970             io.grpc.stub.ServerCalls.asyncUnaryCall(
971                 new MethodHandlers<
972                     com.google.cloud.dataproc.v1.DeleteJobRequest, com.google.protobuf.Empty>(
973                     service, METHODID_DELETE_JOB)))
974         .build();
975   }
976 
977   private abstract static class JobControllerBaseDescriptorSupplier
978       implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
979           io.grpc.protobuf.ProtoServiceDescriptorSupplier {
JobControllerBaseDescriptorSupplier()980     JobControllerBaseDescriptorSupplier() {}
981 
982     @java.lang.Override
getFileDescriptor()983     public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
984       return com.google.cloud.dataproc.v1.JobsProto.getDescriptor();
985     }
986 
987     @java.lang.Override
getServiceDescriptor()988     public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
989       return getFileDescriptor().findServiceByName("JobController");
990     }
991   }
992 
993   private static final class JobControllerFileDescriptorSupplier
994       extends JobControllerBaseDescriptorSupplier {
JobControllerFileDescriptorSupplier()995     JobControllerFileDescriptorSupplier() {}
996   }
997 
998   private static final class JobControllerMethodDescriptorSupplier
999       extends JobControllerBaseDescriptorSupplier
1000       implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
1001     private final String methodName;
1002 
JobControllerMethodDescriptorSupplier(String methodName)1003     JobControllerMethodDescriptorSupplier(String methodName) {
1004       this.methodName = methodName;
1005     }
1006 
1007     @java.lang.Override
getMethodDescriptor()1008     public com.google.protobuf.Descriptors.MethodDescriptor getMethodDescriptor() {
1009       return getServiceDescriptor().findMethodByName(methodName);
1010     }
1011   }
1012 
1013   private static volatile io.grpc.ServiceDescriptor serviceDescriptor;
1014 
getServiceDescriptor()1015   public static io.grpc.ServiceDescriptor getServiceDescriptor() {
1016     io.grpc.ServiceDescriptor result = serviceDescriptor;
1017     if (result == null) {
1018       synchronized (JobControllerGrpc.class) {
1019         result = serviceDescriptor;
1020         if (result == null) {
1021           serviceDescriptor =
1022               result =
1023                   io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
1024                       .setSchemaDescriptor(new JobControllerFileDescriptorSupplier())
1025                       .addMethod(getSubmitJobMethod())
1026                       .addMethod(getSubmitJobAsOperationMethod())
1027                       .addMethod(getGetJobMethod())
1028                       .addMethod(getListJobsMethod())
1029                       .addMethod(getUpdateJobMethod())
1030                       .addMethod(getCancelJobMethod())
1031                       .addMethod(getDeleteJobMethod())
1032                       .build();
1033         }
1034       }
1035     }
1036     return result;
1037   }
1038 }
1039