Skip to content

Commit

Permalink
Backport to branch(3.9) : Bump com.azure:azure-cosmos from 4.44.0 to …
Browse files Browse the repository at this point in the history 
…4.53.1 (#1405)

Signed-off-by: dependabot[bot] <[email protected]>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
  • Loading branch information
@brfrn169 @dependabot
brfrn169 and dependabot[bot] authored Dec 21, 2023
1 parent 17824c5 commit a5d289f
Show file tree
Hide file tree
Showing 6 changed files with 467 additions and 382 deletions.
4 changes: 2 additions & 2 deletions build.gradle
View file
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ subprojects {
guavaVersion = '32.1.1-jre'
slf4jVersion = '1.7.36'
cassandraDriverVersion = '3.11.3'
azureCosmosVersion = '4.44.0'
azureCosmosVersion = '4.53.1'
jooqVersion = '3.14.16'
awssdkVersion = '2.20.54'
commonsDbcp2Version = '2.9.0'
Expand All @@ -33,7 +33,7 @@ subprojects {
oracleDriverVersion = '21.9.0.0'
sqlserverDriverVersion = '11.2.3.jre8'
sqliteDriverVersion = '3.42.0.0'
grpcVersion = '1.53.0'
grpcVersion = '1.60.0'
protobufVersion = '3.21.12'
annotationVersion = '1.3.2'
picocliVersion = '4.7.3'
Expand Down
233 changes: 125 additions & 108 deletions rpc/src/main/grpc/com/scalar/db/rpc/DistributedStorageAdminGrpc.java
View file
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

0 comments on commit a5d289f

Please sign in to comment.