Skip to content

Commit

Permalink
docs: Remove experimental note for schema APIs (#560)
Browse files Browse the repository at this point in the history
* docs: Remove experimental note for schema APIs

PiperOrigin-RevId: 360714464

Source-Author: Google APIs <[email protected]>
Source-Date: Wed Mar 3 11:13:45 2021 -0800
Source-Repo: googleapis/googleapis
Source-Sha: 479acf6990eada1213f8666f1c795a018f8496f9
Source-Link: googleapis/googleapis@479acf6

* chore: update gax-java dependency to 1.62

PiperOrigin-RevId: 361377784

Source-Author: Google APIs <[email protected]>
Source-Date: Sat Mar 6 21:09:41 2021 -0800
Source-Repo: googleapis/googleapis
Source-Sha: 0e915217fb5261c1e57bfaf0e16ee5c7feaaba89
Source-Link: googleapis/googleapis@0e91521
  • Loading branch information
yoshi-automation committed Mar 15, 2021
1 parent b6e299f commit 4b98556
Show file tree
Hide file tree
Showing 10 changed files with 244 additions and 201 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@

// AUTO-GENERATED DOCUMENTATION AND SERVICE
/**
* Service Description:
* Service Description: Service for doing schema-related operations.
*
* <p>This class provides the ability to make remote calls to the backing service through method
* calls that map to API methods. Sample code to get started:
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@
*
* <p>=================== SchemaServiceClient ===================
*
* <p>Service Description:
* <p>Service Description: Service for doing schema-related operations.
*
* <p>Sample for SchemaServiceClient:
*
Expand Down

Large diffs are not rendered by default.

Original file line number Diff line number Diff line change
Expand Up @@ -16,13 +16,14 @@
package com.google.pubsub.v1;

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;

/** */
/**
*
*
* <pre>
* Service for doing schema-related operations.
* </pre>
*/
@javax.annotation.Generated(
value = "by gRPC proto compiler",
comments = "Source: google/pubsub/v1/schema.proto")
Expand Down Expand Up @@ -319,7 +320,13 @@ public SchemaServiceFutureStub newStub(
return SchemaServiceFutureStub.newStub(factory, channel);
}

/** */
/**
*
*
* <pre>
* Service for doing schema-related operations.
* </pre>
*/
public abstract static class SchemaServiceImplBase implements io.grpc.BindableService {

/**
Expand All @@ -332,7 +339,8 @@ public abstract static class SchemaServiceImplBase implements io.grpc.BindableSe
public void createSchema(
com.google.pubsub.v1.CreateSchemaRequest request,
io.grpc.stub.StreamObserver<com.google.pubsub.v1.Schema> responseObserver) {
asyncUnimplementedUnaryCall(getCreateSchemaMethod(), responseObserver);
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
getCreateSchemaMethod(), responseObserver);
}

/**
Expand All @@ -345,7 +353,7 @@ public void createSchema(
public void getSchema(
com.google.pubsub.v1.GetSchemaRequest request,
io.grpc.stub.StreamObserver<com.google.pubsub.v1.Schema> responseObserver) {
asyncUnimplementedUnaryCall(getGetSchemaMethod(), responseObserver);
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetSchemaMethod(), responseObserver);
}

/**
Expand All @@ -358,7 +366,8 @@ public void getSchema(
public void listSchemas(
com.google.pubsub.v1.ListSchemasRequest request,
io.grpc.stub.StreamObserver<com.google.pubsub.v1.ListSchemasResponse> responseObserver) {
asyncUnimplementedUnaryCall(getListSchemasMethod(), responseObserver);
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
getListSchemasMethod(), responseObserver);
}

/**
Expand All @@ -371,7 +380,8 @@ public void listSchemas(
public void deleteSchema(
com.google.pubsub.v1.DeleteSchemaRequest request,
io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) {
asyncUnimplementedUnaryCall(getDeleteSchemaMethod(), responseObserver);
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
getDeleteSchemaMethod(), responseObserver);
}

/**
Expand All @@ -384,7 +394,8 @@ public void deleteSchema(
public void validateSchema(
com.google.pubsub.v1.ValidateSchemaRequest request,
io.grpc.stub.StreamObserver<com.google.pubsub.v1.ValidateSchemaResponse> responseObserver) {
asyncUnimplementedUnaryCall(getValidateSchemaMethod(), responseObserver);
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
getValidateSchemaMethod(), responseObserver);
}

/**
Expand All @@ -398,45 +409,46 @@ public void validateMessage(
com.google.pubsub.v1.ValidateMessageRequest request,
io.grpc.stub.StreamObserver<com.google.pubsub.v1.ValidateMessageResponse>
responseObserver) {
asyncUnimplementedUnaryCall(getValidateMessageMethod(), responseObserver);
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
getValidateMessageMethod(), responseObserver);
}

@java.lang.Override
public final io.grpc.ServerServiceDefinition bindService() {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
.addMethod(
getCreateSchemaMethod(),
asyncUnaryCall(
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.pubsub.v1.CreateSchemaRequest, com.google.pubsub.v1.Schema>(
this, METHODID_CREATE_SCHEMA)))
.addMethod(
getGetSchemaMethod(),
asyncUnaryCall(
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.pubsub.v1.GetSchemaRequest, com.google.pubsub.v1.Schema>(
this, METHODID_GET_SCHEMA)))
.addMethod(
getListSchemasMethod(),
asyncUnaryCall(
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.pubsub.v1.ListSchemasRequest,
com.google.pubsub.v1.ListSchemasResponse>(this, METHODID_LIST_SCHEMAS)))
.addMethod(
getDeleteSchemaMethod(),
asyncUnaryCall(
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.pubsub.v1.DeleteSchemaRequest, com.google.protobuf.Empty>(
this, METHODID_DELETE_SCHEMA)))
.addMethod(
getValidateSchemaMethod(),
asyncUnaryCall(
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.pubsub.v1.ValidateSchemaRequest,
com.google.pubsub.v1.ValidateSchemaResponse>(this, METHODID_VALIDATE_SCHEMA)))
.addMethod(
getValidateMessageMethod(),
asyncUnaryCall(
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.pubsub.v1.ValidateMessageRequest,
com.google.pubsub.v1.ValidateMessageResponse>(
Expand All @@ -445,7 +457,13 @@ public final io.grpc.ServerServiceDefinition bindService() {
}
}

/** */
/**
*
*
* <pre>
* Service for doing schema-related operations.
* </pre>
*/
public static final class SchemaServiceStub
extends io.grpc.stub.AbstractAsyncStub<SchemaServiceStub> {
private SchemaServiceStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
Expand All @@ -467,7 +485,7 @@ protected SchemaServiceStub build(io.grpc.Channel channel, io.grpc.CallOptions c
public void createSchema(
com.google.pubsub.v1.CreateSchemaRequest request,
io.grpc.stub.StreamObserver<com.google.pubsub.v1.Schema> responseObserver) {
asyncUnaryCall(
io.grpc.stub.ClientCalls.asyncUnaryCall(
getChannel().newCall(getCreateSchemaMethod(), getCallOptions()),
request,
responseObserver);
Expand All @@ -483,7 +501,7 @@ public void createSchema(
public void getSchema(
com.google.pubsub.v1.GetSchemaRequest request,
io.grpc.stub.StreamObserver<com.google.pubsub.v1.Schema> responseObserver) {
asyncUnaryCall(
io.grpc.stub.ClientCalls.asyncUnaryCall(
getChannel().newCall(getGetSchemaMethod(), getCallOptions()), request, responseObserver);
}

Expand All @@ -497,7 +515,7 @@ public void getSchema(
public void listSchemas(
com.google.pubsub.v1.ListSchemasRequest request,
io.grpc.stub.StreamObserver<com.google.pubsub.v1.ListSchemasResponse> responseObserver) {
asyncUnaryCall(
io.grpc.stub.ClientCalls.asyncUnaryCall(
getChannel().newCall(getListSchemasMethod(), getCallOptions()),
request,
responseObserver);
Expand All @@ -513,7 +531,7 @@ public void listSchemas(
public void deleteSchema(
com.google.pubsub.v1.DeleteSchemaRequest request,
io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) {
asyncUnaryCall(
io.grpc.stub.ClientCalls.asyncUnaryCall(
getChannel().newCall(getDeleteSchemaMethod(), getCallOptions()),
request,
responseObserver);
Expand All @@ -529,7 +547,7 @@ public void deleteSchema(
public void validateSchema(
com.google.pubsub.v1.ValidateSchemaRequest request,
io.grpc.stub.StreamObserver<com.google.pubsub.v1.ValidateSchemaResponse> responseObserver) {
asyncUnaryCall(
io.grpc.stub.ClientCalls.asyncUnaryCall(
getChannel().newCall(getValidateSchemaMethod(), getCallOptions()),
request,
responseObserver);
Expand All @@ -546,14 +564,20 @@ public void validateMessage(
com.google.pubsub.v1.ValidateMessageRequest request,
io.grpc.stub.StreamObserver<com.google.pubsub.v1.ValidateMessageResponse>
responseObserver) {
asyncUnaryCall(
io.grpc.stub.ClientCalls.asyncUnaryCall(
getChannel().newCall(getValidateMessageMethod(), getCallOptions()),
request,
responseObserver);
}
}

/** */
/**
*
*
* <pre>
* Service for doing schema-related operations.
* </pre>
*/
public static final class SchemaServiceBlockingStub
extends io.grpc.stub.AbstractBlockingStub<SchemaServiceBlockingStub> {
private SchemaServiceBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
Expand All @@ -575,7 +599,8 @@ protected SchemaServiceBlockingStub build(
*/
public com.google.pubsub.v1.Schema createSchema(
com.google.pubsub.v1.CreateSchemaRequest request) {
return blockingUnaryCall(getChannel(), getCreateSchemaMethod(), getCallOptions(), request);
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateSchemaMethod(), getCallOptions(), request);
}

/**
Expand All @@ -586,7 +611,8 @@ public com.google.pubsub.v1.Schema createSchema(
* </pre>
*/
public com.google.pubsub.v1.Schema getSchema(com.google.pubsub.v1.GetSchemaRequest request) {
return blockingUnaryCall(getChannel(), getGetSchemaMethod(), getCallOptions(), request);
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetSchemaMethod(), getCallOptions(), request);
}

/**
Expand All @@ -598,7 +624,8 @@ public com.google.pubsub.v1.Schema getSchema(com.google.pubsub.v1.GetSchemaReque
*/
public com.google.pubsub.v1.ListSchemasResponse listSchemas(
com.google.pubsub.v1.ListSchemasRequest request) {
return blockingUnaryCall(getChannel(), getListSchemasMethod(), getCallOptions(), request);
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListSchemasMethod(), getCallOptions(), request);
}

/**
Expand All @@ -610,7 +637,8 @@ public com.google.pubsub.v1.ListSchemasResponse listSchemas(
*/
public com.google.protobuf.Empty deleteSchema(
com.google.pubsub.v1.DeleteSchemaRequest request) {
return blockingUnaryCall(getChannel(), getDeleteSchemaMethod(), getCallOptions(), request);
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteSchemaMethod(), getCallOptions(), request);
}

/**
Expand All @@ -622,7 +650,8 @@ public com.google.protobuf.Empty deleteSchema(
*/
public com.google.pubsub.v1.ValidateSchemaResponse validateSchema(
com.google.pubsub.v1.ValidateSchemaRequest request) {
return blockingUnaryCall(getChannel(), getValidateSchemaMethod(), getCallOptions(), request);
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getValidateSchemaMethod(), getCallOptions(), request);
}

/**
Expand All @@ -634,11 +663,18 @@ public com.google.pubsub.v1.ValidateSchemaResponse validateSchema(
*/
public com.google.pubsub.v1.ValidateMessageResponse validateMessage(
com.google.pubsub.v1.ValidateMessageRequest request) {
return blockingUnaryCall(getChannel(), getValidateMessageMethod(), getCallOptions(), request);
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getValidateMessageMethod(), getCallOptions(), request);
}
}

/** */
/**
*
*
* <pre>
* Service for doing schema-related operations.
* </pre>
*/
public static final class SchemaServiceFutureStub
extends io.grpc.stub.AbstractFutureStub<SchemaServiceFutureStub> {
private SchemaServiceFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
Expand All @@ -660,7 +696,7 @@ protected SchemaServiceFutureStub build(
*/
public com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.Schema>
createSchema(com.google.pubsub.v1.CreateSchemaRequest request) {
return futureUnaryCall(
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateSchemaMethod(), getCallOptions()), request);
}

Expand All @@ -673,7 +709,8 @@ protected SchemaServiceFutureStub build(
*/
public com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.Schema>
getSchema(com.google.pubsub.v1.GetSchemaRequest request) {
return futureUnaryCall(getChannel().newCall(getGetSchemaMethod(), getCallOptions()), request);
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetSchemaMethod(), getCallOptions()), request);
}

/**
Expand All @@ -686,7 +723,7 @@ protected SchemaServiceFutureStub build(
public com.google.common.util.concurrent.ListenableFuture<
com.google.pubsub.v1.ListSchemasResponse>
listSchemas(com.google.pubsub.v1.ListSchemasRequest request) {
return futureUnaryCall(
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListSchemasMethod(), getCallOptions()), request);
}

Expand All @@ -699,7 +736,7 @@ protected SchemaServiceFutureStub build(
*/
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>
deleteSchema(com.google.pubsub.v1.DeleteSchemaRequest request) {
return futureUnaryCall(
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteSchemaMethod(), getCallOptions()), request);
}

Expand All @@ -713,7 +750,7 @@ protected SchemaServiceFutureStub build(
public com.google.common.util.concurrent.ListenableFuture<
com.google.pubsub.v1.ValidateSchemaResponse>
validateSchema(com.google.pubsub.v1.ValidateSchemaRequest request) {
return futureUnaryCall(
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getValidateSchemaMethod(), getCallOptions()), request);
}

Expand All @@ -727,7 +764,7 @@ protected SchemaServiceFutureStub build(
public com.google.common.util.concurrent.ListenableFuture<
com.google.pubsub.v1.ValidateMessageResponse>
validateMessage(com.google.pubsub.v1.ValidateMessageRequest request) {
return futureUnaryCall(
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getValidateMessageMethod(), getCallOptions()), request);
}
}
Expand Down
Loading

0 comments on commit 4b98556

Please sign in to comment.