Skip to content

Commit

Permalink
feat: [common-protos] Log Analytics features of the Cloud Logging API (…
Browse files Browse the repository at this point in the history 
…#1573)

- [ ] Regenerate this pull request now.

feat: Add ConfigServiceV2.CreateBucketAsync method for creating Log Buckets asynchronously
feat: Add ConfigServiceV2.UpdateBucketAsync method for creating Log Buckets asynchronously
feat: Add ConfigServiceV2.CreateLink method for creating linked datasets for Log Analytics Buckets
feat: Add ConfigServiceV2.DeleteLink method for deleting linked datasets
feat: Add ConfigServiceV2.ListLinks method for listing linked datasets
feat: Add ConfigServiceV2.GetLink methods for describing linked datasets
feat: Add LogBucket.analytics_enabled field that specifies whether Log Bucket's Analytics features are enabled
feat: Add LogBucket.index_configs field that contains a list of Log Bucket's indexed fields and related configuration data
docs: Documentation for the Log Analytics features of the Cloud Logging API

PiperOrigin-RevId: 529851525

Source-Link: https://github.com/googleapis/googleapis/commit/1c7ee99d19adf8e444e2d73c5dd52884eab9862d

Source-Link: https://github.com/googleapis/googleapis-gen/commit/4a2a3a05b91804333a1b39b635d8fe2243d4b4fd
Copy-Tag: eyJwIjoiamF2YS1jb21tb24tcHJvdG9zLy5Pd2xCb3QueWFtbCIsImgiOiI0YTJhM2EwNWI5MTgwNDMzM2ExYjM5YjYzNWQ4ZmUyMjQzZDRiNGZkIn0=

BEGIN_NESTED_COMMIT
feat: [common-protos] add GEO, SHOPPING, GENERATIVE_AI client orgs
docs: fix new_issue_uri comment

PiperOrigin-RevId: 527926860

Source-Link: https://github.com/googleapis/googleapis/commit/2f4668caa329c6dd67c14a5864076a48f0c17841

Source-Link: https://github.com/googleapis/googleapis-gen/commit/fa34096a242426ee1f714dc1249cd28814439e3e
Copy-Tag: eyJwIjoiamF2YS1jb21tb24tcHJvdG9zLy5Pd2xCb3QueWFtbCIsImgiOiJmYTM0MDk2YTI0MjQyNmVlMWY3MTRkYzEyNDljZDI4ODE0NDM5ZTNlIn0=
END_NESTED_COMMIT
BEGIN_NESTED_COMMIT
docs: [common-protos] use deprecated=true for deprecated fields
PiperOrigin-RevId: 521675703

Source-Link: https://github.com/googleapis/googleapis/commit/8bc5a83d9759f2153f2e62d79dc2a024bcf7a3ac

Source-Link: https://github.com/googleapis/googleapis-gen/commit/3a4cf08318827b8ce36d2e6471ca24ae88c0900f
Copy-Tag: eyJwIjoiamF2YS1jb21tb24tcHJvdG9zLy5Pd2xCb3QueWFtbCIsImgiOiIzYTRjZjA4MzE4ODI3YjhjZTM2ZDJlNjQ3MWNhMjRhZTg4YzA5MDBmIn0=
END_NESTED_COMMIT
BEGIN_NESTED_COMMIT
docs: [common-protos] mark ReservationResourceUsage field as deprecated
PiperOrigin-RevId: 521058593

Source-Link: https://github.com/googleapis/googleapis/commit/4c3b682f501bb965d34c3d4fc3461edfccf962db

Source-Link: https://github.com/googleapis/googleapis-gen/commit/9d3275bce3ee4c6b2f6a4529d3cff7e7cdff1ce5
Copy-Tag: eyJwIjoiamF2YS1jb21tb24tcHJvdG9zLy5Pd2xCb3QueWFtbCIsImgiOiI5ZDMyNzViY2UzZWU0YzZiMmY2YTQ1MjlkM2NmZjdlN2NkZmYxY2U1In0=
END_NESTED_COMMIT
BEGIN_NESTED_COMMIT
chore(deps): [common-protos] Update gapic-generator-java to 2.16.0
PiperOrigin-RevId: 520153493

Source-Link: https://github.com/googleapis/googleapis/commit/26a424a2e4190c3103ab6f5d00c3144c89161b20

Source-Link: https://github.com/googleapis/googleapis-gen/commit/78f1567661df07bea7425e4341012e7b77c11254
Copy-Tag: eyJwIjoiamF2YS1jb21tb24tcHJvdG9zLy5Pd2xCb3QueWFtbCIsImgiOiI3OGYxNTY3NjYxZGYwN2JlYTc0MjVlNDM0MTAxMmU3Yjc3YzExMjU0In0=
END_NESTED_COMMIT
BEGIN_NESTED_COMMIT
feat: [common-protos] .NET library settings (for generator behavior tweaks)
docs: separate paragraphs in linear/exponential distributions

PiperOrigin-RevId: 520041337

Source-Link: https://github.com/googleapis/googleapis/commit/ed78055479a002e3c8c5f1f12c2e6bed52360428

Source-Link: https://github.com/googleapis/googleapis-gen/commit/a0b9e45d4e9ce213972593f62924242991087209
Copy-Tag: eyJwIjoiamF2YS1jb21tb24tcHJvdG9zLy5Pd2xCb3QueWFtbCIsImgiOiJhMGI5ZTQ1ZDRlOWNlMjEzOTcyNTkzZjYyOTI0MjQyOTkxMDg3MjA5In0=
END_NESTED_COMMIT
  • Loading branch information
@gcf-owl-bot
gcf-owl-bot[bot] authored May 9, 2023
1 parent d2fe520 commit 7479758
Show file tree
Hide file tree
Showing 14 changed files with 2,302 additions and 122 deletions.
62 changes: 39 additions & 23 deletions ...otos/grpc-google-common-protos/src/main/java/com/google/cloud/location/LocationsGrpc.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -171,7 +171,7 @@ public LocationsFutureStub newStub(
* [Location.metadata][google.cloud.location.Location.metadata] field.
* </pre>
*/
public abstract static class LocationsImplBase implements io.grpc.BindableService {
public interface AsyncService {

/**
*
Expand All @@ -180,7 +180,7 @@ public abstract static class LocationsImplBase implements io.grpc.BindableServic
* Lists information about the supported locations for this service.
* </pre>
*/
public void listLocations(
default void listLocations(
com.google.cloud.location.ListLocationsRequest request,
io.grpc.stub.StreamObserver<com.google.cloud.location.ListLocationsResponse>
responseObserver) {
Expand All @@ -195,35 +195,33 @@ public void listLocations(
* Gets information about a location.
* </pre>
*/
public void getLocation(
default void getLocation(
com.google.cloud.location.GetLocationRequest request,
io.grpc.stub.StreamObserver<com.google.cloud.location.Location> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
getGetLocationMethod(), responseObserver);
}
}

/**
* Base class for the server implementation of the service Locations.
*
* <pre>
* An abstract interface that provides location-related information for
* a service. Service-specific metadata is provided through the
* [Location.metadata][google.cloud.location.Location.metadata] field.
* </pre>
*/
public abstract static class LocationsImplBase implements io.grpc.BindableService, AsyncService {

@java.lang.Override
public final io.grpc.ServerServiceDefinition bindService() {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
.addMethod(
getListLocationsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.location.ListLocationsRequest,
com.google.cloud.location.ListLocationsResponse>(
this, METHODID_LIST_LOCATIONS)))
.addMethod(
getGetLocationMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.location.GetLocationRequest,
com.google.cloud.location.Location>(this, METHODID_GET_LOCATION)))
.build();
return LocationsGrpc.bindService(this);
}
}

/**
*
* A stub to allow clients to do asynchronous rpc calls to service Locations.
*
* <pre>
* An abstract interface that provides location-related information for
Expand Down Expand Up @@ -276,7 +274,7 @@ public void getLocation(
}

/**
*
* A stub to allow clients to do synchronous rpc calls to service Locations.
*
* <pre>
* An abstract interface that provides location-related information for
Expand Down Expand Up @@ -324,7 +322,7 @@ public com.google.cloud.location.Location getLocation(
}

/**
*
* A stub to allow clients to do ListenableFuture-style rpc calls to service Locations.
*
* <pre>
* An abstract interface that provides location-related information for
Expand Down Expand Up @@ -379,10 +377,10 @@ private static final class MethodHandlers<Req, Resp>
io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
private final LocationsImplBase serviceImpl;
private final AsyncService serviceImpl;
private final int methodId;

MethodHandlers(LocationsImplBase serviceImpl, int methodId) {
MethodHandlers(AsyncService serviceImpl, int methodId) {
this.serviceImpl = serviceImpl;
this.methodId = methodId;
}
Expand Down Expand Up @@ -418,6 +416,24 @@ public io.grpc.stub.StreamObserver<Req> invoke(
}
}

public static final io.grpc.ServerServiceDefinition bindService(AsyncService service) {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
.addMethod(
getListLocationsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.location.ListLocationsRequest,
com.google.cloud.location.ListLocationsResponse>(
service, METHODID_LIST_LOCATIONS)))
.addMethod(
getGetLocationMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.location.GetLocationRequest,
com.google.cloud.location.Location>(service, METHODID_GET_LOCATION)))
.build();
}

private abstract static class LocationsBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
io.grpc.protobuf.ProtoServiceDescriptorSupplier {
Expand Down
109 changes: 65 additions & 44 deletions ...protos/grpc-google-common-protos/src/main/java/com/google/longrunning/OperationsGrpc.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -304,7 +304,7 @@ public OperationsFutureStub newStub(
* so developers can have a consistent client experience.
* </pre>
*/
public abstract static class OperationsImplBase implements io.grpc.BindableService {
public interface AsyncService {

/**
*
Expand All @@ -321,7 +321,7 @@ public abstract static class OperationsImplBase implements io.grpc.BindableServi
* is the parent resource, without the operations collection id.
* </pre>
*/
public void listOperations(
default void listOperations(
com.google.longrunning.ListOperationsRequest request,
io.grpc.stub.StreamObserver<com.google.longrunning.ListOperationsResponse>
responseObserver) {
Expand All @@ -338,7 +338,7 @@ public void listOperations(
* service.
* </pre>
*/
public void getOperation(
default void getOperation(
com.google.longrunning.GetOperationRequest request,
io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
Expand All @@ -355,7 +355,7 @@ public void getOperation(
* `google.rpc.Code.UNIMPLEMENTED`.
* </pre>
*/
public void deleteOperation(
default void deleteOperation(
com.google.longrunning.DeleteOperationRequest request,
io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
Expand All @@ -378,7 +378,7 @@ public void deleteOperation(
* corresponding to `Code.CANCELLED`.
* </pre>
*/
public void cancelOperation(
default void cancelOperation(
com.google.longrunning.CancelOperationRequest request,
io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
Expand All @@ -400,53 +400,38 @@ public void cancelOperation(
* immediate response is no guarantee that the operation is done.
* </pre>
*/
public void waitOperation(
default void waitOperation(
com.google.longrunning.WaitOperationRequest request,
io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
getWaitOperationMethod(), responseObserver);
}
}

/**
* Base class for the server implementation of the service Operations.
*
* <pre>
* Manages long-running operations with an API service.
* When an API method normally takes long time to complete, it can be designed
* to return [Operation][google.longrunning.Operation] to the client, and the client can use this
* interface to receive the real response asynchronously by polling the
* operation resource, or pass the operation resource to another API (such as
* Google Cloud Pub/Sub API) to receive the response. Any API service that
* returns long-running operations should implement the `Operations` interface
* so developers can have a consistent client experience.
* </pre>
*/
public abstract static class OperationsImplBase implements io.grpc.BindableService, AsyncService {

@java.lang.Override
public final io.grpc.ServerServiceDefinition bindService() {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
.addMethod(
getListOperationsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.longrunning.ListOperationsRequest,
com.google.longrunning.ListOperationsResponse>(
this, METHODID_LIST_OPERATIONS)))
.addMethod(
getGetOperationMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.longrunning.GetOperationRequest, com.google.longrunning.Operation>(
this, METHODID_GET_OPERATION)))
.addMethod(
getDeleteOperationMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.longrunning.DeleteOperationRequest, com.google.protobuf.Empty>(
this, METHODID_DELETE_OPERATION)))
.addMethod(
getCancelOperationMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.longrunning.CancelOperationRequest, com.google.protobuf.Empty>(
this, METHODID_CANCEL_OPERATION)))
.addMethod(
getWaitOperationMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.longrunning.WaitOperationRequest,
com.google.longrunning.Operation>(this, METHODID_WAIT_OPERATION)))
.build();
return OperationsGrpc.bindService(this);
}
}

/**
*
* A stub to allow clients to do asynchronous rpc calls to service Operations.
*
* <pre>
* Manages long-running operations with an API service.
Expand Down Expand Up @@ -582,7 +567,7 @@ public void waitOperation(
}

/**
*
* A stub to allow clients to do synchronous rpc calls to service Operations.
*
* <pre>
* Manages long-running operations with an API service.
Expand Down Expand Up @@ -704,7 +689,7 @@ public com.google.longrunning.Operation waitOperation(
}

/**
*
* A stub to allow clients to do ListenableFuture-style rpc calls to service Operations.
*
* <pre>
* Manages long-running operations with an API service.
Expand Down Expand Up @@ -836,10 +821,10 @@ private static final class MethodHandlers<Req, Resp>
io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
private final OperationsImplBase serviceImpl;
private final AsyncService serviceImpl;
private final int methodId;

MethodHandlers(OperationsImplBase serviceImpl, int methodId) {
MethodHandlers(AsyncService serviceImpl, int methodId) {
this.serviceImpl = serviceImpl;
this.methodId = methodId;
}
Expand Down Expand Up @@ -890,6 +875,42 @@ public io.grpc.stub.StreamObserver<Req> invoke(
}
}

public static final io.grpc.ServerServiceDefinition bindService(AsyncService service) {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
.addMethod(
getListOperationsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.longrunning.ListOperationsRequest,
com.google.longrunning.ListOperationsResponse>(
service, METHODID_LIST_OPERATIONS)))
.addMethod(
getGetOperationMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.longrunning.GetOperationRequest, com.google.longrunning.Operation>(
service, METHODID_GET_OPERATION)))
.addMethod(
getDeleteOperationMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.longrunning.DeleteOperationRequest, com.google.protobuf.Empty>(
service, METHODID_DELETE_OPERATION)))
.addMethod(
getCancelOperationMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.longrunning.CancelOperationRequest, com.google.protobuf.Empty>(
service, METHODID_CANCEL_OPERATION)))
.addMethod(
getWaitOperationMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.longrunning.WaitOperationRequest, com.google.longrunning.Operation>(
service, METHODID_WAIT_OPERATION)))
.build();
}

private abstract static class OperationsBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
io.grpc.protobuf.ProtoServiceDescriptorSupplier {
Expand Down
Loading

0 comments on commit 7479758

Please sign in to comment.