Skip to content
This repository was archived by the owner on Jul 17, 2023. It is now read-only.
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
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
Original file line number Diff line number Diff line change
Expand Up @@ -16,11 +16,6 @@
package com.google.cloud.workflows.executions.v1beta;

import static io.grpc.MethodDescriptor.generateFullMethodName;
import static io.grpc.stub.ClientCalls.asyncUnaryCall;
import static io.grpc.stub.ClientCalls.blockingUnaryCall;
import static io.grpc.stub.ClientCalls.futureUnaryCall;
import static io.grpc.stub.ServerCalls.asyncUnaryCall;
import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;

/**
*
Expand Down Expand Up @@ -291,7 +286,8 @@ public void listExecutions(
io.grpc.stub.StreamObserver<
com.google.cloud.workflows.executions.v1beta.ListExecutionsResponse>
responseObserver) {
asyncUnimplementedUnaryCall(getListExecutionsMethod(), responseObserver);
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
getListExecutionsMethod(), responseObserver);
}

/**
Expand All @@ -305,7 +301,8 @@ public void createExecution(
com.google.cloud.workflows.executions.v1beta.CreateExecutionRequest request,
io.grpc.stub.StreamObserver<com.google.cloud.workflows.executions.v1beta.Execution>
responseObserver) {
asyncUnimplementedUnaryCall(getCreateExecutionMethod(), responseObserver);
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
getCreateExecutionMethod(), responseObserver);
}

/**
Expand All @@ -319,7 +316,8 @@ public void getExecution(
com.google.cloud.workflows.executions.v1beta.GetExecutionRequest request,
io.grpc.stub.StreamObserver<com.google.cloud.workflows.executions.v1beta.Execution>
responseObserver) {
asyncUnimplementedUnaryCall(getGetExecutionMethod(), responseObserver);
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
getGetExecutionMethod(), responseObserver);
}

/**
Expand All @@ -333,36 +331,37 @@ public void cancelExecution(
com.google.cloud.workflows.executions.v1beta.CancelExecutionRequest request,
io.grpc.stub.StreamObserver<com.google.cloud.workflows.executions.v1beta.Execution>
responseObserver) {
asyncUnimplementedUnaryCall(getCancelExecutionMethod(), responseObserver);
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
getCancelExecutionMethod(), responseObserver);
}

@java.lang.Override
public final io.grpc.ServerServiceDefinition bindService() {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
.addMethod(
getListExecutionsMethod(),
asyncUnaryCall(
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.workflows.executions.v1beta.ListExecutionsRequest,
com.google.cloud.workflows.executions.v1beta.ListExecutionsResponse>(
this, METHODID_LIST_EXECUTIONS)))
.addMethod(
getCreateExecutionMethod(),
asyncUnaryCall(
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.workflows.executions.v1beta.CreateExecutionRequest,
com.google.cloud.workflows.executions.v1beta.Execution>(
this, METHODID_CREATE_EXECUTION)))
.addMethod(
getGetExecutionMethod(),
asyncUnaryCall(
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.workflows.executions.v1beta.GetExecutionRequest,
com.google.cloud.workflows.executions.v1beta.Execution>(
this, METHODID_GET_EXECUTION)))
.addMethod(
getCancelExecutionMethod(),
asyncUnaryCall(
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.workflows.executions.v1beta.CancelExecutionRequest,
com.google.cloud.workflows.executions.v1beta.Execution>(
Expand Down Expand Up @@ -404,7 +403,7 @@ public void listExecutions(
io.grpc.stub.StreamObserver<
com.google.cloud.workflows.executions.v1beta.ListExecutionsResponse>
responseObserver) {
asyncUnaryCall(
io.grpc.stub.ClientCalls.asyncUnaryCall(
getChannel().newCall(getListExecutionsMethod(), getCallOptions()),
request,
responseObserver);
Expand All @@ -421,7 +420,7 @@ public void createExecution(
com.google.cloud.workflows.executions.v1beta.CreateExecutionRequest request,
io.grpc.stub.StreamObserver<com.google.cloud.workflows.executions.v1beta.Execution>
responseObserver) {
asyncUnaryCall(
io.grpc.stub.ClientCalls.asyncUnaryCall(
getChannel().newCall(getCreateExecutionMethod(), getCallOptions()),
request,
responseObserver);
Expand All @@ -438,7 +437,7 @@ public void getExecution(
com.google.cloud.workflows.executions.v1beta.GetExecutionRequest request,
io.grpc.stub.StreamObserver<com.google.cloud.workflows.executions.v1beta.Execution>
responseObserver) {
asyncUnaryCall(
io.grpc.stub.ClientCalls.asyncUnaryCall(
getChannel().newCall(getGetExecutionMethod(), getCallOptions()),
request,
responseObserver);
Expand All @@ -455,7 +454,7 @@ public void cancelExecution(
com.google.cloud.workflows.executions.v1beta.CancelExecutionRequest request,
io.grpc.stub.StreamObserver<com.google.cloud.workflows.executions.v1beta.Execution>
responseObserver) {
asyncUnaryCall(
io.grpc.stub.ClientCalls.asyncUnaryCall(
getChannel().newCall(getCancelExecutionMethod(), getCallOptions()),
request,
responseObserver);
Expand Down Expand Up @@ -494,7 +493,8 @@ protected ExecutionsBlockingStub build(
*/
public com.google.cloud.workflows.executions.v1beta.ListExecutionsResponse listExecutions(
com.google.cloud.workflows.executions.v1beta.ListExecutionsRequest request) {
return blockingUnaryCall(getChannel(), getListExecutionsMethod(), getCallOptions(), request);
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListExecutionsMethod(), getCallOptions(), request);
}

