Skip to content

Commit

Permalink
regenerating libraries for release (#3398)
Browse files Browse the repository at this point in the history 
* regenerate libraries
  • Loading branch information
@yihanzhen
yihanzhen authored Jun 21, 2018
1 parent 5cfc619 commit 4e61242
Show file tree
Hide file tree
Showing 54 changed files with 5,541 additions and 2,003 deletions.
158 changes: 125 additions & 33 deletions ...pi-grpc/grpc-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PublisherGrpc.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -254,6 +254,43 @@ com.google.pubsub.v1.ListTopicSubscriptionsResponse> getListTopicSubscriptionsMe
return getListTopicSubscriptionsMethod;
}
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
@java.lang.Deprecated // Use {@link #getListTopicSnapshotsMethod()} instead.
public static final io.grpc.MethodDescriptor<com.google.pubsub.v1.ListTopicSnapshotsRequest,
com.google.pubsub.v1.ListTopicSnapshotsResponse> METHOD_LIST_TOPIC_SNAPSHOTS = getListTopicSnapshotsMethodHelper();

private static volatile io.grpc.MethodDescriptor<com.google.pubsub.v1.ListTopicSnapshotsRequest,
com.google.pubsub.v1.ListTopicSnapshotsResponse> getListTopicSnapshotsMethod;

@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
public static io.grpc.MethodDescriptor<com.google.pubsub.v1.ListTopicSnapshotsRequest,
com.google.pubsub.v1.ListTopicSnapshotsResponse> getListTopicSnapshotsMethod() {
return getListTopicSnapshotsMethodHelper();
}

private static io.grpc.MethodDescriptor<com.google.pubsub.v1.ListTopicSnapshotsRequest,
com.google.pubsub.v1.ListTopicSnapshotsResponse> getListTopicSnapshotsMethodHelper() {
io.grpc.MethodDescriptor<com.google.pubsub.v1.ListTopicSnapshotsRequest, com.google.pubsub.v1.ListTopicSnapshotsResponse> getListTopicSnapshotsMethod;
if ((getListTopicSnapshotsMethod = PublisherGrpc.getListTopicSnapshotsMethod) == null) {
synchronized (PublisherGrpc.class) {
if ((getListTopicSnapshotsMethod = PublisherGrpc.getListTopicSnapshotsMethod) == null) {
PublisherGrpc.getListTopicSnapshotsMethod = getListTopicSnapshotsMethod =
io.grpc.MethodDescriptor.<com.google.pubsub.v1.ListTopicSnapshotsRequest, com.google.pubsub.v1.ListTopicSnapshotsResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName(
"google.pubsub.v1.Publisher", "ListTopicSnapshots"))
.setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
com.google.pubsub.v1.ListTopicSnapshotsRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
com.google.pubsub.v1.ListTopicSnapshotsResponse.getDefaultInstance()))
.setSchemaDescriptor(new PublisherMethodDescriptorSupplier("ListTopicSnapshots"))
.build();
}
}
}
return getListTopicSnapshotsMethod;
}
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
@java.lang.Deprecated // Use {@link #getDeleteTopicMethod()} instead.
public static final io.grpc.MethodDescriptor<com.google.pubsub.v1.DeleteTopicRequest,
com.google.protobuf.Empty> METHOD_DELETE_TOPIC = getDeleteTopicMethodHelper();
Expand Down Expand Up @@ -324,7 +361,8 @@ public static abstract class PublisherImplBase implements io.grpc.BindableServic

