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

Backport to branch(3.8) : Bump com.azure:azure-cosmos from 4.39.0 to 4.53.1 #1406

Merged
merged 1 commit into from
Dec 21, 2023
Merged

Backport to branch(3.8) : Bump com.azure:azure-cosmos from 4.39.0 to 4.53.1 #1406

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
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
4 changes: 2 additions & 2 deletions build.gradle
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -24,15 +24,15 @@ subprojects {
guavaVersion = '32.1.1-jre'
slf4jVersion = '1.7.30'
cassandraDriverVersion = '3.6.0'
azureCosmosVersion = '4.39.0'
azureCosmosVersion = '4.53.1'
jooqVersion = '3.13.2'
awssdkVersion = '2.19.16'
commonsDbcp2Version = '2.8.0'
mysqlDriverVersion = '8.0.31'
postgresqlDriverVersion = '42.5.1'
oracleDriverVersion = '19.8.0.0'
sqlserverDriverVersion = '8.4.1.jre8'
grpcVersion = '1.53.0'
grpcVersion = '1.60.0'
protobufVersion = '3.21.12'
annotationVersion = '1.3.2'
picocliVersion = '4.1.4'
Expand Down
233 changes: 125 additions & 108 deletions rpc/src/main/grpc/com/scalar/db/rpc/DistributedStorageAdminGrpc.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -5,14 +5,14 @@
/**
*/
@javax.annotation.Generated(
value = "by gRPC proto compiler (version 1.53.0)",
value = "by gRPC proto compiler (version 1.60.0)",
comments = "Source: scalardb.proto")
@io.grpc.stub.annotations.GrpcGenerated
public final class DistributedStorageAdminGrpc {

private DistributedStorageAdminGrpc() {}

public static final String SERVICE_NAME = "rpc.DistributedStorageAdmin";
public static final java.lang.String SERVICE_NAME = "rpc.DistributedStorageAdmin";

// Static method descriptors that strictly reflect the proto.
private static volatile io.grpc.MethodDescriptor<com.scalar.db.rpc.CreateNamespaceRequest,
Expand Down Expand Up @@ -433,185 +433,109 @@ public DistributedStorageAdminFutureStub newStub(io.grpc.Channel channel, io.grp

/**
*/
public static abstract class DistributedStorageAdminImplBase implements io.grpc.BindableService {
public interface AsyncService {

/**
*/
public void createNamespace(com.scalar.db.rpc.CreateNamespaceRequest request,
default void createNamespace(com.scalar.db.rpc.CreateNamespaceRequest request,
io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getCreateNamespaceMethod(), responseObserver);
}

/**
*/
public void dropNamespace(com.scalar.db.rpc.DropNamespaceRequest request,
default void dropNamespace(com.scalar.db.rpc.DropNamespaceRequest request,
io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getDropNamespaceMethod(), responseObserver);
}

/**
*/
public void createTable(com.scalar.db.rpc.CreateTableRequest request,
default void createTable(com.scalar.db.rpc.CreateTableRequest request,
io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getCreateTableMethod(), responseObserver);
}

/**
*/
public void dropTable(com.scalar.db.rpc.DropTableRequest request,
default void dropTable(com.scalar.db.rpc.DropTableRequest request,
io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getDropTableMethod(), responseObserver);
}

/**
*/
public void truncateTable(com.scalar.db.rpc.TruncateTableRequest request,
default void truncateTable(com.scalar.db.rpc.TruncateTableRequest request,
io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getTruncateTableMethod(), responseObserver);
}

/**
*/
public void createIndex(com.scalar.db.rpc.CreateIndexRequest request,
default void createIndex(com.scalar.db.rpc.CreateIndexRequest request,
io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getCreateIndexMethod(), responseObserver);
}

/**
*/
public void dropIndex(com.scalar.db.rpc.DropIndexRequest request,
default void dropIndex(com.scalar.db.rpc.DropIndexRequest request,
io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getDropIndexMethod(), responseObserver);
}

/**
*/
public void getTableMetadata(com.scalar.db.rpc.GetTableMetadataRequest request,
default void getTableMetadata(com.scalar.db.rpc.GetTableMetadataRequest request,
io.grpc.stub.StreamObserver<com.scalar.db.rpc.GetTableMetadataResponse> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetTableMetadataMethod(), responseObserver);
}

/**
*/
public void getNamespaceTableNames(com.scalar.db.rpc.GetNamespaceTableNamesRequest request,
default void getNamespaceTableNames(com.scalar.db.rpc.GetNamespaceTableNamesRequest request,
io.grpc.stub.StreamObserver<com.scalar.db.rpc.GetNamespaceTableNamesResponse> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetNamespaceTableNamesMethod(), responseObserver);
}

/**
*/
public void namespaceExists(com.scalar.db.rpc.NamespaceExistsRequest request,
default void namespaceExists(com.scalar.db.rpc.NamespaceExistsRequest request,
io.grpc.stub.StreamObserver<com.scalar.db.rpc.NamespaceExistsResponse> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getNamespaceExistsMethod(), responseObserver);
}

/**
*/
public void repairTable(com.scalar.db.rpc.RepairTableRequest request,
default void repairTable(com.scalar.db.rpc.RepairTableRequest request,
io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getRepairTableMethod(), responseObserver);
}

/**
*/
public void addNewColumnToTable(com.scalar.db.rpc.AddNewColumnToTableRequest request,
default void addNewColumnToTable(com.scalar.db.rpc.AddNewColumnToTableRequest request,
io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getAddNewColumnToTableMethod(), responseObserver);
}
}

/**
* Base class for the server implementation of the service DistributedStorageAdmin.
*/
public static abstract class DistributedStorageAdminImplBase
implements io.grpc.BindableService, AsyncService {

@java.lang.Override public final io.grpc.ServerServiceDefinition bindService() {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
.addMethod(
getCreateNamespaceMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.scalar.db.rpc.CreateNamespaceRequest,
com.google.protobuf.Empty>(
this, METHODID_CREATE_NAMESPACE)))
.addMethod(
getDropNamespaceMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.scalar.db.rpc.DropNamespaceRequest,
com.google.protobuf.Empty>(
this, METHODID_DROP_NAMESPACE)))
.addMethod(
getCreateTableMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.scalar.db.rpc.CreateTableRequest,
com.google.protobuf.Empty>(
this, METHODID_CREATE_TABLE)))
.addMethod(
getDropTableMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.scalar.db.rpc.DropTableRequest,
com.google.protobuf.Empty>(
this, METHODID_DROP_TABLE)))
.addMethod(
getTruncateTableMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.scalar.db.rpc.TruncateTableRequest,
com.google.protobuf.Empty>(
this, METHODID_TRUNCATE_TABLE)))
.addMethod(
getCreateIndexMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.scalar.db.rpc.CreateIndexRequest,
com.google.protobuf.Empty>(
this, METHODID_CREATE_INDEX)))
.addMethod(
getDropIndexMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.scalar.db.rpc.DropIndexRequest,
com.google.protobuf.Empty>(
this, METHODID_DROP_INDEX)))
.addMethod(
getGetTableMetadataMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.scalar.db.rpc.GetTableMetadataRequest,
com.scalar.db.rpc.GetTableMetadataResponse>(
this, METHODID_GET_TABLE_METADATA)))
.addMethod(
getGetNamespaceTableNamesMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.scalar.db.rpc.GetNamespaceTableNamesRequest,
com.scalar.db.rpc.GetNamespaceTableNamesResponse>(
this, METHODID_GET_NAMESPACE_TABLE_NAMES)))
.addMethod(
getNamespaceExistsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.scalar.db.rpc.NamespaceExistsRequest,
com.scalar.db.rpc.NamespaceExistsResponse>(
this, METHODID_NAMESPACE_EXISTS)))
.addMethod(
getRepairTableMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.scalar.db.rpc.RepairTableRequest,
com.google.protobuf.Empty>(
this, METHODID_REPAIR_TABLE)))
.addMethod(
getAddNewColumnToTableMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.scalar.db.rpc.AddNewColumnToTableRequest,
com.google.protobuf.Empty>(
this, METHODID_ADD_NEW_COLUMN_TO_TABLE)))
.build();
return DistributedStorageAdminGrpc.bindService(this);
}
}