/**
Expand All @@ -506,7 +506,8 @@ public com.google.cloud.workflows.executions.v1beta.ListExecutionsResponse listE
*/
public com.google.cloud.workflows.executions.v1beta.Execution createExecution(
com.google.cloud.workflows.executions.v1beta.CreateExecutionRequest request) {
return blockingUnaryCall(getChannel(), getCreateExecutionMethod(), getCallOptions(), request);
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateExecutionMethod(), getCallOptions(), request);
}

/**
Expand All @@ -518,7 +519,8 @@ public com.google.cloud.workflows.executions.v1beta.Execution createExecution(
*/
public com.google.cloud.workflows.executions.v1beta.Execution getExecution(
com.google.cloud.workflows.executions.v1beta.GetExecutionRequest request) {
return blockingUnaryCall(getChannel(), getGetExecutionMethod(), getCallOptions(), request);
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetExecutionMethod(), getCallOptions(), request);
}

/**
Expand All @@ -530,7 +532,8 @@ public com.google.cloud.workflows.executions.v1beta.Execution getExecution(
*/
public com.google.cloud.workflows.executions.v1beta.Execution cancelExecution(
com.google.cloud.workflows.executions.v1beta.CancelExecutionRequest request) {
return blockingUnaryCall(getChannel(), getCancelExecutionMethod(), getCallOptions(), request);
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCancelExecutionMethod(), getCallOptions(), request);
}
}

Expand Down Expand Up @@ -566,7 +569,7 @@ protected ExecutionsFutureStub build(io.grpc.Channel channel, io.grpc.CallOption
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.workflows.executions.v1beta.ListExecutionsResponse>
listExecutions(com.google.cloud.workflows.executions.v1beta.ListExecutionsRequest request) {
return futureUnaryCall(
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListExecutionsMethod(), getCallOptions()), request);
}

Expand All @@ -581,7 +584,7 @@ protected ExecutionsFutureStub build(io.grpc.Channel channel, io.grpc.CallOption
com.google.cloud.workflows.executions.v1beta.Execution>
createExecution(
com.google.cloud.workflows.executions.v1beta.CreateExecutionRequest request) {
return futureUnaryCall(
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateExecutionMethod(), getCallOptions()), request);
}

Expand All @@ -595,7 +598,7 @@ protected ExecutionsFutureStub build(io.grpc.Channel channel, io.grpc.CallOption
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.workflows.executions.v1beta.Execution>
getExecution(com.google.cloud.workflows.executions.v1beta.GetExecutionRequest request) {
return futureUnaryCall(
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetExecutionMethod(), getCallOptions()), request);
}

Expand All @@ -610,7 +613,7 @@ protected ExecutionsFutureStub build(io.grpc.Channel channel, io.grpc.CallOption
com.google.cloud.workflows.executions.v1beta.Execution>
cancelExecution(
com.google.cloud.workflows.executions.v1beta.CancelExecutionRequest request) {
return futureUnaryCall(
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCancelExecutionMethod(), getCallOptions()), request);
}
}
Expand Down
6 changes: 3 additions & 3 deletions synth.metadata
Original file line number Diff line number Diff line change
Expand Up @@ -4,15 +4,15 @@
"git": {
"name": ".",
"remote": "https://github.com/googleapis/java-workflow-executions.git",
"sha": "16c56036867e723b1f4857f5c34949a6670bee42"
"sha": "4ae9db293e8c08e0c568665ea844d2243beb70dd"
}
},
{
"git": {
"name": "googleapis",
"remote": "https://github.com/googleapis/googleapis.git",
"sha": "3befd26ca55723d3e8111909331eac1249837987",
"internalRef": "360805639"
"sha": "0e915217fb5261c1e57bfaf0e16ee5c7feaaba89",
"internalRef": "361377784"
}
},
{
Expand Down