{
private AssetServiceBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected AssetServiceBlockingStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new AssetServiceBlockingStub(channel, callOptions);
}
/**
*
*
*
* Exports assets with time and resource types to a given Cloud Storage
* location/BigQuery table. For Cloud Storage location destinations, the
* output format is newline-delimited JSON. Each line represents a
* [google.cloud.asset.v1.Asset][google.cloud.asset.v1.Asset] in the JSON
* format; for BigQuery table destinations, the output table stores the fields
* in asset Protobuf as columns. This API implements the
* [google.longrunning.Operation][google.longrunning.Operation] API, which
* allows you to keep track of the export. We recommend intervals of at least
* 2 seconds with exponential retry to poll the export operation result. For
* regular-size resource parent, the export operation usually finishes within
* 5 minutes.
*
*/
public com.google.longrunning.Operation exportAssets(
com.google.cloud.asset.v1.ExportAssetsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getExportAssetsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists assets with time and resource types and returns paged results in
* response.
*
*/
public com.google.cloud.asset.v1.ListAssetsResponse listAssets(
com.google.cloud.asset.v1.ListAssetsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListAssetsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Batch gets the update history of assets that overlap a time window.
* For IAM_POLICY content, this API outputs history when the asset and its
* attached IAM POLICY both exist. This can create gaps in the output history.
* Otherwise, this API outputs history with asset in both non-delete or
* deleted status.
* If a specified asset does not exist, this API returns an INVALID_ARGUMENT
* error.
*
*/
public com.google.cloud.asset.v1.BatchGetAssetsHistoryResponse batchGetAssetsHistory(
com.google.cloud.asset.v1.BatchGetAssetsHistoryRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getBatchGetAssetsHistoryMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates a feed in a parent project/folder/organization to listen to its
* asset updates.
*
*/
public com.google.cloud.asset.v1.Feed createFeed(
com.google.cloud.asset.v1.CreateFeedRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateFeedMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets details about an asset feed.
*
*/
public com.google.cloud.asset.v1.Feed getFeed(
com.google.cloud.asset.v1.GetFeedRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetFeedMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists all asset feeds in a parent project/folder/organization.
*
*/
public com.google.cloud.asset.v1.ListFeedsResponse listFeeds(
com.google.cloud.asset.v1.ListFeedsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListFeedsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates an asset feed configuration.
*
*/
public com.google.cloud.asset.v1.Feed updateFeed(
com.google.cloud.asset.v1.UpdateFeedRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateFeedMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes an asset feed.
*
*/
public com.google.protobuf.Empty deleteFeed(
com.google.cloud.asset.v1.DeleteFeedRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteFeedMethod(), getCallOptions(), request);
}
/**
*
*
*
* Searches all Google Cloud resources within the specified scope, such as a
* project, folder, or organization. The caller must be granted the
* `cloudasset.assets.searchAllResources` permission on the desired scope,
* otherwise the request will be rejected.
*
*/
public com.google.cloud.asset.v1.SearchAllResourcesResponse searchAllResources(
com.google.cloud.asset.v1.SearchAllResourcesRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getSearchAllResourcesMethod(), getCallOptions(), request);
}
/**
*
*
*
* Searches all IAM policies within the specified scope, such as a project,
* folder, or organization. The caller must be granted the
* `cloudasset.assets.searchAllIamPolicies` permission on the desired scope,
* otherwise the request will be rejected.
*
*/
public com.google.cloud.asset.v1.SearchAllIamPoliciesResponse searchAllIamPolicies(
com.google.cloud.asset.v1.SearchAllIamPoliciesRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getSearchAllIamPoliciesMethod(), getCallOptions(), request);
}
/**
*
*
*
* Analyzes IAM policies to answer which identities have what accesses on
* which resources.
*
*/
public com.google.cloud.asset.v1.AnalyzeIamPolicyResponse analyzeIamPolicy(
com.google.cloud.asset.v1.AnalyzeIamPolicyRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getAnalyzeIamPolicyMethod(), getCallOptions(), request);
}
/**
*
*
*
* Analyzes IAM policies asynchronously to answer which identities have what
* accesses on which resources, and writes the analysis results to a Google
* Cloud Storage or a BigQuery destination. For Cloud Storage destination, the
* output format is the JSON format that represents a
* [AnalyzeIamPolicyResponse][google.cloud.asset.v1.AnalyzeIamPolicyResponse].
* This method implements the
* [google.longrunning.Operation][google.longrunning.Operation], which allows
* you to track the operation status. We recommend intervals of at least 2
* seconds with exponential backoff retry to poll the operation result. The
* metadata contains the metadata for the long-running operation.
*
*/
public com.google.longrunning.Operation analyzeIamPolicyLongrunning(
com.google.cloud.asset.v1.AnalyzeIamPolicyLongrunningRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getAnalyzeIamPolicyLongrunningMethod(), getCallOptions(), request);
}
/**
*
*
*
* Analyze moving a resource to a specified destination without kicking off
* the actual move. The analysis is best effort depending on the user's
* permissions of viewing different hierarchical policies and configurations.
* The policies and configuration are subject to change before the actual
* resource migration takes place.
*
*/
public com.google.cloud.asset.v1.AnalyzeMoveResponse analyzeMove(
com.google.cloud.asset.v1.AnalyzeMoveRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getAnalyzeMoveMethod(), getCallOptions(), request);
}
/**
*
*
*
* Issue a job that queries assets using a SQL statement compatible with
* [BigQuery Standard
* SQL](http://cloud/bigquery/docs/reference/standard-sql/enabling-standard-sql).
* If the query execution finishes within timeout and there's no pagination,
* the full query results will be returned in the `QueryAssetsResponse`.
* Otherwise, full query results can be obtained by issuing extra requests
* with the `job_reference` from the a previous `QueryAssets` call.
* Note, the query result has approximately 10 GB limitation enforced by
* BigQuery
* https://cloud.google.com/bigquery/docs/best-practices-performance-output,
* queries return larger results will result in errors.
*
*/
public com.google.cloud.asset.v1.QueryAssetsResponse queryAssets(
com.google.cloud.asset.v1.QueryAssetsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getQueryAssetsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates a saved query in a parent project/folder/organization.
*
*/
public com.google.cloud.asset.v1.SavedQuery createSavedQuery(
com.google.cloud.asset.v1.CreateSavedQueryRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateSavedQueryMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets details about a saved query.
*
*/
public com.google.cloud.asset.v1.SavedQuery getSavedQuery(
com.google.cloud.asset.v1.GetSavedQueryRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetSavedQueryMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists all saved queries in a parent project/folder/organization.
*
*/
public com.google.cloud.asset.v1.ListSavedQueriesResponse listSavedQueries(
com.google.cloud.asset.v1.ListSavedQueriesRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListSavedQueriesMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates a saved query.
*
*/
public com.google.cloud.asset.v1.SavedQuery updateSavedQuery(
com.google.cloud.asset.v1.UpdateSavedQueryRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateSavedQueryMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes a saved query.
*
*/
public com.google.protobuf.Empty deleteSavedQuery(
com.google.cloud.asset.v1.DeleteSavedQueryRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteSavedQueryMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets effective IAM policies for a batch of resources.
*
*/
public com.google.cloud.asset.v1.BatchGetEffectiveIamPoliciesResponse
batchGetEffectiveIamPolicies(
com.google.cloud.asset.v1.BatchGetEffectiveIamPoliciesRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getBatchGetEffectiveIamPoliciesMethod(), getCallOptions(), request);
}
/**
*
*
*
* Analyzes organization policies under a scope.
*
*/
public com.google.cloud.asset.v1.AnalyzeOrgPoliciesResponse analyzeOrgPolicies(
com.google.cloud.asset.v1.AnalyzeOrgPoliciesRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getAnalyzeOrgPoliciesMethod(), getCallOptions(), request);
}
/**
*
*
*
* Analyzes organization policies governed containers (projects, folders or
* organization) under a scope.
*
*/
public com.google.cloud.asset.v1.AnalyzeOrgPolicyGovernedContainersResponse
analyzeOrgPolicyGovernedContainers(
com.google.cloud.asset.v1.AnalyzeOrgPolicyGovernedContainersRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getAnalyzeOrgPolicyGovernedContainersMethod(), getCallOptions(), request);
}
/**
*
*
*
* Analyzes organization policies governed assets (Google Cloud resources or
* policies) under a scope. This RPC supports custom constraints and the
* following 10 canned constraints:
* * storage.uniformBucketLevelAccess
* * iam.disableServiceAccountKeyCreation
* * iam.allowedPolicyMemberDomains
* * compute.vmExternalIpAccess
* * appengine.enforceServiceAccountActAsCheck
* * gcp.resourceLocations
* * compute.trustedImageProjects
* * compute.skipDefaultNetworkCreation
* * compute.requireOsLogin
* * compute.disableNestedVirtualization
* This RPC only returns either resources of types supported by [searchable
* asset
* types](https://cloud.google.com/asset-inventory/docs/supported-asset-types#searchable_asset_types),
* or IAM policies.
*
*/
public com.google.cloud.asset.v1.AnalyzeOrgPolicyGovernedAssetsResponse
analyzeOrgPolicyGovernedAssets(
com.google.cloud.asset.v1.AnalyzeOrgPolicyGovernedAssetsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getAnalyzeOrgPolicyGovernedAssetsMethod(), getCallOptions(), request);
}
}
/**
* A stub to allow clients to do ListenableFuture-style rpc calls to service AssetService.
*
*
* Asset service definition.
*
*/
public static final class AssetServiceFutureStub
extends io.grpc.stub.AbstractFutureStub {
private AssetServiceFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected AssetServiceFutureStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new AssetServiceFutureStub(channel, callOptions);
}
/**
*
*
*
* Exports assets with time and resource types to a given Cloud Storage
* location/BigQuery table. For Cloud Storage location destinations, the
* output format is newline-delimited JSON. Each line represents a
* [google.cloud.asset.v1.Asset][google.cloud.asset.v1.Asset] in the JSON
* format; for BigQuery table destinations, the output table stores the fields
* in asset Protobuf as columns. This API implements the
* [google.longrunning.Operation][google.longrunning.Operation] API, which
* allows you to keep track of the export. We recommend intervals of at least
* 2 seconds with exponential retry to poll the export operation result. For
* regular-size resource parent, the export operation usually finishes within
* 5 minutes.
*
*/
public com.google.common.util.concurrent.ListenableFuture
exportAssets(com.google.cloud.asset.v1.ExportAssetsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getExportAssetsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists assets with time and resource types and returns paged results in
* response.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.asset.v1.ListAssetsResponse>
listAssets(com.google.cloud.asset.v1.ListAssetsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListAssetsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Batch gets the update history of assets that overlap a time window.
* For IAM_POLICY content, this API outputs history when the asset and its
* attached IAM POLICY both exist. This can create gaps in the output history.
* Otherwise, this API outputs history with asset in both non-delete or
* deleted status.
* If a specified asset does not exist, this API returns an INVALID_ARGUMENT
* error.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.asset.v1.BatchGetAssetsHistoryResponse>
batchGetAssetsHistory(com.google.cloud.asset.v1.BatchGetAssetsHistoryRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getBatchGetAssetsHistoryMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates a feed in a parent project/folder/organization to listen to its
* asset updates.
*
*/
public com.google.common.util.concurrent.ListenableFuture
createFeed(com.google.cloud.asset.v1.CreateFeedRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateFeedMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets details about an asset feed.
*
*/
public com.google.common.util.concurrent.ListenableFuture
getFeed(com.google.cloud.asset.v1.GetFeedRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetFeedMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists all asset feeds in a parent project/folder/organization.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.asset.v1.ListFeedsResponse>
listFeeds(com.google.cloud.asset.v1.ListFeedsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListFeedsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates an asset feed configuration.
*
*/
public com.google.common.util.concurrent.ListenableFuture
updateFeed(com.google.cloud.asset.v1.UpdateFeedRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateFeedMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes an asset feed.
*
*/
public com.google.common.util.concurrent.ListenableFuture deleteFeed(
com.google.cloud.asset.v1.DeleteFeedRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteFeedMethod(), getCallOptions()), request);
}
/**
*
*
*
* Searches all Google Cloud resources within the specified scope, such as a
* project, folder, or organization. The caller must be granted the
* `cloudasset.assets.searchAllResources` permission on the desired scope,
* otherwise the request will be rejected.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.asset.v1.SearchAllResourcesResponse>
searchAllResources(com.google.cloud.asset.v1.SearchAllResourcesRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getSearchAllResourcesMethod(), getCallOptions()), request);
}
/**
*
*
*
* Searches all IAM policies within the specified scope, such as a project,
* folder, or organization. The caller must be granted the
* `cloudasset.assets.searchAllIamPolicies` permission on the desired scope,
* otherwise the request will be rejected.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.asset.v1.SearchAllIamPoliciesResponse>
searchAllIamPolicies(com.google.cloud.asset.v1.SearchAllIamPoliciesRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getSearchAllIamPoliciesMethod(), getCallOptions()), request);
}
/**
*
*
*
* Analyzes IAM policies to answer which identities have what accesses on
* which resources.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.asset.v1.AnalyzeIamPolicyResponse>
analyzeIamPolicy(com.google.cloud.asset.v1.AnalyzeIamPolicyRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getAnalyzeIamPolicyMethod(), getCallOptions()), request);
}
/**
*
*
*
* Analyzes IAM policies asynchronously to answer which identities have what
* accesses on which resources, and writes the analysis results to a Google
* Cloud Storage or a BigQuery destination. For Cloud Storage destination, the
* output format is the JSON format that represents a
* [AnalyzeIamPolicyResponse][google.cloud.asset.v1.AnalyzeIamPolicyResponse].
* This method implements the
* [google.longrunning.Operation][google.longrunning.Operation], which allows
* you to track the operation status. We recommend intervals of at least 2
* seconds with exponential backoff retry to poll the operation result. The
* metadata contains the metadata for the long-running operation.
*
*/
public com.google.common.util.concurrent.ListenableFuture
analyzeIamPolicyLongrunning(
com.google.cloud.asset.v1.AnalyzeIamPolicyLongrunningRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getAnalyzeIamPolicyLongrunningMethod(), getCallOptions()), request);
}
/**
*
*
*
* Analyze moving a resource to a specified destination without kicking off
* the actual move. The analysis is best effort depending on the user's
* permissions of viewing different hierarchical policies and configurations.
* The policies and configuration are subject to change before the actual
* resource migration takes place.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.asset.v1.AnalyzeMoveResponse>
analyzeMove(com.google.cloud.asset.v1.AnalyzeMoveRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getAnalyzeMoveMethod(), getCallOptions()), request);
}
/**
*
*
*
* Issue a job that queries assets using a SQL statement compatible with
* [BigQuery Standard
* SQL](http://cloud/bigquery/docs/reference/standard-sql/enabling-standard-sql).
* If the query execution finishes within timeout and there's no pagination,
* the full query results will be returned in the `QueryAssetsResponse`.
* Otherwise, full query results can be obtained by issuing extra requests
* with the `job_reference` from the a previous `QueryAssets` call.
* Note, the query result has approximately 10 GB limitation enforced by
* BigQuery
* https://cloud.google.com/bigquery/docs/best-practices-performance-output,
* queries return larger results will result in errors.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.asset.v1.QueryAssetsResponse>
queryAssets(com.google.cloud.asset.v1.QueryAssetsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getQueryAssetsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates a saved query in a parent project/folder/organization.
*
*/
public com.google.common.util.concurrent.ListenableFuture
createSavedQuery(com.google.cloud.asset.v1.CreateSavedQueryRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateSavedQueryMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets details about a saved query.
*
*/
public com.google.common.util.concurrent.ListenableFuture
getSavedQuery(com.google.cloud.asset.v1.GetSavedQueryRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetSavedQueryMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists all saved queries in a parent project/folder/organization.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.asset.v1.ListSavedQueriesResponse>
listSavedQueries(com.google.cloud.asset.v1.ListSavedQueriesRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListSavedQueriesMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates a saved query.
*
*/
public com.google.common.util.concurrent.ListenableFuture
updateSavedQuery(com.google.cloud.asset.v1.UpdateSavedQueryRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateSavedQueryMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes a saved query.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteSavedQuery(com.google.cloud.asset.v1.DeleteSavedQueryRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteSavedQueryMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets effective IAM policies for a batch of resources.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.asset.v1.BatchGetEffectiveIamPoliciesResponse>
batchGetEffectiveIamPolicies(
com.google.cloud.asset.v1.BatchGetEffectiveIamPoliciesRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getBatchGetEffectiveIamPoliciesMethod(), getCallOptions()), request);
}
/**
*
*
*
* Analyzes organization policies under a scope.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.asset.v1.AnalyzeOrgPoliciesResponse>
analyzeOrgPolicies(com.google.cloud.asset.v1.AnalyzeOrgPoliciesRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getAnalyzeOrgPoliciesMethod(), getCallOptions()), request);
}
/**
*
*
*
* Analyzes organization policies governed containers (projects, folders or
* organization) under a scope.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.asset.v1.AnalyzeOrgPolicyGovernedContainersResponse>
analyzeOrgPolicyGovernedContainers(
com.google.cloud.asset.v1.AnalyzeOrgPolicyGovernedContainersRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getAnalyzeOrgPolicyGovernedContainersMethod(), getCallOptions()),
request);
}
/**
*
*
*
* Analyzes organization policies governed assets (Google Cloud resources or
* policies) under a scope. This RPC supports custom constraints and the
* following 10 canned constraints:
* * storage.uniformBucketLevelAccess
* * iam.disableServiceAccountKeyCreation
* * iam.allowedPolicyMemberDomains
* * compute.vmExternalIpAccess
* * appengine.enforceServiceAccountActAsCheck
* * gcp.resourceLocations
* * compute.trustedImageProjects
* * compute.skipDefaultNetworkCreation
* * compute.requireOsLogin
* * compute.disableNestedVirtualization
* This RPC only returns either resources of types supported by [searchable
* asset
* types](https://cloud.google.com/asset-inventory/docs/supported-asset-types#searchable_asset_types),
* or IAM policies.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.asset.v1.AnalyzeOrgPolicyGovernedAssetsResponse>
analyzeOrgPolicyGovernedAssets(
com.google.cloud.asset.v1.AnalyzeOrgPolicyGovernedAssetsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getAnalyzeOrgPolicyGovernedAssetsMethod(), getCallOptions()),
request);
}
}
private static final int METHODID_EXPORT_ASSETS = 0;
private static final int METHODID_LIST_ASSETS = 1;
private static final int METHODID_BATCH_GET_ASSETS_HISTORY = 2;
private static final int METHODID_CREATE_FEED = 3;
private static final int METHODID_GET_FEED = 4;
private static final int METHODID_LIST_FEEDS = 5;
private static final int METHODID_UPDATE_FEED = 6;
private static final int METHODID_DELETE_FEED = 7;
private static final int METHODID_SEARCH_ALL_RESOURCES = 8;
private static final int METHODID_SEARCH_ALL_IAM_POLICIES = 9;
private static final int METHODID_ANALYZE_IAM_POLICY = 10;
private static final int METHODID_ANALYZE_IAM_POLICY_LONGRUNNING = 11;
private static final int METHODID_ANALYZE_MOVE = 12;
private static final int METHODID_QUERY_ASSETS = 13;
private static final int METHODID_CREATE_SAVED_QUERY = 14;
private static final int METHODID_GET_SAVED_QUERY = 15;
private static final int METHODID_LIST_SAVED_QUERIES = 16;
private static final int METHODID_UPDATE_SAVED_QUERY = 17;
private static final int METHODID_DELETE_SAVED_QUERY = 18;
private static final int METHODID_BATCH_GET_EFFECTIVE_IAM_POLICIES = 19;
private static final int METHODID_ANALYZE_ORG_POLICIES = 20;
private static final int METHODID_ANALYZE_ORG_POLICY_GOVERNED_CONTAINERS = 21;
private static final int METHODID_ANALYZE_ORG_POLICY_GOVERNED_ASSETS = 22;
private static final class MethodHandlers
implements io.grpc.stub.ServerCalls.UnaryMethod,
io.grpc.stub.ServerCalls.ServerStreamingMethod,
io.grpc.stub.ServerCalls.ClientStreamingMethod,
io.grpc.stub.ServerCalls.BidiStreamingMethod {
private final AsyncService serviceImpl;
private final int methodId;
MethodHandlers(AsyncService serviceImpl, int methodId) {
this.serviceImpl = serviceImpl;
this.methodId = methodId;
}
@java.lang.Override
@java.lang.SuppressWarnings("unchecked")
public void invoke(Req request, io.grpc.stub.StreamObserver responseObserver) {
switch (methodId) {
case METHODID_EXPORT_ASSETS:
serviceImpl.exportAssets(
(com.google.cloud.asset.v1.ExportAssetsRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_LIST_ASSETS:
serviceImpl.listAssets(
(com.google.cloud.asset.v1.ListAssetsRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_BATCH_GET_ASSETS_HISTORY:
serviceImpl.batchGetAssetsHistory(
(com.google.cloud.asset.v1.BatchGetAssetsHistoryRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_CREATE_FEED:
serviceImpl.createFeed(
(com.google.cloud.asset.v1.CreateFeedRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_GET_FEED:
serviceImpl.getFeed(
(com.google.cloud.asset.v1.GetFeedRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_LIST_FEEDS:
serviceImpl.listFeeds(
(com.google.cloud.asset.v1.ListFeedsRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_UPDATE_FEED:
serviceImpl.updateFeed(
(com.google.cloud.asset.v1.UpdateFeedRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_DELETE_FEED:
serviceImpl.deleteFeed(
(com.google.cloud.asset.v1.DeleteFeedRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_SEARCH_ALL_RESOURCES:
serviceImpl.searchAllResources(
(com.google.cloud.asset.v1.SearchAllResourcesRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_SEARCH_ALL_IAM_POLICIES:
serviceImpl.searchAllIamPolicies(
(com.google.cloud.asset.v1.SearchAllIamPoliciesRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_ANALYZE_IAM_POLICY:
serviceImpl.analyzeIamPolicy(
(com.google.cloud.asset.v1.AnalyzeIamPolicyRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_ANALYZE_IAM_POLICY_LONGRUNNING:
serviceImpl.analyzeIamPolicyLongrunning(
(com.google.cloud.asset.v1.AnalyzeIamPolicyLongrunningRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_ANALYZE_MOVE:
serviceImpl.analyzeMove(
(com.google.cloud.asset.v1.AnalyzeMoveRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_QUERY_ASSETS:
serviceImpl.queryAssets(
(com.google.cloud.asset.v1.QueryAssetsRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_CREATE_SAVED_QUERY:
serviceImpl.createSavedQuery(
(com.google.cloud.asset.v1.CreateSavedQueryRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_GET_SAVED_QUERY:
serviceImpl.getSavedQuery(
(com.google.cloud.asset.v1.GetSavedQueryRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_LIST_SAVED_QUERIES:
serviceImpl.listSavedQueries(
(com.google.cloud.asset.v1.ListSavedQueriesRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_UPDATE_SAVED_QUERY:
serviceImpl.updateSavedQuery(
(com.google.cloud.asset.v1.UpdateSavedQueryRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_DELETE_SAVED_QUERY:
serviceImpl.deleteSavedQuery(
(com.google.cloud.asset.v1.DeleteSavedQueryRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_BATCH_GET_EFFECTIVE_IAM_POLICIES:
serviceImpl.batchGetEffectiveIamPolicies(
(com.google.cloud.asset.v1.BatchGetEffectiveIamPoliciesRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.asset.v1.BatchGetEffectiveIamPoliciesResponse>)
responseObserver);
break;
case METHODID_ANALYZE_ORG_POLICIES:
serviceImpl.analyzeOrgPolicies(
(com.google.cloud.asset.v1.AnalyzeOrgPoliciesRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_ANALYZE_ORG_POLICY_GOVERNED_CONTAINERS:
serviceImpl.analyzeOrgPolicyGovernedContainers(
(com.google.cloud.asset.v1.AnalyzeOrgPolicyGovernedContainersRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.asset.v1.AnalyzeOrgPolicyGovernedContainersResponse>)
responseObserver);
break;
case METHODID_ANALYZE_ORG_POLICY_GOVERNED_ASSETS:
serviceImpl.analyzeOrgPolicyGovernedAssets(
(com.google.cloud.asset.v1.AnalyzeOrgPolicyGovernedAssetsRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.asset.v1.AnalyzeOrgPolicyGovernedAssetsResponse>)
responseObserver);
break;
default:
throw new AssertionError();
}
}
@java.lang.Override
@java.lang.SuppressWarnings("unchecked")
public io.grpc.stub.StreamObserver invoke(
io.grpc.stub.StreamObserver responseObserver) {
switch (methodId) {
default:
throw new AssertionError();
}
}
}
public static final io.grpc.ServerServiceDefinition bindService(AsyncService service) {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
.addMethod(
getExportAssetsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.asset.v1.ExportAssetsRequest,
com.google.longrunning.Operation>(service, METHODID_EXPORT_ASSETS)))
.addMethod(
getListAssetsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.asset.v1.ListAssetsRequest,
com.google.cloud.asset.v1.ListAssetsResponse>(service, METHODID_LIST_ASSETS)))
.addMethod(
getBatchGetAssetsHistoryMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.asset.v1.BatchGetAssetsHistoryRequest,
com.google.cloud.asset.v1.BatchGetAssetsHistoryResponse>(
service, METHODID_BATCH_GET_ASSETS_HISTORY)))
.addMethod(
getCreateFeedMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.asset.v1.CreateFeedRequest, com.google.cloud.asset.v1.Feed>(
service, METHODID_CREATE_FEED)))
.addMethod(
getGetFeedMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.asset.v1.GetFeedRequest, com.google.cloud.asset.v1.Feed>(
service, METHODID_GET_FEED)))
.addMethod(
getListFeedsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.asset.v1.ListFeedsRequest,
com.google.cloud.asset.v1.ListFeedsResponse>(service, METHODID_LIST_FEEDS)))
.addMethod(
getUpdateFeedMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.asset.v1.UpdateFeedRequest, com.google.cloud.asset.v1.Feed>(
service, METHODID_UPDATE_FEED)))
.addMethod(
getDeleteFeedMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.asset.v1.DeleteFeedRequest, com.google.protobuf.Empty>(
service, METHODID_DELETE_FEED)))
.addMethod(
getSearchAllResourcesMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.asset.v1.SearchAllResourcesRequest,
com.google.cloud.asset.v1.SearchAllResourcesResponse>(
service, METHODID_SEARCH_ALL_RESOURCES)))
.addMethod(
getSearchAllIamPoliciesMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.asset.v1.SearchAllIamPoliciesRequest,
com.google.cloud.asset.v1.SearchAllIamPoliciesResponse>(
service, METHODID_SEARCH_ALL_IAM_POLICIES)))
.addMethod(
getAnalyzeIamPolicyMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.asset.v1.AnalyzeIamPolicyRequest,
com.google.cloud.asset.v1.AnalyzeIamPolicyResponse>(
service, METHODID_ANALYZE_IAM_POLICY)))
.addMethod(
getAnalyzeIamPolicyLongrunningMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.asset.v1.AnalyzeIamPolicyLongrunningRequest,
com.google.longrunning.Operation>(
service, METHODID_ANALYZE_IAM_POLICY_LONGRUNNING)))
.addMethod(
getAnalyzeMoveMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.asset.v1.AnalyzeMoveRequest,
com.google.cloud.asset.v1.AnalyzeMoveResponse>(service, METHODID_ANALYZE_MOVE)))
.addMethod(
getQueryAssetsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.asset.v1.QueryAssetsRequest,
com.google.cloud.asset.v1.QueryAssetsResponse>(service, METHODID_QUERY_ASSETS)))
.addMethod(
getCreateSavedQueryMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.asset.v1.CreateSavedQueryRequest,
com.google.cloud.asset.v1.SavedQuery>(service, METHODID_CREATE_SAVED_QUERY)))
.addMethod(
getGetSavedQueryMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.asset.v1.GetSavedQueryRequest,
com.google.cloud.asset.v1.SavedQuery>(service, METHODID_GET_SAVED_QUERY)))
.addMethod(
getListSavedQueriesMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.asset.v1.ListSavedQueriesRequest,
com.google.cloud.asset.v1.ListSavedQueriesResponse>(
service, METHODID_LIST_SAVED_QUERIES)))
.addMethod(
getUpdateSavedQueryMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.asset.v1.UpdateSavedQueryRequest,
com.google.cloud.asset.v1.SavedQuery>(service, METHODID_UPDATE_SAVED_QUERY)))
.addMethod(
getDeleteSavedQueryMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.asset.v1.DeleteSavedQueryRequest, com.google.protobuf.Empty>(
service, METHODID_DELETE_SAVED_QUERY)))
.addMethod(
getBatchGetEffectiveIamPoliciesMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.asset.v1.BatchGetEffectiveIamPoliciesRequest,
com.google.cloud.asset.v1.BatchGetEffectiveIamPoliciesResponse>(
service, METHODID_BATCH_GET_EFFECTIVE_IAM_POLICIES)))
.addMethod(
getAnalyzeOrgPoliciesMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.asset.v1.AnalyzeOrgPoliciesRequest,
com.google.cloud.asset.v1.AnalyzeOrgPoliciesResponse>(
service, METHODID_ANALYZE_ORG_POLICIES)))
.addMethod(
getAnalyzeOrgPolicyGovernedContainersMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.asset.v1.AnalyzeOrgPolicyGovernedContainersRequest,
com.google.cloud.asset.v1.AnalyzeOrgPolicyGovernedContainersResponse>(
service, METHODID_ANALYZE_ORG_POLICY_GOVERNED_CONTAINERS)))
.addMethod(
getAnalyzeOrgPolicyGovernedAssetsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.asset.v1.AnalyzeOrgPolicyGovernedAssetsRequest,
com.google.cloud.asset.v1.AnalyzeOrgPolicyGovernedAssetsResponse>(
service, METHODID_ANALYZE_ORG_POLICY_GOVERNED_ASSETS)))
.build();
}
private abstract static class AssetServiceBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
io.grpc.protobuf.ProtoServiceDescriptorSupplier {
AssetServiceBaseDescriptorSupplier() {}
@java.lang.Override
public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
return com.google.cloud.asset.v1.AssetServiceProto.getDescriptor();
}
@java.lang.Override
public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
return getFileDescriptor().findServiceByName("AssetService");
}
}
private static final class AssetServiceFileDescriptorSupplier
extends AssetServiceBaseDescriptorSupplier {
AssetServiceFileDescriptorSupplier() {}
}
private static final class AssetServiceMethodDescriptorSupplier
extends AssetServiceBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
private final String methodName;
AssetServiceMethodDescriptorSupplier(String methodName) {
this.methodName = methodName;
}
@java.lang.Override
public com.google.protobuf.Descriptors.MethodDescriptor getMethodDescriptor() {
return getServiceDescriptor().findMethodByName(methodName);
}
}
private static volatile io.grpc.ServiceDescriptor serviceDescriptor;
public static io.grpc.ServiceDescriptor getServiceDescriptor() {
io.grpc.ServiceDescriptor result = serviceDescriptor;
if (result == null) {
synchronized (AssetServiceGrpc.class) {
result = serviceDescriptor;
if (result == null) {
serviceDescriptor =
result =
io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
.setSchemaDescriptor(new AssetServiceFileDescriptorSupplier())
.addMethod(getExportAssetsMethod())
.addMethod(getListAssetsMethod())
.addMethod(getBatchGetAssetsHistoryMethod())
.addMethod(getCreateFeedMethod())
.addMethod(getGetFeedMethod())
.addMethod(getListFeedsMethod())
.addMethod(getUpdateFeedMethod())
.addMethod(getDeleteFeedMethod())
.addMethod(getSearchAllResourcesMethod())
.addMethod(getSearchAllIamPoliciesMethod())
.addMethod(getAnalyzeIamPolicyMethod())
.addMethod(getAnalyzeIamPolicyLongrunningMethod())
.addMethod(getAnalyzeMoveMethod())
.addMethod(getQueryAssetsMethod())
.addMethod(getCreateSavedQueryMethod())
.addMethod(getGetSavedQueryMethod())
.addMethod(getListSavedQueriesMethod())
.addMethod(getUpdateSavedQueryMethod())
.addMethod(getDeleteSavedQueryMethod())
.addMethod(getBatchGetEffectiveIamPoliciesMethod())
.addMethod(getAnalyzeOrgPoliciesMethod())
.addMethod(getAnalyzeOrgPolicyGovernedContainersMethod())
.addMethod(getAnalyzeOrgPolicyGovernedAssetsMethod())
.build();
}
}
}
return result;
}
}