Skip to content
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

Jump to bottom

regenerating libraries for release #3398

Merged
merged 2 commits into from
Jun 21, 2018
Merged

regenerating libraries for release #3398

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
b21855a
generating libraries
yihanzhen Jun 20, 2018
0600c1b
add generated gapics
yihanzhen Jun 21, 2018
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
158 changes: 125 additions & 33 deletions ...pi-grpc/grpc-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PublisherGrpc.java
View file
Open in desktop
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