/**
* <pre>
* Creates the given topic with the given name.
* Creates the given topic with the given name. See the
* &lt;a href="/pubsub/docs/admin#resource_names"&gt; resource name rules&lt;/a&gt;.
* </pre>
*/
public void createTopic(com.google.pubsub.v1.Topic request,
Expand All @@ -334,12 +372,8 @@ public void createTopic(com.google.pubsub.v1.Topic request,

/**
* <pre>
* Updates an existing topic. Note that certain properties of a topic are not
* modifiable. Options settings follow the style guide:
* NOTE: The style guide requires body: "topic" instead of body: "*".
* Keeping the latter for internal consistency in V1, however it should be
* corrected in V2. See
* https://cloud.google.com/apis/design/standard_methods#update for details.
* Updates an existing topic. Note that certain properties of a
* topic are not modifiable.
* </pre>
*/
public void updateTopic(com.google.pubsub.v1.UpdateTopicRequest request,
Expand Down Expand Up @@ -381,14 +415,27 @@ public void listTopics(com.google.pubsub.v1.ListTopicsRequest request,

/**
* <pre>
* Lists the name of the subscriptions for this topic.
* Lists the names of the subscriptions on this topic.
* </pre>
*/
public void listTopicSubscriptions(com.google.pubsub.v1.ListTopicSubscriptionsRequest request,
io.grpc.stub.StreamObserver<com.google.pubsub.v1.ListTopicSubscriptionsResponse> responseObserver) {
asyncUnimplementedUnaryCall(getListTopicSubscriptionsMethodHelper(), responseObserver);
}

/**
* <pre>
* Lists the names of the snapshots on this topic.&lt;br&gt;&lt;br&gt;
* &lt;b&gt;ALPHA:&lt;/b&gt; This feature is part of an alpha release. This API might be
* changed in backward-incompatible ways and is not recommended for production
* use. It is not subject to any SLA or deprecation policy.
* </pre>
*/
public void listTopicSnapshots(com.google.pubsub.v1.ListTopicSnapshotsRequest request,
io.grpc.stub.StreamObserver<com.google.pubsub.v1.ListTopicSnapshotsResponse> responseObserver) {
asyncUnimplementedUnaryCall(getListTopicSnapshotsMethodHelper(), responseObserver);
}

/**
* <pre>
* Deletes the topic with the given name. Returns `NOT_FOUND` if the topic
Expand Down Expand Up @@ -447,6 +494,13 @@ public void deleteTopic(com.google.pubsub.v1.DeleteTopicRequest request,
com.google.pubsub.v1.ListTopicSubscriptionsRequest,
com.google.pubsub.v1.ListTopicSubscriptionsResponse>(
this, METHODID_LIST_TOPIC_SUBSCRIPTIONS)))
.addMethod(
getListTopicSnapshotsMethodHelper(),
asyncUnaryCall(
new MethodHandlers<
com.google.pubsub.v1.ListTopicSnapshotsRequest,
com.google.pubsub.v1.ListTopicSnapshotsResponse>(
this, METHODID_LIST_TOPIC_SNAPSHOTS)))
.addMethod(
getDeleteTopicMethodHelper(),
asyncUnaryCall(
Expand Down Expand Up @@ -482,7 +536,8 @@ protected PublisherStub build(io.grpc.Channel channel,

/**
* <pre>
* Creates the given topic with the given name.
* Creates the given topic with the given name. See the
* &lt;a href="/pubsub/docs/admin#resource_names"&gt; resource name rules&lt;/a&gt;.
* </pre>
*/
public void createTopic(com.google.pubsub.v1.Topic request,
Expand All @@ -493,12 +548,8 @@ public void createTopic(com.google.pubsub.v1.Topic request,

/**
* <pre>
* Updates an existing topic. Note that certain properties of a topic are not
* modifiable. Options settings follow the style guide:
* NOTE: The style guide requires body: "topic" instead of body: "*".
* Keeping the latter for internal consistency in V1, however it should be
* corrected in V2. See
* https://cloud.google.com/apis/design/standard_methods#update for details.
* Updates an existing topic. Note that certain properties of a
* topic are not modifiable.
* </pre>
*/
public void updateTopic(com.google.pubsub.v1.UpdateTopicRequest request,
Expand Down Expand Up @@ -544,7 +595,7 @@ public void listTopics(com.google.pubsub.v1.ListTopicsRequest request,

/**
* <pre>
* Lists the name of the subscriptions for this topic.
* Lists the names of the subscriptions on this topic.
* </pre>
*/
public void listTopicSubscriptions(com.google.pubsub.v1.ListTopicSubscriptionsRequest request,
Expand All @@ -553,6 +604,20 @@ public void listTopicSubscriptions(com.google.pubsub.v1.ListTopicSubscriptionsRe
getChannel().newCall(getListTopicSubscriptionsMethodHelper(), getCallOptions()), request, responseObserver);
}

/**
* <pre>
* Lists the names of the snapshots on this topic.&lt;br&gt;&lt;br&gt;
* &lt;b&gt;ALPHA:&lt;/b&gt; This feature is part of an alpha release. This API might be
* changed in backward-incompatible ways and is not recommended for production
* use. It is not subject to any SLA or deprecation policy.
* </pre>
*/
public void listTopicSnapshots(com.google.pubsub.v1.ListTopicSnapshotsRequest request,
io.grpc.stub.StreamObserver<com.google.pubsub.v1.ListTopicSnapshotsResponse> responseObserver) {
asyncUnaryCall(
getChannel().newCall(getListTopicSnapshotsMethodHelper(), getCallOptions()), request, responseObserver);
}

/**
* <pre>
* Deletes the topic with the given name. Returns `NOT_FOUND` if the topic
Expand Down Expand Up @@ -593,7 +658,8 @@ protected PublisherBlockingStub build(io.grpc.Channel channel,

/**
* <pre>
* Creates the given topic with the given name.
* Creates the given topic with the given name. See the
* &lt;a href="/pubsub/docs/admin#resource_names"&gt; resource name rules&lt;/a&gt;.
* </pre>
*/
public com.google.pubsub.v1.Topic createTopic(com.google.pubsub.v1.Topic request) {
Expand All @@ -603,12 +669,8 @@ public com.google.pubsub.v1.Topic createTopic(com.google.pubsub.v1.Topic request

/**
* <pre>
* Updates an existing topic. Note that certain properties of a topic are not
* modifiable. Options settings follow the style guide:
* NOTE: The style guide requires body: "topic" instead of body: "*".
* Keeping the latter for internal consistency in V1, however it should be
* corrected in V2. See
* https://cloud.google.com/apis/design/standard_methods#update for details.
* Updates an existing topic. Note that certain properties of a
* topic are not modifiable.
* </pre>
*/
public com.google.pubsub.v1.Topic updateTopic(com.google.pubsub.v1.UpdateTopicRequest request) {
Expand Down Expand Up @@ -650,14 +712,27 @@ public com.google.pubsub.v1.ListTopicsResponse listTopics(com.google.pubsub.v1.L

/**
* <pre>
* Lists the name of the subscriptions for this topic.
* Lists the names of the subscriptions on this topic.
* </pre>
*/
public com.google.pubsub.v1.ListTopicSubscriptionsResponse listTopicSubscriptions(com.google.pubsub.v1.ListTopicSubscriptionsRequest request) {
return blockingUnaryCall(
getChannel(), getListTopicSubscriptionsMethodHelper(), getCallOptions(), request);
}

/**
* <pre>
* Lists the names of the snapshots on this topic.&lt;br&gt;&lt;br&gt;
* &lt;b&gt;ALPHA:&lt;/b&gt; This feature is part of an alpha release. This API might be
* changed in backward-incompatible ways and is not recommended for production
* use. It is not subject to any SLA or deprecation policy.
* </pre>
*/
public com.google.pubsub.v1.ListTopicSnapshotsResponse listTopicSnapshots(com.google.pubsub.v1.ListTopicSnapshotsRequest request) {
return blockingUnaryCall(
getChannel(), getListTopicSnapshotsMethodHelper(), getCallOptions(), request);
}

/**
* <pre>
* Deletes the topic with the given name. Returns `NOT_FOUND` if the topic
Expand Down Expand Up @@ -697,7 +772,8 @@ protected PublisherFutureStub build(io.grpc.Channel channel,

/**
* <pre>
* Creates the given topic with the given name.
* Creates the given topic with the given name. See the
* &lt;a href="/pubsub/docs/admin#resource_names"&gt; resource name rules&lt;/a&gt;.
* </pre>
*/
public com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.Topic> createTopic(
Expand All @@ -708,12 +784,8 @@ public com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.T

/**
* <pre>
* Updates an existing topic. Note that certain properties of a topic are not
* modifiable. Options settings follow the style guide:
* NOTE: The style guide requires body: "topic" instead of body: "*".
* Keeping the latter for internal consistency in V1, however it should be
* corrected in V2. See
* https://cloud.google.com/apis/design/standard_methods#update for details.
* Updates an existing topic. Note that certain properties of a
* topic are not modifiable.
* </pre>
*/
public com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.Topic> updateTopic(
Expand Down Expand Up @@ -759,7 +831,7 @@ public com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.L

/**
* <pre>
* Lists the name of the subscriptions for this topic.
* Lists the names of the subscriptions on this topic.
* </pre>
*/
public com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.ListTopicSubscriptionsResponse> listTopicSubscriptions(
Expand All @@ -768,6 +840,20 @@ public com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.L
getChannel().newCall(getListTopicSubscriptionsMethodHelper(), getCallOptions()), request);
}

/**
* <pre>
* Lists the names of the snapshots on this topic.&lt;br&gt;&lt;br&gt;
* &lt;b&gt;ALPHA:&lt;/b&gt; This feature is part of an alpha release. This API might be
* changed in backward-incompatible ways and is not recommended for production
* use. It is not subject to any SLA or deprecation policy.
* </pre>
*/
public com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.ListTopicSnapshotsResponse> listTopicSnapshots(
com.google.pubsub.v1.ListTopicSnapshotsRequest request) {
return futureUnaryCall(
getChannel().newCall(getListTopicSnapshotsMethodHelper(), getCallOptions()), request);
}

/**
* <pre>
* Deletes the topic with the given name. Returns `NOT_FOUND` if the topic
Expand All @@ -790,7 +876,8 @@ public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Em
private static final int METHODID_GET_TOPIC = 3;
private static final int METHODID_LIST_TOPICS = 4;
private static final int METHODID_LIST_TOPIC_SUBSCRIPTIONS = 5;
private static final int METHODID_DELETE_TOPIC = 6;
private static final int METHODID_LIST_TOPIC_SNAPSHOTS = 6;
private static final int METHODID_DELETE_TOPIC = 7;

private static final class MethodHandlers<Req, Resp> implements
io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
Expand Down Expand Up @@ -833,6 +920,10 @@ public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserv
serviceImpl.listTopicSubscriptions((com.google.pubsub.v1.ListTopicSubscriptionsRequest) request,
(io.grpc.stub.StreamObserver<com.google.pubsub.v1.ListTopicSubscriptionsResponse>) responseObserver);
break;
case METHODID_LIST_TOPIC_SNAPSHOTS:
serviceImpl.listTopicSnapshots((com.google.pubsub.v1.ListTopicSnapshotsRequest) request,
(io.grpc.stub.StreamObserver<com.google.pubsub.v1.ListTopicSnapshotsResponse>) responseObserver);
break;
case METHODID_DELETE_TOPIC:
serviceImpl.deleteTopic((com.google.pubsub.v1.DeleteTopicRequest) request,
(io.grpc.stub.StreamObserver<com.google.protobuf.Empty>) responseObserver);
Expand Down Expand Up @@ -904,6 +995,7 @@ public static io.grpc.ServiceDescriptor getServiceDescriptor() {
.addMethod(getGetTopicMethodHelper())
.addMethod(getListTopicsMethodHelper())
.addMethod(getListTopicSubscriptionsMethodHelper())
.addMethod(getListTopicSnapshotsMethodHelper())
.addMethod(getDeleteTopicMethodHelper())
.build();
}
Expand Down
Loading

0 comments on commit 4e61242

Please sign in to comment.