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.

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

docs: Remove experimental note for schema APIs #560

Merged
merged 2 commits into from Mar 15, 2021
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.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
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
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.

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