/**
* A stub to allow clients to do asynchronous rpc calls to service DistributedStorageAdmin.
*/
public static final class DistributedStorageAdminStub extends io.grpc.stub.AbstractAsyncStub<DistributedStorageAdminStub> {
public static final class DistributedStorageAdminStub
extends io.grpc.stub.AbstractAsyncStub<DistributedStorageAdminStub> {
private DistributedStorageAdminStub(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
Expand Down Expand Up @@ -721,8 +645,10 @@ public void addNewColumnToTable(com.scalar.db.rpc.AddNewColumnToTableRequest req
}

/**
* A stub to allow clients to do synchronous rpc calls to service DistributedStorageAdmin.
*/
public static final class DistributedStorageAdminBlockingStub extends io.grpc.stub.AbstractBlockingStub<DistributedStorageAdminBlockingStub> {
public static final class DistributedStorageAdminBlockingStub
extends io.grpc.stub.AbstractBlockingStub<DistributedStorageAdminBlockingStub> {
private DistributedStorageAdminBlockingStub(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
Expand Down Expand Up @@ -820,8 +746,10 @@ public com.google.protobuf.Empty addNewColumnToTable(com.scalar.db.rpc.AddNewCol
}

/**
* A stub to allow clients to do ListenableFuture-style rpc calls to service DistributedStorageAdmin.
*/
public static final class DistributedStorageAdminFutureStub extends io.grpc.stub.AbstractFutureStub<DistributedStorageAdminFutureStub> {
public static final class DistributedStorageAdminFutureStub
extends io.grpc.stub.AbstractFutureStub<DistributedStorageAdminFutureStub> {
private DistributedStorageAdminFutureStub(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
Expand Down Expand Up @@ -948,10 +876,10 @@ private static final class MethodHandlers<Req, Resp> implements
io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
private final DistributedStorageAdminImplBase serviceImpl;
private final AsyncService serviceImpl;
private final int methodId;

MethodHandlers(DistributedStorageAdminImplBase serviceImpl, int methodId) {
MethodHandlers(AsyncService serviceImpl, int methodId) {
this.serviceImpl = serviceImpl;
this.methodId = methodId;
}
Expand Down Expand Up @@ -1024,6 +952,95 @@ public io.grpc.stub.StreamObserver<Req> invoke(
}
}

public static final io.grpc.ServerServiceDefinition bindService(AsyncService service) {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
.addMethod(
getCreateNamespaceMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.scalar.db.rpc.CreateNamespaceRequest,
com.google.protobuf.Empty>(
service, METHODID_CREATE_NAMESPACE)))
.addMethod(
getDropNamespaceMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.scalar.db.rpc.DropNamespaceRequest,
com.google.protobuf.Empty>(
service, METHODID_DROP_NAMESPACE)))
.addMethod(
getCreateTableMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.scalar.db.rpc.CreateTableRequest,
com.google.protobuf.Empty>(
service, METHODID_CREATE_TABLE)))
.addMethod(
getDropTableMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.scalar.db.rpc.DropTableRequest,
com.google.protobuf.Empty>(
service, METHODID_DROP_TABLE)))
.addMethod(
getTruncateTableMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.scalar.db.rpc.TruncateTableRequest,
com.google.protobuf.Empty>(
service, METHODID_TRUNCATE_TABLE)))
.addMethod(
getCreateIndexMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.scalar.db.rpc.CreateIndexRequest,
com.google.protobuf.Empty>(
service, METHODID_CREATE_INDEX)))
.addMethod(
getDropIndexMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.scalar.db.rpc.DropIndexRequest,
com.google.protobuf.Empty>(
service, METHODID_DROP_INDEX)))
.addMethod(
getGetTableMetadataMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.scalar.db.rpc.GetTableMetadataRequest,
com.scalar.db.rpc.GetTableMetadataResponse>(
service, METHODID_GET_TABLE_METADATA)))
.addMethod(
getGetNamespaceTableNamesMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.scalar.db.rpc.GetNamespaceTableNamesRequest,
com.scalar.db.rpc.GetNamespaceTableNamesResponse>(
service, METHODID_GET_NAMESPACE_TABLE_NAMES)))
.addMethod(
getNamespaceExistsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.scalar.db.rpc.NamespaceExistsRequest,
com.scalar.db.rpc.NamespaceExistsResponse>(
service, METHODID_NAMESPACE_EXISTS)))
.addMethod(
getRepairTableMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.scalar.db.rpc.RepairTableRequest,
com.google.protobuf.Empty>(
service, METHODID_REPAIR_TABLE)))
.addMethod(
getAddNewColumnToTableMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.scalar.db.rpc.AddNewColumnToTableRequest,
com.google.protobuf.Empty>(
service, METHODID_ADD_NEW_COLUMN_TO_TABLE)))
.build();
}

private static abstract class DistributedStorageAdminBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoFileDescriptorSupplier, io.grpc.protobuf.ProtoServiceDescriptorSupplier {
DistributedStorageAdminBaseDescriptorSupplier() {}
Expand All @@ -1047,9 +1064,9 @@ private static final class DistributedStorageAdminFileDescriptorSupplier
private static final class DistributedStorageAdminMethodDescriptorSupplier
extends DistributedStorageAdminBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
private final String methodName;
private final java.lang.String methodName;

DistributedStorageAdminMethodDescriptorSupplier(String methodName) {
DistributedStorageAdminMethodDescriptorSupplier(java.lang.String methodName) {
this.methodName = methodName;
}

Expand Down
Loading