@@ -139,6 +139,37 @@ io.weaviate.client.grpc.protocol.v1.WeaviateProtoTenants.TenantsGetReply> getTen
139139 return getTenantsGetMethod ;
140140 }
141141
142+ private static volatile io .grpc .MethodDescriptor <io .weaviate .client .grpc .protocol .v1 .WeaviateProtoAggregate .AggregateRequest ,
143+ io .weaviate .client .grpc .protocol .v1 .WeaviateProtoAggregate .AggregateReply > getAggregateMethod ;
144+
145+ @ io .grpc .stub .annotations .RpcMethod (
146+ fullMethodName = SERVICE_NAME + '/' + "Aggregate" ,
147+ requestType = io .weaviate .client .grpc .protocol .v1 .WeaviateProtoAggregate .AggregateRequest .class ,
148+ responseType = io .weaviate .client .grpc .protocol .v1 .WeaviateProtoAggregate .AggregateReply .class ,
149+ methodType = io .grpc .MethodDescriptor .MethodType .UNARY )
150+ public static io .grpc .MethodDescriptor <io .weaviate .client .grpc .protocol .v1 .WeaviateProtoAggregate .AggregateRequest ,
151+ io .weaviate .client .grpc .protocol .v1 .WeaviateProtoAggregate .AggregateReply > getAggregateMethod () {
152+ io .grpc .MethodDescriptor <io .weaviate .client .grpc .protocol .v1 .WeaviateProtoAggregate .AggregateRequest , io .weaviate .client .grpc .protocol .v1 .WeaviateProtoAggregate .AggregateReply > getAggregateMethod ;
153+ if ((getAggregateMethod = WeaviateGrpc .getAggregateMethod ) == null ) {
154+ synchronized (WeaviateGrpc .class ) {
155+ if ((getAggregateMethod = WeaviateGrpc .getAggregateMethod ) == null ) {
156+ WeaviateGrpc .getAggregateMethod = getAggregateMethod =
157+ io .grpc .MethodDescriptor .<io .weaviate .client .grpc .protocol .v1 .WeaviateProtoAggregate .AggregateRequest , io .weaviate .client .grpc .protocol .v1 .WeaviateProtoAggregate .AggregateReply >newBuilder ()
158+ .setType (io .grpc .MethodDescriptor .MethodType .UNARY )
159+ .setFullMethodName (generateFullMethodName (SERVICE_NAME , "Aggregate" ))
160+ .setSampledToLocalTracing (true )
161+ .setRequestMarshaller (io .grpc .protobuf .ProtoUtils .marshaller (
162+ io .weaviate .client .grpc .protocol .v1 .WeaviateProtoAggregate .AggregateRequest .getDefaultInstance ()))
163+ .setResponseMarshaller (io .grpc .protobuf .ProtoUtils .marshaller (
164+ io .weaviate .client .grpc .protocol .v1 .WeaviateProtoAggregate .AggregateReply .getDefaultInstance ()))
165+ .setSchemaDescriptor (new WeaviateMethodDescriptorSupplier ("Aggregate" ))
166+ .build ();
167+ }
168+ }
169+ }
170+ return getAggregateMethod ;
171+ }
172+
142173 /**
143174 * Creates a new async stub that supports all call types for the service
144175 */
@@ -214,6 +245,13 @@ default void tenantsGet(io.weaviate.client.grpc.protocol.v1.WeaviateProtoTenants
214245 io .grpc .stub .StreamObserver <io .weaviate .client .grpc .protocol .v1 .WeaviateProtoTenants .TenantsGetReply > responseObserver ) {
215246 io .grpc .stub .ServerCalls .asyncUnimplementedUnaryCall (getTenantsGetMethod (), responseObserver );
216247 }
248+
249+ /**
250+ */
251+ default void aggregate (io .weaviate .client .grpc .protocol .v1 .WeaviateProtoAggregate .AggregateRequest request ,
252+ io .grpc .stub .StreamObserver <io .weaviate .client .grpc .protocol .v1 .WeaviateProtoAggregate .AggregateReply > responseObserver ) {
253+ io .grpc .stub .ServerCalls .asyncUnimplementedUnaryCall (getAggregateMethod (), responseObserver );
254+ }
217255 }
218256
219257 /**
@@ -274,6 +312,14 @@ public void tenantsGet(io.weaviate.client.grpc.protocol.v1.WeaviateProtoTenants.
274312 io .grpc .stub .ClientCalls .asyncUnaryCall (
275313 getChannel ().newCall (getTenantsGetMethod (), getCallOptions ()), request , responseObserver );
276314 }
315+
316+ /**
317+ */
318+ public void aggregate (io .weaviate .client .grpc .protocol .v1 .WeaviateProtoAggregate .AggregateRequest request ,
319+ io .grpc .stub .StreamObserver <io .weaviate .client .grpc .protocol .v1 .WeaviateProtoAggregate .AggregateReply > responseObserver ) {
320+ io .grpc .stub .ClientCalls .asyncUnaryCall (
321+ getChannel ().newCall (getAggregateMethod (), getCallOptions ()), request , responseObserver );
322+ }
277323 }
278324
279325 /**
@@ -319,6 +365,13 @@ public io.weaviate.client.grpc.protocol.v1.WeaviateProtoTenants.TenantsGetReply
319365 return io .grpc .stub .ClientCalls .blockingUnaryCall (
320366 getChannel (), getTenantsGetMethod (), getCallOptions (), request );
321367 }
368+
369+ /**
370+ */
371+ public io .weaviate .client .grpc .protocol .v1 .WeaviateProtoAggregate .AggregateReply aggregate (io .weaviate .client .grpc .protocol .v1 .WeaviateProtoAggregate .AggregateRequest request ) {
372+ return io .grpc .stub .ClientCalls .blockingUnaryCall (
373+ getChannel (), getAggregateMethod (), getCallOptions (), request );
374+ }
322375 }
323376
324377 /**
@@ -368,12 +421,21 @@ public com.google.common.util.concurrent.ListenableFuture<io.weaviate.client.grp
368421 return io .grpc .stub .ClientCalls .futureUnaryCall (
369422 getChannel ().newCall (getTenantsGetMethod (), getCallOptions ()), request );
370423 }
424+
425+ /**
426+ */
427+ public com .google .common .util .concurrent .ListenableFuture <io .weaviate .client .grpc .protocol .v1 .WeaviateProtoAggregate .AggregateReply > aggregate (
428+ io .weaviate .client .grpc .protocol .v1 .WeaviateProtoAggregate .AggregateRequest request ) {
429+ return io .grpc .stub .ClientCalls .futureUnaryCall (
430+ getChannel ().newCall (getAggregateMethod (), getCallOptions ()), request );
431+ }
371432 }
372433
373434 private static final int METHODID_SEARCH = 0 ;
374435 private static final int METHODID_BATCH_OBJECTS = 1 ;
375436 private static final int METHODID_BATCH_DELETE = 2 ;
376437 private static final int METHODID_TENANTS_GET = 3 ;
438+ private static final int METHODID_AGGREGATE = 4 ;
377439
378440 private static final class MethodHandlers <Req , Resp > implements
379441 io .grpc .stub .ServerCalls .UnaryMethod <Req , Resp >,
@@ -408,6 +470,10 @@ public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserv
408470 serviceImpl .tenantsGet ((io .weaviate .client .grpc .protocol .v1 .WeaviateProtoTenants .TenantsGetRequest ) request ,
409471 (io .grpc .stub .StreamObserver <io .weaviate .client .grpc .protocol .v1 .WeaviateProtoTenants .TenantsGetReply >) responseObserver );
410472 break ;
473+ case METHODID_AGGREGATE :
474+ serviceImpl .aggregate ((io .weaviate .client .grpc .protocol .v1 .WeaviateProtoAggregate .AggregateRequest ) request ,
475+ (io .grpc .stub .StreamObserver <io .weaviate .client .grpc .protocol .v1 .WeaviateProtoAggregate .AggregateReply >) responseObserver );
476+ break ;
411477 default :
412478 throw new AssertionError ();
413479 }
@@ -454,6 +520,13 @@ public static final io.grpc.ServerServiceDefinition bindService(AsyncService ser
454520 io .weaviate .client .grpc .protocol .v1 .WeaviateProtoTenants .TenantsGetRequest ,
455521 io .weaviate .client .grpc .protocol .v1 .WeaviateProtoTenants .TenantsGetReply >(
456522 service , METHODID_TENANTS_GET )))
523+ .addMethod (
524+ getAggregateMethod (),
525+ io .grpc .stub .ServerCalls .asyncUnaryCall (
526+ new MethodHandlers <
527+ io .weaviate .client .grpc .protocol .v1 .WeaviateProtoAggregate .AggregateRequest ,
528+ io .weaviate .client .grpc .protocol .v1 .WeaviateProtoAggregate .AggregateReply >(
529+ service , METHODID_AGGREGATE )))
457530 .build ();
458531 }
459532
@@ -506,6 +579,7 @@ public static io.grpc.ServiceDescriptor getServiceDescriptor() {
506579 .addMethod (getBatchObjectsMethod ())
507580 .addMethod (getBatchDeleteMethod ())
508581 .addMethod (getTenantsGetMethod ())
582+ .addMethod (getAggregateMethod ())
509583 .build ();
510584 }
511585 }
0 commit comments