Skip to content

Commit df1e2e1

Browse files
cq-botcq-bot
authored
fix: Generate Java Code from plugin-pb (#80)
This PR was created by a scheduled workflow to regenerate the Java code from `plugin-pb`.
1 parent 2cbf8f3 commit df1e2e1

File tree

6 files changed

+1685
-93
lines changed

6 files changed

+1685
-93
lines changed

‎build/generated/source/proto/main/grpc/io/cloudquery/plugin/v3/PluginGrpc.java‎

Lines changed: 100 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -77,6 +77,37 @@ io.cloudquery.plugin.v3.GetVersion.Response> getGetVersionMethod() {
7777
return getGetVersionMethod;
7878
}
7979

80+
private static volatile io.grpc.MethodDescriptor<io.cloudquery.plugin.v3.GetSpecSchema.Request,
81+
io.cloudquery.plugin.v3.GetSpecSchema.Response> getGetSpecSchemaMethod;
82+
83+
@io.grpc.stub.annotations.RpcMethod(
84+
fullMethodName = SERVICE_NAME + '/' + "GetSpecSchema",
85+
requestType = io.cloudquery.plugin.v3.GetSpecSchema.Request.class,
86+
responseType = io.cloudquery.plugin.v3.GetSpecSchema.Response.class,
87+
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
88+
public static io.grpc.MethodDescriptor<io.cloudquery.plugin.v3.GetSpecSchema.Request,
89+
io.cloudquery.plugin.v3.GetSpecSchema.Response> getGetSpecSchemaMethod() {
90+
io.grpc.MethodDescriptor<io.cloudquery.plugin.v3.GetSpecSchema.Request, io.cloudquery.plugin.v3.GetSpecSchema.Response> getGetSpecSchemaMethod;
91+
if ((getGetSpecSchemaMethod = PluginGrpc.getGetSpecSchemaMethod) == null) {
92+
synchronized (PluginGrpc.class) {
93+
if ((getGetSpecSchemaMethod = PluginGrpc.getGetSpecSchemaMethod) == null) {
94+
PluginGrpc.getGetSpecSchemaMethod = getGetSpecSchemaMethod =
95+
io.grpc.MethodDescriptor.<io.cloudquery.plugin.v3.GetSpecSchema.Request, io.cloudquery.plugin.v3.GetSpecSchema.Response>newBuilder()
96+
.setType(io.grpc.MethodDescriptor.MethodType.UNARY)
97+
.setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetSpecSchema"))
98+
.setSampledToLocalTracing(true)
99+
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
100+
io.cloudquery.plugin.v3.GetSpecSchema.Request.getDefaultInstance()))
101+
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
102+
io.cloudquery.plugin.v3.GetSpecSchema.Response.getDefaultInstance()))
103+
.setSchemaDescriptor(new PluginMethodDescriptorSupplier("GetSpecSchema"))
104+
.build();
105+
}
106+
}
107+
}
108+
return getGetSpecSchemaMethod;
109+
}
110+
80111
private static volatile io.grpc.MethodDescriptor<io.cloudquery.plugin.v3.Init.Request,
81112
io.cloudquery.plugin.v3.Init.Response> getInitMethod;
82113

@@ -331,6 +362,18 @@ default void getVersion(io.cloudquery.plugin.v3.GetVersion.Request request,
331362
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetVersionMethod(), responseObserver);
332363
}
333364

365+
/**
366+
* <pre>
367+
* Get plugin spec schema.
368+
* This will allow validating the input even before calling Init.
369+
* Should be called before Init.
370+
* </pre>
371+
*/
372+
default void getSpecSchema(io.cloudquery.plugin.v3.GetSpecSchema.Request request,
373+
io.grpc.stub.StreamObserver<io.cloudquery.plugin.v3.GetSpecSchema.Response> responseObserver) {
374+
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetSpecSchemaMethod(), responseObserver);
375+
}
376+
334377
/**
335378
* <pre>
336379
* Configure the plugin with the given credentials and mode
@@ -442,6 +485,19 @@ public void getVersion(io.cloudquery.plugin.v3.GetVersion.Request request,
442485
getChannel().newCall(getGetVersionMethod(), getCallOptions()), request, responseObserver);
443486
}
444487

488+
/**
489+
* <pre>
490+
* Get plugin spec schema.
491+
* This will allow validating the input even before calling Init.
492+
* Should be called before Init.
493+
* </pre>
494+
*/
495+
public void getSpecSchema(io.cloudquery.plugin.v3.GetSpecSchema.Request request,
496+
io.grpc.stub.StreamObserver<io.cloudquery.plugin.v3.GetSpecSchema.Response> responseObserver) {
497+
io.grpc.stub.ClientCalls.asyncUnaryCall(
498+
getChannel().newCall(getGetSpecSchemaMethod(), getCallOptions()), request, responseObserver);
499+
}
500+
445501
/**
446502
* <pre>
447503
* Configure the plugin with the given credentials and mode
@@ -546,6 +602,18 @@ public io.cloudquery.plugin.v3.GetVersion.Response getVersion(io.cloudquery.plug
546602
getChannel(), getGetVersionMethod(), getCallOptions(), request);
547603
}
548604

605+
/**
606+
* <pre>
607+
* Get plugin spec schema.
608+
* This will allow validating the input even before calling Init.
609+
* Should be called before Init.
610+
* </pre>
611+
*/
612+
public io.cloudquery.plugin.v3.GetSpecSchema.Response getSpecSchema(io.cloudquery.plugin.v3.GetSpecSchema.Request request) {
613+
return io.grpc.stub.ClientCalls.blockingUnaryCall(
614+
getChannel(), getGetSpecSchemaMethod(), getCallOptions(), request);
615+
}
616+
549617
/**
550618
* <pre>
551619
* Configure the plugin with the given credentials and mode
@@ -638,6 +706,19 @@ public com.google.common.util.concurrent.ListenableFuture<io.cloudquery.plugin.v
638706
getChannel().newCall(getGetVersionMethod(), getCallOptions()), request);
639707
}
640708

709+
/**
710+
* <pre>
711+
* Get plugin spec schema.
712+
* This will allow validating the input even before calling Init.
713+
* Should be called before Init.
714+
* </pre>
715+
*/
716+
public com.google.common.util.concurrent.ListenableFuture<io.cloudquery.plugin.v3.GetSpecSchema.Response> getSpecSchema(
717+
io.cloudquery.plugin.v3.GetSpecSchema.Request request) {
718+
return io.grpc.stub.ClientCalls.futureUnaryCall(
719+
getChannel().newCall(getGetSpecSchemaMethod(), getCallOptions()), request);
720+
}
721+
641722
/**
642723
* <pre>
643724
* Configure the plugin with the given credentials and mode
@@ -674,12 +755,13 @@ public com.google.common.util.concurrent.ListenableFuture<io.cloudquery.plugin.v
674755

675756
private static final int METHODID_GET_NAME = 0;
676757
private static final int METHODID_GET_VERSION = 1;
677-
private static final int METHODID_INIT = 2;
678-
private static final int METHODID_GET_TABLES = 3;
679-
private static final int METHODID_SYNC = 4;
680-
private static final int METHODID_READ = 5;
681-
private static final int METHODID_CLOSE = 6;
682-
private static final int METHODID_WRITE = 7;
758+
private static final int METHODID_GET_SPEC_SCHEMA = 2;
759+
private static final int METHODID_INIT = 3;
760+
private static final int METHODID_GET_TABLES = 4;
761+
private static final int METHODID_SYNC = 5;
762+
private static final int METHODID_READ = 6;
763+
private static final int METHODID_CLOSE = 7;
764+
private static final int METHODID_WRITE = 8;
683765

684766
private static final class MethodHandlers<Req, Resp> implements
685767
io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
@@ -706,6 +788,10 @@ public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserv
706788
serviceImpl.getVersion((io.cloudquery.plugin.v3.GetVersion.Request) request,
707789
(io.grpc.stub.StreamObserver<io.cloudquery.plugin.v3.GetVersion.Response>) responseObserver);
708790
break;
791+
case METHODID_GET_SPEC_SCHEMA:
792+
serviceImpl.getSpecSchema((io.cloudquery.plugin.v3.GetSpecSchema.Request) request,
793+
(io.grpc.stub.StreamObserver<io.cloudquery.plugin.v3.GetSpecSchema.Response>) responseObserver);
794+
break;
709795
case METHODID_INIT:
710796
serviceImpl.init((io.cloudquery.plugin.v3.Init.Request) request,
711797
(io.grpc.stub.StreamObserver<io.cloudquery.plugin.v3.Init.Response>) responseObserver);
@@ -761,6 +847,13 @@ public static final io.grpc.ServerServiceDefinition bindService(AsyncService ser
761847
io.cloudquery.plugin.v3.GetVersion.Request,
762848
io.cloudquery.plugin.v3.GetVersion.Response>(
763849
service, METHODID_GET_VERSION)))
850+
.addMethod(
851+
getGetSpecSchemaMethod(),
852+
io.grpc.stub.ServerCalls.asyncUnaryCall(
853+
new MethodHandlers<
854+
io.cloudquery.plugin.v3.GetSpecSchema.Request,
855+
io.cloudquery.plugin.v3.GetSpecSchema.Response>(
856+
service, METHODID_GET_SPEC_SCHEMA)))
764857
.addMethod(
765858
getInitMethod(),
766859
io.grpc.stub.ServerCalls.asyncUnaryCall(
@@ -853,6 +946,7 @@ public static io.grpc.ServiceDescriptor getServiceDescriptor() {
853946
.setSchemaDescriptor(new PluginFileDescriptorSupplier())
854947
.addMethod(getGetNameMethod())
855948
.addMethod(getGetVersionMethod())
949+
.addMethod(getGetSpecSchemaMethod())
856950
.addMethod(getInitMethod())
857951
.addMethod(getGetTablesMethod())
858952
.addMethod(getSyncMethod())

0 commit comments

Comments
 (0)