diff --git a/google-api-grpc/grpc-google-cloud-dlp-v2/src/main/java/com/google/privacy/dlp/v2/DlpServiceGrpc.java b/google-api-grpc/grpc-google-cloud-dlp-v2/src/main/java/com/google/privacy/dlp/v2/DlpServiceGrpc.java
index d291ae3451ab..563aa1ce9b87 100644
--- a/google-api-grpc/grpc-google-cloud-dlp-v2/src/main/java/com/google/privacy/dlp/v2/DlpServiceGrpc.java
+++ b/google-api-grpc/grpc-google-cloud-dlp-v2/src/main/java/com/google/privacy/dlp/v2/DlpServiceGrpc.java
@@ -23,6 +23,8 @@
* blocks or images.
* The service also includes methods for sensitive data redaction and
* scheduling of data scans on Google Cloud Platform based data sets.
+ * To learn more about concepts and find how-to guides see
+ * https://cloud.google.com/dlp/docs/.
*
*/
@javax.annotation.Generated(
@@ -992,6 +994,8 @@ public static DlpServiceFutureStub newFutureStub(
* blocks or images.
* The service also includes methods for sensitive data redaction and
* scheduling of data scans on Google Cloud Platform based data sets.
+ * To learn more about concepts and find how-to guides see
+ * https://cloud.google.com/dlp/docs/.
*
*/
public static abstract class DlpServiceImplBase implements io.grpc.BindableService {
@@ -1000,8 +1004,11 @@ public static abstract class DlpServiceImplBase implements io.grpc.BindableServi
*
* Finds potentially sensitive info in content.
* This method has limits on input size, processing time, and output size.
- * [How-to guide for text](/dlp/docs/inspecting-text), [How-to guide for
- * images](/dlp/docs/inspecting-images)
+ * When no InfoTypes or CustomInfoTypes are specified in this request, the
+ * system will automatically choose what detectors to run. By default this may
+ * be all types, but may change over time as detectors are updated.
+ * For how to guides, see https://cloud.google.com/dlp/docs/inspecting-images
+ * and https://cloud.google.com/dlp/docs/inspecting-text,
*
*/
public void inspectContent(com.google.privacy.dlp.v2.InspectContentRequest request,
@@ -1013,7 +1020,11 @@ public void inspectContent(com.google.privacy.dlp.v2.InspectContentRequest reque
*
* Redacts potentially sensitive info from an image.
* This method has limits on input size, processing time, and output size.
- * [How-to guide](/dlp/docs/redacting-sensitive-data-images)
+ * See https://cloud.google.com/dlp/docs/redacting-sensitive-data-images to
+ * learn more.
+ * When no InfoTypes or CustomInfoTypes are specified in this request, the
+ * system will automatically choose what detectors to run. By default this may
+ * be all types, but may change over time as detectors are updated.
*
*/
public void redactImage(com.google.privacy.dlp.v2.RedactImageRequest request,
@@ -1025,7 +1036,11 @@ public void redactImage(com.google.privacy.dlp.v2.RedactImageRequest request,
*
* De-identifies potentially sensitive info from a ContentItem.
* This method has limits on input size and output size.
- * [How-to guide](/dlp/docs/deidentify-sensitive-data)
+ * See https://cloud.google.com/dlp/docs/deidentify-sensitive-data to
+ * learn more.
+ * When no InfoTypes or CustomInfoTypes are specified in this request, the
+ * system will automatically choose what detectors to run. By default this may
+ * be all types, but may change over time as detectors are updated.
*
*/
public void deidentifyContent(com.google.privacy.dlp.v2.DeidentifyContentRequest request,
@@ -1036,6 +1051,9 @@ public void deidentifyContent(com.google.privacy.dlp.v2.DeidentifyContentRequest
/**
*
* Re-identifies content that has been de-identified.
+ * See
+ * https://cloud.google.com/dlp/docs/pseudonymization#re-identification_in_free_text_code_example
+ * to learn more.
*
*/
public void reidentifyContent(com.google.privacy.dlp.v2.ReidentifyContentRequest request,
@@ -1046,8 +1064,8 @@ public void reidentifyContent(com.google.privacy.dlp.v2.ReidentifyContentRequest
/**
*
* Returns a list of the sensitive information types that the DLP API
- * supports. For more information, see [Listing supported predefined
- * infoTypes](/dlp/docs/listing-infotypes).
+ * supports. See https://cloud.google.com/dlp/docs/infotypes-reference to
+ * learn more.
*
*/
public void listInfoTypes(com.google.privacy.dlp.v2.ListInfoTypesRequest request,
@@ -1059,6 +1077,7 @@ public void listInfoTypes(com.google.privacy.dlp.v2.ListInfoTypesRequest request
*
* Creates an InspectTemplate for re-using frequently used configuration
* for inspecting content, images, and storage.
+ * See https://cloud.google.com/dlp/docs/creating-templates to learn more.
*
*/
public void createInspectTemplate(com.google.privacy.dlp.v2.CreateInspectTemplateRequest request,
@@ -1069,6 +1088,7 @@ public void createInspectTemplate(com.google.privacy.dlp.v2.CreateInspectTemplat
/**
*
* Updates the InspectTemplate.
+ * See https://cloud.google.com/dlp/docs/creating-templates to learn more.
*
*/
public void updateInspectTemplate(com.google.privacy.dlp.v2.UpdateInspectTemplateRequest request,
@@ -1079,6 +1099,7 @@ public void updateInspectTemplate(com.google.privacy.dlp.v2.UpdateInspectTemplat
/**
*
* Gets an InspectTemplate.
+ * See https://cloud.google.com/dlp/docs/creating-templates to learn more.
*
*/
public void getInspectTemplate(com.google.privacy.dlp.v2.GetInspectTemplateRequest request,
@@ -1089,6 +1110,7 @@ public void getInspectTemplate(com.google.privacy.dlp.v2.GetInspectTemplateReque
/**
*
* Lists InspectTemplates.
+ * See https://cloud.google.com/dlp/docs/creating-templates to learn more.
*
*/
public void listInspectTemplates(com.google.privacy.dlp.v2.ListInspectTemplatesRequest request,
@@ -1099,6 +1121,7 @@ public void listInspectTemplates(com.google.privacy.dlp.v2.ListInspectTemplatesR
/**
*
* Deletes an InspectTemplate.
+ * See https://cloud.google.com/dlp/docs/creating-templates to learn more.
*
*/
public void deleteInspectTemplate(com.google.privacy.dlp.v2.DeleteInspectTemplateRequest request,
@@ -1110,6 +1133,8 @@ public void deleteInspectTemplate(com.google.privacy.dlp.v2.DeleteInspectTemplat
*
* Creates a DeidentifyTemplate for re-using frequently used configuration
* for de-identifying content, images, and storage.
+ * See https://cloud.google.com/dlp/docs/creating-templates-deid to learn
+ * more.
*
*/
public void createDeidentifyTemplate(com.google.privacy.dlp.v2.CreateDeidentifyTemplateRequest request,
@@ -1120,6 +1145,8 @@ public void createDeidentifyTemplate(com.google.privacy.dlp.v2.CreateDeidentifyT
/**
*
* Updates the DeidentifyTemplate.
+ * See https://cloud.google.com/dlp/docs/creating-templates-deid to learn
+ * more.
*
*/
public void updateDeidentifyTemplate(com.google.privacy.dlp.v2.UpdateDeidentifyTemplateRequest request,
@@ -1130,6 +1157,8 @@ public void updateDeidentifyTemplate(com.google.privacy.dlp.v2.UpdateDeidentifyT
/**
*
* Gets a DeidentifyTemplate.
+ * See https://cloud.google.com/dlp/docs/creating-templates-deid to learn
+ * more.
*
*/
public void getDeidentifyTemplate(com.google.privacy.dlp.v2.GetDeidentifyTemplateRequest request,
@@ -1140,6 +1169,8 @@ public void getDeidentifyTemplate(com.google.privacy.dlp.v2.GetDeidentifyTemplat
/**
*
* Lists DeidentifyTemplates.
+ * See https://cloud.google.com/dlp/docs/creating-templates-deid to learn
+ * more.
*
*/
public void listDeidentifyTemplates(com.google.privacy.dlp.v2.ListDeidentifyTemplatesRequest request,
@@ -1150,6 +1181,8 @@ public void listDeidentifyTemplates(com.google.privacy.dlp.v2.ListDeidentifyTemp
/**
*
* Deletes a DeidentifyTemplate.
+ * See https://cloud.google.com/dlp/docs/creating-templates-deid to learn
+ * more.
*
*/
public void deleteDeidentifyTemplate(com.google.privacy.dlp.v2.DeleteDeidentifyTemplateRequest request,
@@ -1161,6 +1194,7 @@ public void deleteDeidentifyTemplate(com.google.privacy.dlp.v2.DeleteDeidentifyT
*
* Creates a job trigger to run DLP actions such as scanning storage for
* sensitive information on a set schedule.
+ * See https://cloud.google.com/dlp/docs/creating-job-triggers to learn more.
*
*/
public void createJobTrigger(com.google.privacy.dlp.v2.CreateJobTriggerRequest request,
@@ -1171,6 +1205,7 @@ public void createJobTrigger(com.google.privacy.dlp.v2.CreateJobTriggerRequest r
/**
*
* Updates a job trigger.
+ * See https://cloud.google.com/dlp/docs/creating-job-triggers to learn more.
*
*/
public void updateJobTrigger(com.google.privacy.dlp.v2.UpdateJobTriggerRequest request,
@@ -1181,6 +1216,7 @@ public void updateJobTrigger(com.google.privacy.dlp.v2.UpdateJobTriggerRequest r
/**
*
* Gets a job trigger.
+ * See https://cloud.google.com/dlp/docs/creating-job-triggers to learn more.
*
*/
public void getJobTrigger(com.google.privacy.dlp.v2.GetJobTriggerRequest request,
@@ -1191,6 +1227,7 @@ public void getJobTrigger(com.google.privacy.dlp.v2.GetJobTriggerRequest request
/**
*
* Lists job triggers.
+ * See https://cloud.google.com/dlp/docs/creating-job-triggers to learn more.
*
*/
public void listJobTriggers(com.google.privacy.dlp.v2.ListJobTriggersRequest request,
@@ -1201,6 +1238,7 @@ public void listJobTriggers(com.google.privacy.dlp.v2.ListJobTriggersRequest req
/**
*
* Deletes a job trigger.
+ * See https://cloud.google.com/dlp/docs/creating-job-triggers to learn more.
*
*/
public void deleteJobTrigger(com.google.privacy.dlp.v2.DeleteJobTriggerRequest request,
@@ -1211,7 +1249,11 @@ public void deleteJobTrigger(com.google.privacy.dlp.v2.DeleteJobTriggerRequest r
/**
*
* Creates a new job to inspect storage or calculate risk metrics.
- * [How-to guide](/dlp/docs/compute-risk-analysis).
+ * See https://cloud.google.com/dlp/docs/inspecting-storage and
+ * https://cloud.google.com/dlp/docs/compute-risk-analysis to learn more.
+ * When no InfoTypes or CustomInfoTypes are specified in inspect jobs, the
+ * system will automatically choose what detectors to run. By default this may
+ * be all types, but may change over time as detectors are updated.
*
*/
public void createDlpJob(com.google.privacy.dlp.v2.CreateDlpJobRequest request,
@@ -1222,6 +1264,8 @@ public void createDlpJob(com.google.privacy.dlp.v2.CreateDlpJobRequest request,
/**
*
* Lists DlpJobs that match the specified filter in the request.
+ * See https://cloud.google.com/dlp/docs/inspecting-storage and
+ * https://cloud.google.com/dlp/docs/compute-risk-analysis to learn more.
*
*/
public void listDlpJobs(com.google.privacy.dlp.v2.ListDlpJobsRequest request,
@@ -1232,6 +1276,8 @@ public void listDlpJobs(com.google.privacy.dlp.v2.ListDlpJobsRequest request,
/**
*
* Gets the latest state of a long-running DlpJob.
+ * See https://cloud.google.com/dlp/docs/inspecting-storage and
+ * https://cloud.google.com/dlp/docs/compute-risk-analysis to learn more.
*
*/
public void getDlpJob(com.google.privacy.dlp.v2.GetDlpJobRequest request,
@@ -1244,6 +1290,8 @@ public void getDlpJob(com.google.privacy.dlp.v2.GetDlpJobRequest request,
* Deletes a long-running DlpJob. This method indicates that the client is
* no longer interested in the DlpJob result. The job will be cancelled if
* possible.
+ * See https://cloud.google.com/dlp/docs/inspecting-storage and
+ * https://cloud.google.com/dlp/docs/compute-risk-analysis to learn more.
*
*/
public void deleteDlpJob(com.google.privacy.dlp.v2.DeleteDlpJobRequest request,
@@ -1256,6 +1304,8 @@ public void deleteDlpJob(com.google.privacy.dlp.v2.DeleteDlpJobRequest request,
* Starts asynchronous cancellation on a long-running DlpJob. The server
* makes a best effort to cancel the DlpJob, but success is not
* guaranteed.
+ * See https://cloud.google.com/dlp/docs/inspecting-storage and
+ * https://cloud.google.com/dlp/docs/compute-risk-analysis to learn more.
*
*/
public void cancelDlpJob(com.google.privacy.dlp.v2.CancelDlpJobRequest request,
@@ -1452,6 +1502,8 @@ public void cancelDlpJob(com.google.privacy.dlp.v2.CancelDlpJobRequest request,
* blocks or images.
* The service also includes methods for sensitive data redaction and
* scheduling of data scans on Google Cloud Platform based data sets.
+ * To learn more about concepts and find how-to guides see
+ * https://cloud.google.com/dlp/docs/.
*
*/
public static final class DlpServiceStub extends io.grpc.stub.AbstractStub {
@@ -1474,8 +1526,11 @@ protected DlpServiceStub build(io.grpc.Channel channel,
*
* Finds potentially sensitive info in content.
* This method has limits on input size, processing time, and output size.
- * [How-to guide for text](/dlp/docs/inspecting-text), [How-to guide for
- * images](/dlp/docs/inspecting-images)
+ * When no InfoTypes or CustomInfoTypes are specified in this request, the
+ * system will automatically choose what detectors to run. By default this may
+ * be all types, but may change over time as detectors are updated.
+ * For how to guides, see https://cloud.google.com/dlp/docs/inspecting-images
+ * and https://cloud.google.com/dlp/docs/inspecting-text,
*
*/
public void inspectContent(com.google.privacy.dlp.v2.InspectContentRequest request,
@@ -1488,7 +1543,11 @@ public void inspectContent(com.google.privacy.dlp.v2.InspectContentRequest reque
*
* Redacts potentially sensitive info from an image.
* This method has limits on input size, processing time, and output size.
- * [How-to guide](/dlp/docs/redacting-sensitive-data-images)
+ * See https://cloud.google.com/dlp/docs/redacting-sensitive-data-images to
+ * learn more.
+ * When no InfoTypes or CustomInfoTypes are specified in this request, the
+ * system will automatically choose what detectors to run. By default this may
+ * be all types, but may change over time as detectors are updated.
*
*/
public void redactImage(com.google.privacy.dlp.v2.RedactImageRequest request,
@@ -1501,7 +1560,11 @@ public void redactImage(com.google.privacy.dlp.v2.RedactImageRequest request,
*
* De-identifies potentially sensitive info from a ContentItem.
* This method has limits on input size and output size.
- * [How-to guide](/dlp/docs/deidentify-sensitive-data)
+ * See https://cloud.google.com/dlp/docs/deidentify-sensitive-data to
+ * learn more.
+ * When no InfoTypes or CustomInfoTypes are specified in this request, the
+ * system will automatically choose what detectors to run. By default this may
+ * be all types, but may change over time as detectors are updated.
*
*/
public void deidentifyContent(com.google.privacy.dlp.v2.DeidentifyContentRequest request,
@@ -1513,6 +1576,9 @@ public void deidentifyContent(com.google.privacy.dlp.v2.DeidentifyContentRequest
/**
*
* Re-identifies content that has been de-identified.
+ * See
+ * https://cloud.google.com/dlp/docs/pseudonymization#re-identification_in_free_text_code_example
+ * to learn more.
*
*/
public void reidentifyContent(com.google.privacy.dlp.v2.ReidentifyContentRequest request,
@@ -1524,8 +1590,8 @@ public void reidentifyContent(com.google.privacy.dlp.v2.ReidentifyContentRequest
/**
*
* Returns a list of the sensitive information types that the DLP API
- * supports. For more information, see [Listing supported predefined
- * infoTypes](/dlp/docs/listing-infotypes).
+ * supports. See https://cloud.google.com/dlp/docs/infotypes-reference to
+ * learn more.
*
*/
public void listInfoTypes(com.google.privacy.dlp.v2.ListInfoTypesRequest request,
@@ -1538,6 +1604,7 @@ public void listInfoTypes(com.google.privacy.dlp.v2.ListInfoTypesRequest request
*
* Creates an InspectTemplate for re-using frequently used configuration
* for inspecting content, images, and storage.
+ * See https://cloud.google.com/dlp/docs/creating-templates to learn more.
*
*/
public void createInspectTemplate(com.google.privacy.dlp.v2.CreateInspectTemplateRequest request,
@@ -1549,6 +1616,7 @@ public void createInspectTemplate(com.google.privacy.dlp.v2.CreateInspectTemplat
/**
*
* Updates the InspectTemplate.
+ * See https://cloud.google.com/dlp/docs/creating-templates to learn more.
*
*/
public void updateInspectTemplate(com.google.privacy.dlp.v2.UpdateInspectTemplateRequest request,
@@ -1560,6 +1628,7 @@ public void updateInspectTemplate(com.google.privacy.dlp.v2.UpdateInspectTemplat
/**
*
* Gets an InspectTemplate.
+ * See https://cloud.google.com/dlp/docs/creating-templates to learn more.
*
*/
public void getInspectTemplate(com.google.privacy.dlp.v2.GetInspectTemplateRequest request,
@@ -1571,6 +1640,7 @@ public void getInspectTemplate(com.google.privacy.dlp.v2.GetInspectTemplateReque
/**
*
* Lists InspectTemplates.
+ * See https://cloud.google.com/dlp/docs/creating-templates to learn more.
*
*/
public void listInspectTemplates(com.google.privacy.dlp.v2.ListInspectTemplatesRequest request,
@@ -1582,6 +1652,7 @@ public void listInspectTemplates(com.google.privacy.dlp.v2.ListInspectTemplatesR
/**
*
* Deletes an InspectTemplate.
+ * See https://cloud.google.com/dlp/docs/creating-templates to learn more.
*
*/
public void deleteInspectTemplate(com.google.privacy.dlp.v2.DeleteInspectTemplateRequest request,
@@ -1594,6 +1665,8 @@ public void deleteInspectTemplate(com.google.privacy.dlp.v2.DeleteInspectTemplat
*
* Creates a DeidentifyTemplate for re-using frequently used configuration
* for de-identifying content, images, and storage.
+ * See https://cloud.google.com/dlp/docs/creating-templates-deid to learn
+ * more.
*
*/
public void createDeidentifyTemplate(com.google.privacy.dlp.v2.CreateDeidentifyTemplateRequest request,
@@ -1605,6 +1678,8 @@ public void createDeidentifyTemplate(com.google.privacy.dlp.v2.CreateDeidentifyT
/**
*
* Updates the DeidentifyTemplate.
+ * See https://cloud.google.com/dlp/docs/creating-templates-deid to learn
+ * more.
*
*/
public void updateDeidentifyTemplate(com.google.privacy.dlp.v2.UpdateDeidentifyTemplateRequest request,
@@ -1616,6 +1691,8 @@ public void updateDeidentifyTemplate(com.google.privacy.dlp.v2.UpdateDeidentifyT
/**
*
* Gets a DeidentifyTemplate.
+ * See https://cloud.google.com/dlp/docs/creating-templates-deid to learn
+ * more.
*
*/
public void getDeidentifyTemplate(com.google.privacy.dlp.v2.GetDeidentifyTemplateRequest request,
@@ -1627,6 +1704,8 @@ public void getDeidentifyTemplate(com.google.privacy.dlp.v2.GetDeidentifyTemplat
/**
*
* Lists DeidentifyTemplates.
+ * See https://cloud.google.com/dlp/docs/creating-templates-deid to learn
+ * more.
*
*/
public void listDeidentifyTemplates(com.google.privacy.dlp.v2.ListDeidentifyTemplatesRequest request,
@@ -1638,6 +1717,8 @@ public void listDeidentifyTemplates(com.google.privacy.dlp.v2.ListDeidentifyTemp
/**
*
* Deletes a DeidentifyTemplate.
+ * See https://cloud.google.com/dlp/docs/creating-templates-deid to learn
+ * more.
*
*/
public void deleteDeidentifyTemplate(com.google.privacy.dlp.v2.DeleteDeidentifyTemplateRequest request,
@@ -1650,6 +1731,7 @@ public void deleteDeidentifyTemplate(com.google.privacy.dlp.v2.DeleteDeidentifyT
*
* Creates a job trigger to run DLP actions such as scanning storage for
* sensitive information on a set schedule.
+ * See https://cloud.google.com/dlp/docs/creating-job-triggers to learn more.
*
*/
public void createJobTrigger(com.google.privacy.dlp.v2.CreateJobTriggerRequest request,
@@ -1661,6 +1743,7 @@ public void createJobTrigger(com.google.privacy.dlp.v2.CreateJobTriggerRequest r
/**
*
* Updates a job trigger.
+ * See https://cloud.google.com/dlp/docs/creating-job-triggers to learn more.
*
*/
public void updateJobTrigger(com.google.privacy.dlp.v2.UpdateJobTriggerRequest request,
@@ -1672,6 +1755,7 @@ public void updateJobTrigger(com.google.privacy.dlp.v2.UpdateJobTriggerRequest r
/**
*
* Gets a job trigger.
+ * See https://cloud.google.com/dlp/docs/creating-job-triggers to learn more.
*
*/
public void getJobTrigger(com.google.privacy.dlp.v2.GetJobTriggerRequest request,
@@ -1683,6 +1767,7 @@ public void getJobTrigger(com.google.privacy.dlp.v2.GetJobTriggerRequest request
/**
*
* Lists job triggers.
+ * See https://cloud.google.com/dlp/docs/creating-job-triggers to learn more.
*
*/
public void listJobTriggers(com.google.privacy.dlp.v2.ListJobTriggersRequest request,
@@ -1694,6 +1779,7 @@ public void listJobTriggers(com.google.privacy.dlp.v2.ListJobTriggersRequest req
/**
*
* Deletes a job trigger.
+ * See https://cloud.google.com/dlp/docs/creating-job-triggers to learn more.
*
*/
public void deleteJobTrigger(com.google.privacy.dlp.v2.DeleteJobTriggerRequest request,
@@ -1705,7 +1791,11 @@ public void deleteJobTrigger(com.google.privacy.dlp.v2.DeleteJobTriggerRequest r
/**
*
* Creates a new job to inspect storage or calculate risk metrics.
- * [How-to guide](/dlp/docs/compute-risk-analysis).
+ * See https://cloud.google.com/dlp/docs/inspecting-storage and
+ * https://cloud.google.com/dlp/docs/compute-risk-analysis to learn more.
+ * When no InfoTypes or CustomInfoTypes are specified in inspect jobs, the
+ * system will automatically choose what detectors to run. By default this may
+ * be all types, but may change over time as detectors are updated.
*
*/
public void createDlpJob(com.google.privacy.dlp.v2.CreateDlpJobRequest request,
@@ -1717,6 +1807,8 @@ public void createDlpJob(com.google.privacy.dlp.v2.CreateDlpJobRequest request,
/**
*
* Lists DlpJobs that match the specified filter in the request.
+ * See https://cloud.google.com/dlp/docs/inspecting-storage and
+ * https://cloud.google.com/dlp/docs/compute-risk-analysis to learn more.
*
*/
public void listDlpJobs(com.google.privacy.dlp.v2.ListDlpJobsRequest request,
@@ -1728,6 +1820,8 @@ public void listDlpJobs(com.google.privacy.dlp.v2.ListDlpJobsRequest request,
/**
*
* Gets the latest state of a long-running DlpJob.
+ * See https://cloud.google.com/dlp/docs/inspecting-storage and
+ * https://cloud.google.com/dlp/docs/compute-risk-analysis to learn more.
*
*/
public void getDlpJob(com.google.privacy.dlp.v2.GetDlpJobRequest request,
@@ -1741,6 +1835,8 @@ public void getDlpJob(com.google.privacy.dlp.v2.GetDlpJobRequest request,
* Deletes a long-running DlpJob. This method indicates that the client is
* no longer interested in the DlpJob result. The job will be cancelled if
* possible.
+ * See https://cloud.google.com/dlp/docs/inspecting-storage and
+ * https://cloud.google.com/dlp/docs/compute-risk-analysis to learn more.
*
*/
public void deleteDlpJob(com.google.privacy.dlp.v2.DeleteDlpJobRequest request,
@@ -1754,6 +1850,8 @@ public void deleteDlpJob(com.google.privacy.dlp.v2.DeleteDlpJobRequest request,
* Starts asynchronous cancellation on a long-running DlpJob. The server
* makes a best effort to cancel the DlpJob, but success is not
* guaranteed.
+ * See https://cloud.google.com/dlp/docs/inspecting-storage and
+ * https://cloud.google.com/dlp/docs/compute-risk-analysis to learn more.
*
*/
public void cancelDlpJob(com.google.privacy.dlp.v2.CancelDlpJobRequest request,
@@ -1771,6 +1869,8 @@ public void cancelDlpJob(com.google.privacy.dlp.v2.CancelDlpJobRequest request,
* blocks or images.
* The service also includes methods for sensitive data redaction and
* scheduling of data scans on Google Cloud Platform based data sets.
+ * To learn more about concepts and find how-to guides see
+ * https://cloud.google.com/dlp/docs/.
*
*/
public static final class DlpServiceBlockingStub extends io.grpc.stub.AbstractStub {
@@ -1793,8 +1893,11 @@ protected DlpServiceBlockingStub build(io.grpc.Channel channel,
*
* Finds potentially sensitive info in content.
* This method has limits on input size, processing time, and output size.
- * [How-to guide for text](/dlp/docs/inspecting-text), [How-to guide for
- * images](/dlp/docs/inspecting-images)
+ * When no InfoTypes or CustomInfoTypes are specified in this request, the
+ * system will automatically choose what detectors to run. By default this may
+ * be all types, but may change over time as detectors are updated.
+ * For how to guides, see https://cloud.google.com/dlp/docs/inspecting-images
+ * and https://cloud.google.com/dlp/docs/inspecting-text,
*
*/
public com.google.privacy.dlp.v2.InspectContentResponse inspectContent(com.google.privacy.dlp.v2.InspectContentRequest request) {
@@ -1806,7 +1909,11 @@ public com.google.privacy.dlp.v2.InspectContentResponse inspectContent(com.googl
*
* Redacts potentially sensitive info from an image.
* This method has limits on input size, processing time, and output size.
- * [How-to guide](/dlp/docs/redacting-sensitive-data-images)
+ * See https://cloud.google.com/dlp/docs/redacting-sensitive-data-images to
+ * learn more.
+ * When no InfoTypes or CustomInfoTypes are specified in this request, the
+ * system will automatically choose what detectors to run. By default this may
+ * be all types, but may change over time as detectors are updated.
*
*/
public com.google.privacy.dlp.v2.RedactImageResponse redactImage(com.google.privacy.dlp.v2.RedactImageRequest request) {
@@ -1818,7 +1925,11 @@ public com.google.privacy.dlp.v2.RedactImageResponse redactImage(com.google.priv
*
* De-identifies potentially sensitive info from a ContentItem.
* This method has limits on input size and output size.
- * [How-to guide](/dlp/docs/deidentify-sensitive-data)
+ * See https://cloud.google.com/dlp/docs/deidentify-sensitive-data to
+ * learn more.
+ * When no InfoTypes or CustomInfoTypes are specified in this request, the
+ * system will automatically choose what detectors to run. By default this may
+ * be all types, but may change over time as detectors are updated.
*
*/
public com.google.privacy.dlp.v2.DeidentifyContentResponse deidentifyContent(com.google.privacy.dlp.v2.DeidentifyContentRequest request) {
@@ -1829,6 +1940,9 @@ public com.google.privacy.dlp.v2.DeidentifyContentResponse deidentifyContent(com
/**
*
* Re-identifies content that has been de-identified.
+ * See
+ * https://cloud.google.com/dlp/docs/pseudonymization#re-identification_in_free_text_code_example
+ * to learn more.
*
*/
public com.google.privacy.dlp.v2.ReidentifyContentResponse reidentifyContent(com.google.privacy.dlp.v2.ReidentifyContentRequest request) {
@@ -1839,8 +1953,8 @@ public com.google.privacy.dlp.v2.ReidentifyContentResponse reidentifyContent(com
/**
*
* Returns a list of the sensitive information types that the DLP API
- * supports. For more information, see [Listing supported predefined
- * infoTypes](/dlp/docs/listing-infotypes).
+ * supports. See https://cloud.google.com/dlp/docs/infotypes-reference to
+ * learn more.
*
*/
public com.google.privacy.dlp.v2.ListInfoTypesResponse listInfoTypes(com.google.privacy.dlp.v2.ListInfoTypesRequest request) {
@@ -1852,6 +1966,7 @@ public com.google.privacy.dlp.v2.ListInfoTypesResponse listInfoTypes(com.google.
*
* Creates an InspectTemplate for re-using frequently used configuration
* for inspecting content, images, and storage.
+ * See https://cloud.google.com/dlp/docs/creating-templates to learn more.
*
*/
public com.google.privacy.dlp.v2.InspectTemplate createInspectTemplate(com.google.privacy.dlp.v2.CreateInspectTemplateRequest request) {
@@ -1862,6 +1977,7 @@ public com.google.privacy.dlp.v2.InspectTemplate createInspectTemplate(com.googl
/**
*
* Updates the InspectTemplate.
+ * See https://cloud.google.com/dlp/docs/creating-templates to learn more.
*
*/
public com.google.privacy.dlp.v2.InspectTemplate updateInspectTemplate(com.google.privacy.dlp.v2.UpdateInspectTemplateRequest request) {
@@ -1872,6 +1988,7 @@ public com.google.privacy.dlp.v2.InspectTemplate updateInspectTemplate(com.googl
/**
*
* Gets an InspectTemplate.
+ * See https://cloud.google.com/dlp/docs/creating-templates to learn more.
*
*/
public com.google.privacy.dlp.v2.InspectTemplate getInspectTemplate(com.google.privacy.dlp.v2.GetInspectTemplateRequest request) {
@@ -1882,6 +1999,7 @@ public com.google.privacy.dlp.v2.InspectTemplate getInspectTemplate(com.google.p
/**
*
* Lists InspectTemplates.
+ * See https://cloud.google.com/dlp/docs/creating-templates to learn more.
*
*/
public com.google.privacy.dlp.v2.ListInspectTemplatesResponse listInspectTemplates(com.google.privacy.dlp.v2.ListInspectTemplatesRequest request) {
@@ -1892,6 +2010,7 @@ public com.google.privacy.dlp.v2.ListInspectTemplatesResponse listInspectTemplat
/**
*
* Deletes an InspectTemplate.
+ * See https://cloud.google.com/dlp/docs/creating-templates to learn more.
*
*/
public com.google.protobuf.Empty deleteInspectTemplate(com.google.privacy.dlp.v2.DeleteInspectTemplateRequest request) {
@@ -1903,6 +2022,8 @@ public com.google.protobuf.Empty deleteInspectTemplate(com.google.privacy.dlp.v2
*
* Creates a DeidentifyTemplate for re-using frequently used configuration
* for de-identifying content, images, and storage.
+ * See https://cloud.google.com/dlp/docs/creating-templates-deid to learn
+ * more.
*
*/
public com.google.privacy.dlp.v2.DeidentifyTemplate createDeidentifyTemplate(com.google.privacy.dlp.v2.CreateDeidentifyTemplateRequest request) {
@@ -1913,6 +2034,8 @@ public com.google.privacy.dlp.v2.DeidentifyTemplate createDeidentifyTemplate(com
/**
*
* Updates the DeidentifyTemplate.
+ * See https://cloud.google.com/dlp/docs/creating-templates-deid to learn
+ * more.
*
*/
public com.google.privacy.dlp.v2.DeidentifyTemplate updateDeidentifyTemplate(com.google.privacy.dlp.v2.UpdateDeidentifyTemplateRequest request) {
@@ -1923,6 +2046,8 @@ public com.google.privacy.dlp.v2.DeidentifyTemplate updateDeidentifyTemplate(com
/**
*
* Gets a DeidentifyTemplate.
+ * See https://cloud.google.com/dlp/docs/creating-templates-deid to learn
+ * more.
*
*/
public com.google.privacy.dlp.v2.DeidentifyTemplate getDeidentifyTemplate(com.google.privacy.dlp.v2.GetDeidentifyTemplateRequest request) {
@@ -1933,6 +2058,8 @@ public com.google.privacy.dlp.v2.DeidentifyTemplate getDeidentifyTemplate(com.go
/**
*
* Lists DeidentifyTemplates.
+ * See https://cloud.google.com/dlp/docs/creating-templates-deid to learn
+ * more.
*
*/
public com.google.privacy.dlp.v2.ListDeidentifyTemplatesResponse listDeidentifyTemplates(com.google.privacy.dlp.v2.ListDeidentifyTemplatesRequest request) {
@@ -1943,6 +2070,8 @@ public com.google.privacy.dlp.v2.ListDeidentifyTemplatesResponse listDeidentifyT
/**
*
* Deletes a DeidentifyTemplate.
+ * See https://cloud.google.com/dlp/docs/creating-templates-deid to learn
+ * more.
*
*/
public com.google.protobuf.Empty deleteDeidentifyTemplate(com.google.privacy.dlp.v2.DeleteDeidentifyTemplateRequest request) {
@@ -1954,6 +2083,7 @@ public com.google.protobuf.Empty deleteDeidentifyTemplate(com.google.privacy.dlp
*
* Creates a job trigger to run DLP actions such as scanning storage for
* sensitive information on a set schedule.
+ * See https://cloud.google.com/dlp/docs/creating-job-triggers to learn more.
*
*/
public com.google.privacy.dlp.v2.JobTrigger createJobTrigger(com.google.privacy.dlp.v2.CreateJobTriggerRequest request) {
@@ -1964,6 +2094,7 @@ public com.google.privacy.dlp.v2.JobTrigger createJobTrigger(com.google.privacy.
/**
*
* Updates a job trigger.
+ * See https://cloud.google.com/dlp/docs/creating-job-triggers to learn more.
*
*/
public com.google.privacy.dlp.v2.JobTrigger updateJobTrigger(com.google.privacy.dlp.v2.UpdateJobTriggerRequest request) {
@@ -1974,6 +2105,7 @@ public com.google.privacy.dlp.v2.JobTrigger updateJobTrigger(com.google.privacy.
/**
*
* Gets a job trigger.
+ * See https://cloud.google.com/dlp/docs/creating-job-triggers to learn more.
*
*/
public com.google.privacy.dlp.v2.JobTrigger getJobTrigger(com.google.privacy.dlp.v2.GetJobTriggerRequest request) {
@@ -1984,6 +2116,7 @@ public com.google.privacy.dlp.v2.JobTrigger getJobTrigger(com.google.privacy.dlp
/**
*
* Lists job triggers.
+ * See https://cloud.google.com/dlp/docs/creating-job-triggers to learn more.
*
*/
public com.google.privacy.dlp.v2.ListJobTriggersResponse listJobTriggers(com.google.privacy.dlp.v2.ListJobTriggersRequest request) {
@@ -1994,6 +2127,7 @@ public com.google.privacy.dlp.v2.ListJobTriggersResponse listJobTriggers(com.goo
/**
*
* Deletes a job trigger.
+ * See https://cloud.google.com/dlp/docs/creating-job-triggers to learn more.
*
*/
public com.google.protobuf.Empty deleteJobTrigger(com.google.privacy.dlp.v2.DeleteJobTriggerRequest request) {
@@ -2004,7 +2138,11 @@ public com.google.protobuf.Empty deleteJobTrigger(com.google.privacy.dlp.v2.Dele
/**
*
* Creates a new job to inspect storage or calculate risk metrics.
- * [How-to guide](/dlp/docs/compute-risk-analysis).
+ * See https://cloud.google.com/dlp/docs/inspecting-storage and
+ * https://cloud.google.com/dlp/docs/compute-risk-analysis to learn more.
+ * When no InfoTypes or CustomInfoTypes are specified in inspect jobs, the
+ * system will automatically choose what detectors to run. By default this may
+ * be all types, but may change over time as detectors are updated.
*
*/
public com.google.privacy.dlp.v2.DlpJob createDlpJob(com.google.privacy.dlp.v2.CreateDlpJobRequest request) {
@@ -2015,6 +2153,8 @@ public com.google.privacy.dlp.v2.DlpJob createDlpJob(com.google.privacy.dlp.v2.C
/**
*
* Lists DlpJobs that match the specified filter in the request.
+ * See https://cloud.google.com/dlp/docs/inspecting-storage and
+ * https://cloud.google.com/dlp/docs/compute-risk-analysis to learn more.
*
*/
public com.google.privacy.dlp.v2.ListDlpJobsResponse listDlpJobs(com.google.privacy.dlp.v2.ListDlpJobsRequest request) {
@@ -2025,6 +2165,8 @@ public com.google.privacy.dlp.v2.ListDlpJobsResponse listDlpJobs(com.google.priv
/**
*
* Gets the latest state of a long-running DlpJob.
+ * See https://cloud.google.com/dlp/docs/inspecting-storage and
+ * https://cloud.google.com/dlp/docs/compute-risk-analysis to learn more.
*
*/
public com.google.privacy.dlp.v2.DlpJob getDlpJob(com.google.privacy.dlp.v2.GetDlpJobRequest request) {
@@ -2037,6 +2179,8 @@ public com.google.privacy.dlp.v2.DlpJob getDlpJob(com.google.privacy.dlp.v2.GetD
* Deletes a long-running DlpJob. This method indicates that the client is
* no longer interested in the DlpJob result. The job will be cancelled if
* possible.
+ * See https://cloud.google.com/dlp/docs/inspecting-storage and
+ * https://cloud.google.com/dlp/docs/compute-risk-analysis to learn more.
*
*/
public com.google.protobuf.Empty deleteDlpJob(com.google.privacy.dlp.v2.DeleteDlpJobRequest request) {
@@ -2049,6 +2193,8 @@ public com.google.protobuf.Empty deleteDlpJob(com.google.privacy.dlp.v2.DeleteDl
* Starts asynchronous cancellation on a long-running DlpJob. The server
* makes a best effort to cancel the DlpJob, but success is not
* guaranteed.
+ * See https://cloud.google.com/dlp/docs/inspecting-storage and
+ * https://cloud.google.com/dlp/docs/compute-risk-analysis to learn more.
*
*/
public com.google.protobuf.Empty cancelDlpJob(com.google.privacy.dlp.v2.CancelDlpJobRequest request) {
@@ -2065,6 +2211,8 @@ public com.google.protobuf.Empty cancelDlpJob(com.google.privacy.dlp.v2.CancelDl
* blocks or images.
* The service also includes methods for sensitive data redaction and
* scheduling of data scans on Google Cloud Platform based data sets.
+ * To learn more about concepts and find how-to guides see
+ * https://cloud.google.com/dlp/docs/.
*
*/
public static final class DlpServiceFutureStub extends io.grpc.stub.AbstractStub {
@@ -2087,8 +2235,11 @@ protected DlpServiceFutureStub build(io.grpc.Channel channel,
*
* Finds potentially sensitive info in content.
* This method has limits on input size, processing time, and output size.
- * [How-to guide for text](/dlp/docs/inspecting-text), [How-to guide for
- * images](/dlp/docs/inspecting-images)
+ * When no InfoTypes or CustomInfoTypes are specified in this request, the
+ * system will automatically choose what detectors to run. By default this may
+ * be all types, but may change over time as detectors are updated.
+ * For how to guides, see https://cloud.google.com/dlp/docs/inspecting-images
+ * and https://cloud.google.com/dlp/docs/inspecting-text,
*
*/
public com.google.common.util.concurrent.ListenableFuture inspectContent(
@@ -2101,7 +2252,11 @@ public com.google.common.util.concurrent.ListenableFuture
* Redacts potentially sensitive info from an image.
* This method has limits on input size, processing time, and output size.
- * [How-to guide](/dlp/docs/redacting-sensitive-data-images)
+ * See https://cloud.google.com/dlp/docs/redacting-sensitive-data-images to
+ * learn more.
+ * When no InfoTypes or CustomInfoTypes are specified in this request, the
+ * system will automatically choose what detectors to run. By default this may
+ * be all types, but may change over time as detectors are updated.
*
*/
public com.google.common.util.concurrent.ListenableFuture redactImage(
@@ -2114,7 +2269,11 @@ public com.google.common.util.concurrent.ListenableFuture
* De-identifies potentially sensitive info from a ContentItem.
* This method has limits on input size and output size.
- * [How-to guide](/dlp/docs/deidentify-sensitive-data)
+ * See https://cloud.google.com/dlp/docs/deidentify-sensitive-data to
+ * learn more.
+ * When no InfoTypes or CustomInfoTypes are specified in this request, the
+ * system will automatically choose what detectors to run. By default this may
+ * be all types, but may change over time as detectors are updated.
*
*/
public com.google.common.util.concurrent.ListenableFuture deidentifyContent(
@@ -2126,6 +2285,9 @@ public com.google.common.util.concurrent.ListenableFuture
* Re-identifies content that has been de-identified.
+ * See
+ * https://cloud.google.com/dlp/docs/pseudonymization#re-identification_in_free_text_code_example
+ * to learn more.
*
*/
public com.google.common.util.concurrent.ListenableFuture reidentifyContent(
@@ -2137,8 +2299,8 @@ public com.google.common.util.concurrent.ListenableFuture
* Returns a list of the sensitive information types that the DLP API
- * supports. For more information, see [Listing supported predefined
- * infoTypes](/dlp/docs/listing-infotypes).
+ * supports. See https://cloud.google.com/dlp/docs/infotypes-reference to
+ * learn more.
*
*/
public com.google.common.util.concurrent.ListenableFuture listInfoTypes(
@@ -2151,6 +2313,7 @@ public com.google.common.util.concurrent.ListenableFuture
* Creates an InspectTemplate for re-using frequently used configuration
* for inspecting content, images, and storage.
+ * See https://cloud.google.com/dlp/docs/creating-templates to learn more.
*
*/
public com.google.common.util.concurrent.ListenableFuture createInspectTemplate(
@@ -2162,6 +2325,7 @@ public com.google.common.util.concurrent.ListenableFuture
* Updates the InspectTemplate.
+ * See https://cloud.google.com/dlp/docs/creating-templates to learn more.
*
*/
public com.google.common.util.concurrent.ListenableFuture updateInspectTemplate(
@@ -2173,6 +2337,7 @@ public com.google.common.util.concurrent.ListenableFuture
* Gets an InspectTemplate.
+ * See https://cloud.google.com/dlp/docs/creating-templates to learn more.
*
*/
public com.google.common.util.concurrent.ListenableFuture getInspectTemplate(
@@ -2184,6 +2349,7 @@ public com.google.common.util.concurrent.ListenableFuture
* Lists InspectTemplates.
+ * See https://cloud.google.com/dlp/docs/creating-templates to learn more.
*
*/
public com.google.common.util.concurrent.ListenableFuture listInspectTemplates(
@@ -2195,6 +2361,7 @@ public com.google.common.util.concurrent.ListenableFuture
* Deletes an InspectTemplate.
+ * See https://cloud.google.com/dlp/docs/creating-templates to learn more.
*
*/
public com.google.common.util.concurrent.ListenableFuture deleteInspectTemplate(
@@ -2207,6 +2374,8 @@ public com.google.common.util.concurrent.ListenableFuture
* Creates a DeidentifyTemplate for re-using frequently used configuration
* for de-identifying content, images, and storage.
+ * See https://cloud.google.com/dlp/docs/creating-templates-deid to learn
+ * more.
*
*/
public com.google.common.util.concurrent.ListenableFuture createDeidentifyTemplate(
@@ -2218,6 +2387,8 @@ public com.google.common.util.concurrent.ListenableFuture
* Updates the DeidentifyTemplate.
+ * See https://cloud.google.com/dlp/docs/creating-templates-deid to learn
+ * more.
*
*/
public com.google.common.util.concurrent.ListenableFuture updateDeidentifyTemplate(
@@ -2229,6 +2400,8 @@ public com.google.common.util.concurrent.ListenableFuture
* Gets a DeidentifyTemplate.
+ * See https://cloud.google.com/dlp/docs/creating-templates-deid to learn
+ * more.
*
*/
public com.google.common.util.concurrent.ListenableFuture getDeidentifyTemplate(
@@ -2240,6 +2413,8 @@ public com.google.common.util.concurrent.ListenableFuture
* Lists DeidentifyTemplates.
+ * See https://cloud.google.com/dlp/docs/creating-templates-deid to learn
+ * more.
*
*/
public com.google.common.util.concurrent.ListenableFuture listDeidentifyTemplates(
@@ -2251,6 +2426,8 @@ public com.google.common.util.concurrent.ListenableFuture
* Deletes a DeidentifyTemplate.
+ * See https://cloud.google.com/dlp/docs/creating-templates-deid to learn
+ * more.
*
*/
public com.google.common.util.concurrent.ListenableFuture deleteDeidentifyTemplate(
@@ -2263,6 +2440,7 @@ public com.google.common.util.concurrent.ListenableFuture
* Creates a job trigger to run DLP actions such as scanning storage for
* sensitive information on a set schedule.
+ * See https://cloud.google.com/dlp/docs/creating-job-triggers to learn more.
*
*/
public com.google.common.util.concurrent.ListenableFuture createJobTrigger(
@@ -2274,6 +2452,7 @@ public com.google.common.util.concurrent.ListenableFuture
* Updates a job trigger.
+ * See https://cloud.google.com/dlp/docs/creating-job-triggers to learn more.
*
*/
public com.google.common.util.concurrent.ListenableFuture updateJobTrigger(
@@ -2285,6 +2464,7 @@ public com.google.common.util.concurrent.ListenableFuture
* Gets a job trigger.
+ * See https://cloud.google.com/dlp/docs/creating-job-triggers to learn more.
*
*/
public com.google.common.util.concurrent.ListenableFuture getJobTrigger(
@@ -2296,6 +2476,7 @@ public com.google.common.util.concurrent.ListenableFuture
* Lists job triggers.
+ * See https://cloud.google.com/dlp/docs/creating-job-triggers to learn more.
*
*/
public com.google.common.util.concurrent.ListenableFuture listJobTriggers(
@@ -2307,6 +2488,7 @@ public com.google.common.util.concurrent.ListenableFuture
* Deletes a job trigger.
+ * See https://cloud.google.com/dlp/docs/creating-job-triggers to learn more.
*
*/
public com.google.common.util.concurrent.ListenableFuture deleteJobTrigger(
@@ -2318,7 +2500,11 @@ public com.google.common.util.concurrent.ListenableFuture
* Creates a new job to inspect storage or calculate risk metrics.
- * [How-to guide](/dlp/docs/compute-risk-analysis).
+ * See https://cloud.google.com/dlp/docs/inspecting-storage and
+ * https://cloud.google.com/dlp/docs/compute-risk-analysis to learn more.
+ * When no InfoTypes or CustomInfoTypes are specified in inspect jobs, the
+ * system will automatically choose what detectors to run. By default this may
+ * be all types, but may change over time as detectors are updated.
*
*/
public com.google.common.util.concurrent.ListenableFuture createDlpJob(
@@ -2330,6 +2516,8 @@ public com.google.common.util.concurrent.ListenableFuture
* Lists DlpJobs that match the specified filter in the request.
+ * See https://cloud.google.com/dlp/docs/inspecting-storage and
+ * https://cloud.google.com/dlp/docs/compute-risk-analysis to learn more.
*
*/
public com.google.common.util.concurrent.ListenableFuture listDlpJobs(
@@ -2341,6 +2529,8 @@ public com.google.common.util.concurrent.ListenableFuture
* Gets the latest state of a long-running DlpJob.
+ * See https://cloud.google.com/dlp/docs/inspecting-storage and
+ * https://cloud.google.com/dlp/docs/compute-risk-analysis to learn more.
*
*/
public com.google.common.util.concurrent.ListenableFuture getDlpJob(
@@ -2354,6 +2544,8 @@ public com.google.common.util.concurrent.ListenableFuture
*/
public com.google.common.util.concurrent.ListenableFuture deleteDlpJob(
@@ -2367,6 +2559,8 @@ public com.google.common.util.concurrent.ListenableFuture
*/
public com.google.common.util.concurrent.ListenableFuture cancelDlpJob(
diff --git a/google-api-grpc/grpc-google-cloud-logging-v2/src/main/java/com/google/logging/v2/LoggingServiceV2Grpc.java b/google-api-grpc/grpc-google-cloud-logging-v2/src/main/java/com/google/logging/v2/LoggingServiceV2Grpc.java
index 9972029726d2..8c154f0bab4b 100644
--- a/google-api-grpc/grpc-google-cloud-logging-v2/src/main/java/com/google/logging/v2/LoggingServiceV2Grpc.java
+++ b/google-api-grpc/grpc-google-cloud-logging-v2/src/main/java/com/google/logging/v2/LoggingServiceV2Grpc.java
@@ -261,12 +261,14 @@ public void deleteLog(com.google.logging.v2.DeleteLogRequest request,
/**
*
- * ## Log entry resources
* Writes log entries to Stackdriver Logging. This API method is the
* only way to send log entries to Stackdriver Logging. This method
* is used, directly or indirectly, by the Stackdriver Logging agent
* (fluentd) and all logging libraries configured to use Stackdriver
* Logging.
+ * A single request may contain log entries for a maximum of 1000
+ * different resources (projects, organizations, billing accounts or
+ * folders)
*
*/
public void writeLogEntries(com.google.logging.v2.WriteLogEntriesRequest request,
@@ -386,12 +388,14 @@ public void deleteLog(com.google.logging.v2.DeleteLogRequest request,
/**
*
- * ## Log entry resources
* Writes log entries to Stackdriver Logging. This API method is the
* only way to send log entries to Stackdriver Logging. This method
* is used, directly or indirectly, by the Stackdriver Logging agent
* (fluentd) and all logging libraries configured to use Stackdriver
* Logging.
+ * A single request may contain log entries for a maximum of 1000
+ * different resources (projects, organizations, billing accounts or
+ * folders)
*
*/
public void writeLogEntries(com.google.logging.v2.WriteLogEntriesRequest request,
@@ -474,12 +478,14 @@ public com.google.protobuf.Empty deleteLog(com.google.logging.v2.DeleteLogReques
/**
*
- * ## Log entry resources
* Writes log entries to Stackdriver Logging. This API method is the
* only way to send log entries to Stackdriver Logging. This method
* is used, directly or indirectly, by the Stackdriver Logging agent
* (fluentd) and all logging libraries configured to use Stackdriver
* Logging.
+ * A single request may contain log entries for a maximum of 1000
+ * different resources (projects, organizations, billing accounts or
+ * folders)
*
*/
public com.google.logging.v2.WriteLogEntriesResponse writeLogEntries(com.google.logging.v2.WriteLogEntriesRequest request) {
@@ -559,12 +565,14 @@ public com.google.common.util.concurrent.ListenableFuture
- * ## Log entry resources
* Writes log entries to Stackdriver Logging. This API method is the
* only way to send log entries to Stackdriver Logging. This method
* is used, directly or indirectly, by the Stackdriver Logging agent
* (fluentd) and all logging libraries configured to use Stackdriver
* Logging.
+ * A single request may contain log entries for a maximum of 1000
+ * different resources (projects, organizations, billing accounts or
+ * folders)
*
*/
public com.google.common.util.concurrent.ListenableFuture writeLogEntries(
diff --git a/google-api-grpc/grpc-google-cloud-tasks-v2beta2/pom.xml b/google-api-grpc/grpc-google-cloud-tasks-v2beta2/pom.xml
new file mode 100644
index 000000000000..e369024eda94
--- /dev/null
+++ b/google-api-grpc/grpc-google-cloud-tasks-v2beta2/pom.xml
@@ -0,0 +1,31 @@
+
+ 4.0.0
+ grpc-google-cloud-tasks-v2beta2
+ 0.18.1-SNAPSHOT
+ grpc-google-cloud-tasks-v2beta2
+ GRPC library for grpc-google-cloud-tasks-v2beta2
+
+ com.google.api.grpc
+ google-api-grpc
+ 0.18.1-SNAPSHOT
+
+
+
+ io.grpc
+ grpc-stub
+ compile
+
+
+ io.grpc
+ grpc-protobuf
+ compile
+
+
+ com.google.api.grpc
+ proto-google-cloud-tasks-v2beta2
+ compile
+
+
+
diff --git a/google-api-grpc/grpc-google-cloud-tasks-v2beta2/src/main/java/com/google/cloud/tasks/v2beta2/CloudTasksGrpc.java b/google-api-grpc/grpc-google-cloud-tasks-v2beta2/src/main/java/com/google/cloud/tasks/v2beta2/CloudTasksGrpc.java
new file mode 100644
index 000000000000..08b5c1c2153a
--- /dev/null
+++ b/google-api-grpc/grpc-google-cloud-tasks-v2beta2/src/main/java/com/google/cloud/tasks/v2beta2/CloudTasksGrpc.java
@@ -0,0 +1,2574 @@
+package com.google.cloud.tasks.v2beta2;
+
+import static io.grpc.MethodDescriptor.generateFullMethodName;
+import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
+import static io.grpc.stub.ClientCalls.asyncClientStreamingCall;
+import static io.grpc.stub.ClientCalls.asyncServerStreamingCall;
+import static io.grpc.stub.ClientCalls.asyncUnaryCall;
+import static io.grpc.stub.ClientCalls.blockingServerStreamingCall;
+import static io.grpc.stub.ClientCalls.blockingUnaryCall;
+import static io.grpc.stub.ClientCalls.futureUnaryCall;
+import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
+import static io.grpc.stub.ServerCalls.asyncClientStreamingCall;
+import static io.grpc.stub.ServerCalls.asyncServerStreamingCall;
+import static io.grpc.stub.ServerCalls.asyncUnaryCall;
+import static io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall;
+import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
+
+/**
+ *
+ * Cloud Tasks allows developers to manage the execution of background
+ * work in their applications.
+ *
+ */
+@javax.annotation.Generated(
+ value = "by gRPC proto compiler (version 1.10.0)",
+ comments = "Source: google/cloud/tasks/v2beta2/cloudtasks.proto")
+public final class CloudTasksGrpc {
+
+ private CloudTasksGrpc() {}
+
+ public static final String SERVICE_NAME = "google.cloud.tasks.v2beta2.CloudTasks";
+
+ // Static method descriptors that strictly reflect the proto.
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ @java.lang.Deprecated // Use {@link #getListQueuesMethod()} instead.
+ public static final io.grpc.MethodDescriptor METHOD_LIST_QUEUES = getListQueuesMethodHelper();
+
+ private static volatile io.grpc.MethodDescriptor getListQueuesMethod;
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ public static io.grpc.MethodDescriptor getListQueuesMethod() {
+ return getListQueuesMethodHelper();
+ }
+
+ private static io.grpc.MethodDescriptor getListQueuesMethodHelper() {
+ io.grpc.MethodDescriptor getListQueuesMethod;
+ if ((getListQueuesMethod = CloudTasksGrpc.getListQueuesMethod) == null) {
+ synchronized (CloudTasksGrpc.class) {
+ if ((getListQueuesMethod = CloudTasksGrpc.getListQueuesMethod) == null) {
+ CloudTasksGrpc.getListQueuesMethod = getListQueuesMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(
+ "google.cloud.tasks.v2beta2.CloudTasks", "ListQueues"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.tasks.v2beta2.ListQueuesRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.tasks.v2beta2.ListQueuesResponse.getDefaultInstance()))
+ .setSchemaDescriptor(new CloudTasksMethodDescriptorSupplier("ListQueues"))
+ .build();
+ }
+ }
+ }
+ return getListQueuesMethod;
+ }
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ @java.lang.Deprecated // Use {@link #getGetQueueMethod()} instead.
+ public static final io.grpc.MethodDescriptor METHOD_GET_QUEUE = getGetQueueMethodHelper();
+
+ private static volatile io.grpc.MethodDescriptor getGetQueueMethod;
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ public static io.grpc.MethodDescriptor getGetQueueMethod() {
+ return getGetQueueMethodHelper();
+ }
+
+ private static io.grpc.MethodDescriptor getGetQueueMethodHelper() {
+ io.grpc.MethodDescriptor getGetQueueMethod;
+ if ((getGetQueueMethod = CloudTasksGrpc.getGetQueueMethod) == null) {
+ synchronized (CloudTasksGrpc.class) {
+ if ((getGetQueueMethod = CloudTasksGrpc.getGetQueueMethod) == null) {
+ CloudTasksGrpc.getGetQueueMethod = getGetQueueMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(
+ "google.cloud.tasks.v2beta2.CloudTasks", "GetQueue"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.tasks.v2beta2.GetQueueRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.tasks.v2beta2.Queue.getDefaultInstance()))
+ .setSchemaDescriptor(new CloudTasksMethodDescriptorSupplier("GetQueue"))
+ .build();
+ }
+ }
+ }
+ return getGetQueueMethod;
+ }
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ @java.lang.Deprecated // Use {@link #getCreateQueueMethod()} instead.
+ public static final io.grpc.MethodDescriptor METHOD_CREATE_QUEUE = getCreateQueueMethodHelper();
+
+ private static volatile io.grpc.MethodDescriptor getCreateQueueMethod;
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ public static io.grpc.MethodDescriptor getCreateQueueMethod() {
+ return getCreateQueueMethodHelper();
+ }
+
+ private static io.grpc.MethodDescriptor getCreateQueueMethodHelper() {
+ io.grpc.MethodDescriptor getCreateQueueMethod;
+ if ((getCreateQueueMethod = CloudTasksGrpc.getCreateQueueMethod) == null) {
+ synchronized (CloudTasksGrpc.class) {
+ if ((getCreateQueueMethod = CloudTasksGrpc.getCreateQueueMethod) == null) {
+ CloudTasksGrpc.getCreateQueueMethod = getCreateQueueMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(
+ "google.cloud.tasks.v2beta2.CloudTasks", "CreateQueue"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.tasks.v2beta2.CreateQueueRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.tasks.v2beta2.Queue.getDefaultInstance()))
+ .setSchemaDescriptor(new CloudTasksMethodDescriptorSupplier("CreateQueue"))
+ .build();
+ }
+ }
+ }
+ return getCreateQueueMethod;
+ }
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ @java.lang.Deprecated // Use {@link #getUpdateQueueMethod()} instead.
+ public static final io.grpc.MethodDescriptor METHOD_UPDATE_QUEUE = getUpdateQueueMethodHelper();
+
+ private static volatile io.grpc.MethodDescriptor getUpdateQueueMethod;
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ public static io.grpc.MethodDescriptor getUpdateQueueMethod() {
+ return getUpdateQueueMethodHelper();
+ }
+
+ private static io.grpc.MethodDescriptor getUpdateQueueMethodHelper() {
+ io.grpc.MethodDescriptor getUpdateQueueMethod;
+ if ((getUpdateQueueMethod = CloudTasksGrpc.getUpdateQueueMethod) == null) {
+ synchronized (CloudTasksGrpc.class) {
+ if ((getUpdateQueueMethod = CloudTasksGrpc.getUpdateQueueMethod) == null) {
+ CloudTasksGrpc.getUpdateQueueMethod = getUpdateQueueMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(
+ "google.cloud.tasks.v2beta2.CloudTasks", "UpdateQueue"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.tasks.v2beta2.UpdateQueueRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.tasks.v2beta2.Queue.getDefaultInstance()))
+ .setSchemaDescriptor(new CloudTasksMethodDescriptorSupplier("UpdateQueue"))
+ .build();
+ }
+ }
+ }
+ return getUpdateQueueMethod;
+ }
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ @java.lang.Deprecated // Use {@link #getDeleteQueueMethod()} instead.
+ public static final io.grpc.MethodDescriptor METHOD_DELETE_QUEUE = getDeleteQueueMethodHelper();
+
+ private static volatile io.grpc.MethodDescriptor getDeleteQueueMethod;
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ public static io.grpc.MethodDescriptor getDeleteQueueMethod() {
+ return getDeleteQueueMethodHelper();
+ }
+
+ private static io.grpc.MethodDescriptor getDeleteQueueMethodHelper() {
+ io.grpc.MethodDescriptor getDeleteQueueMethod;
+ if ((getDeleteQueueMethod = CloudTasksGrpc.getDeleteQueueMethod) == null) {
+ synchronized (CloudTasksGrpc.class) {
+ if ((getDeleteQueueMethod = CloudTasksGrpc.getDeleteQueueMethod) == null) {
+ CloudTasksGrpc.getDeleteQueueMethod = getDeleteQueueMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(
+ "google.cloud.tasks.v2beta2.CloudTasks", "DeleteQueue"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.tasks.v2beta2.DeleteQueueRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.protobuf.Empty.getDefaultInstance()))
+ .setSchemaDescriptor(new CloudTasksMethodDescriptorSupplier("DeleteQueue"))
+ .build();
+ }
+ }
+ }
+ return getDeleteQueueMethod;
+ }
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ @java.lang.Deprecated // Use {@link #getPurgeQueueMethod()} instead.
+ public static final io.grpc.MethodDescriptor METHOD_PURGE_QUEUE = getPurgeQueueMethodHelper();
+
+ private static volatile io.grpc.MethodDescriptor getPurgeQueueMethod;
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ public static io.grpc.MethodDescriptor getPurgeQueueMethod() {
+ return getPurgeQueueMethodHelper();
+ }
+
+ private static io.grpc.MethodDescriptor getPurgeQueueMethodHelper() {
+ io.grpc.MethodDescriptor getPurgeQueueMethod;
+ if ((getPurgeQueueMethod = CloudTasksGrpc.getPurgeQueueMethod) == null) {
+ synchronized (CloudTasksGrpc.class) {
+ if ((getPurgeQueueMethod = CloudTasksGrpc.getPurgeQueueMethod) == null) {
+ CloudTasksGrpc.getPurgeQueueMethod = getPurgeQueueMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(
+ "google.cloud.tasks.v2beta2.CloudTasks", "PurgeQueue"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.tasks.v2beta2.PurgeQueueRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.tasks.v2beta2.Queue.getDefaultInstance()))
+ .setSchemaDescriptor(new CloudTasksMethodDescriptorSupplier("PurgeQueue"))
+ .build();
+ }
+ }
+ }
+ return getPurgeQueueMethod;
+ }
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ @java.lang.Deprecated // Use {@link #getPauseQueueMethod()} instead.
+ public static final io.grpc.MethodDescriptor METHOD_PAUSE_QUEUE = getPauseQueueMethodHelper();
+
+ private static volatile io.grpc.MethodDescriptor getPauseQueueMethod;
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ public static io.grpc.MethodDescriptor getPauseQueueMethod() {
+ return getPauseQueueMethodHelper();
+ }
+
+ private static io.grpc.MethodDescriptor getPauseQueueMethodHelper() {
+ io.grpc.MethodDescriptor getPauseQueueMethod;
+ if ((getPauseQueueMethod = CloudTasksGrpc.getPauseQueueMethod) == null) {
+ synchronized (CloudTasksGrpc.class) {
+ if ((getPauseQueueMethod = CloudTasksGrpc.getPauseQueueMethod) == null) {
+ CloudTasksGrpc.getPauseQueueMethod = getPauseQueueMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(
+ "google.cloud.tasks.v2beta2.CloudTasks", "PauseQueue"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.tasks.v2beta2.PauseQueueRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.tasks.v2beta2.Queue.getDefaultInstance()))
+ .setSchemaDescriptor(new CloudTasksMethodDescriptorSupplier("PauseQueue"))
+ .build();
+ }
+ }
+ }
+ return getPauseQueueMethod;
+ }
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ @java.lang.Deprecated // Use {@link #getResumeQueueMethod()} instead.
+ public static final io.grpc.MethodDescriptor METHOD_RESUME_QUEUE = getResumeQueueMethodHelper();
+
+ private static volatile io.grpc.MethodDescriptor getResumeQueueMethod;
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ public static io.grpc.MethodDescriptor getResumeQueueMethod() {
+ return getResumeQueueMethodHelper();
+ }
+
+ private static io.grpc.MethodDescriptor getResumeQueueMethodHelper() {
+ io.grpc.MethodDescriptor getResumeQueueMethod;
+ if ((getResumeQueueMethod = CloudTasksGrpc.getResumeQueueMethod) == null) {
+ synchronized (CloudTasksGrpc.class) {
+ if ((getResumeQueueMethod = CloudTasksGrpc.getResumeQueueMethod) == null) {
+ CloudTasksGrpc.getResumeQueueMethod = getResumeQueueMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(
+ "google.cloud.tasks.v2beta2.CloudTasks", "ResumeQueue"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.tasks.v2beta2.ResumeQueueRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.tasks.v2beta2.Queue.getDefaultInstance()))
+ .setSchemaDescriptor(new CloudTasksMethodDescriptorSupplier("ResumeQueue"))
+ .build();
+ }
+ }
+ }
+ return getResumeQueueMethod;
+ }
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ @java.lang.Deprecated // Use {@link #getGetIamPolicyMethod()} instead.
+ public static final io.grpc.MethodDescriptor METHOD_GET_IAM_POLICY = getGetIamPolicyMethodHelper();
+
+ private static volatile io.grpc.MethodDescriptor getGetIamPolicyMethod;
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ public static io.grpc.MethodDescriptor getGetIamPolicyMethod() {
+ return getGetIamPolicyMethodHelper();
+ }
+
+ private static io.grpc.MethodDescriptor getGetIamPolicyMethodHelper() {
+ io.grpc.MethodDescriptor getGetIamPolicyMethod;
+ if ((getGetIamPolicyMethod = CloudTasksGrpc.getGetIamPolicyMethod) == null) {
+ synchronized (CloudTasksGrpc.class) {
+ if ((getGetIamPolicyMethod = CloudTasksGrpc.getGetIamPolicyMethod) == null) {
+ CloudTasksGrpc.getGetIamPolicyMethod = getGetIamPolicyMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(
+ "google.cloud.tasks.v2beta2.CloudTasks", "GetIamPolicy"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.iam.v1.GetIamPolicyRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.iam.v1.Policy.getDefaultInstance()))
+ .setSchemaDescriptor(new CloudTasksMethodDescriptorSupplier("GetIamPolicy"))
+ .build();
+ }
+ }
+ }
+ return getGetIamPolicyMethod;
+ }
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ @java.lang.Deprecated // Use {@link #getSetIamPolicyMethod()} instead.
+ public static final io.grpc.MethodDescriptor METHOD_SET_IAM_POLICY = getSetIamPolicyMethodHelper();
+
+ private static volatile io.grpc.MethodDescriptor getSetIamPolicyMethod;
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ public static io.grpc.MethodDescriptor getSetIamPolicyMethod() {
+ return getSetIamPolicyMethodHelper();
+ }
+
+ private static io.grpc.MethodDescriptor getSetIamPolicyMethodHelper() {
+ io.grpc.MethodDescriptor getSetIamPolicyMethod;
+ if ((getSetIamPolicyMethod = CloudTasksGrpc.getSetIamPolicyMethod) == null) {
+ synchronized (CloudTasksGrpc.class) {
+ if ((getSetIamPolicyMethod = CloudTasksGrpc.getSetIamPolicyMethod) == null) {
+ CloudTasksGrpc.getSetIamPolicyMethod = getSetIamPolicyMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(
+ "google.cloud.tasks.v2beta2.CloudTasks", "SetIamPolicy"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.iam.v1.SetIamPolicyRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.iam.v1.Policy.getDefaultInstance()))
+ .setSchemaDescriptor(new CloudTasksMethodDescriptorSupplier("SetIamPolicy"))
+ .build();
+ }
+ }
+ }
+ return getSetIamPolicyMethod;
+ }
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ @java.lang.Deprecated // Use {@link #getTestIamPermissionsMethod()} instead.
+ public static final io.grpc.MethodDescriptor METHOD_TEST_IAM_PERMISSIONS = getTestIamPermissionsMethodHelper();
+
+ private static volatile io.grpc.MethodDescriptor getTestIamPermissionsMethod;
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ public static io.grpc.MethodDescriptor getTestIamPermissionsMethod() {
+ return getTestIamPermissionsMethodHelper();
+ }
+
+ private static io.grpc.MethodDescriptor getTestIamPermissionsMethodHelper() {
+ io.grpc.MethodDescriptor getTestIamPermissionsMethod;
+ if ((getTestIamPermissionsMethod = CloudTasksGrpc.getTestIamPermissionsMethod) == null) {
+ synchronized (CloudTasksGrpc.class) {
+ if ((getTestIamPermissionsMethod = CloudTasksGrpc.getTestIamPermissionsMethod) == null) {
+ CloudTasksGrpc.getTestIamPermissionsMethod = getTestIamPermissionsMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(
+ "google.cloud.tasks.v2beta2.CloudTasks", "TestIamPermissions"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.iam.v1.TestIamPermissionsRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.iam.v1.TestIamPermissionsResponse.getDefaultInstance()))
+ .setSchemaDescriptor(new CloudTasksMethodDescriptorSupplier("TestIamPermissions"))
+ .build();
+ }
+ }
+ }
+ return getTestIamPermissionsMethod;
+ }
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ @java.lang.Deprecated // Use {@link #getListTasksMethod()} instead.
+ public static final io.grpc.MethodDescriptor METHOD_LIST_TASKS = getListTasksMethodHelper();
+
+ private static volatile io.grpc.MethodDescriptor getListTasksMethod;
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ public static io.grpc.MethodDescriptor getListTasksMethod() {
+ return getListTasksMethodHelper();
+ }
+
+ private static io.grpc.MethodDescriptor getListTasksMethodHelper() {
+ io.grpc.MethodDescriptor getListTasksMethod;
+ if ((getListTasksMethod = CloudTasksGrpc.getListTasksMethod) == null) {
+ synchronized (CloudTasksGrpc.class) {
+ if ((getListTasksMethod = CloudTasksGrpc.getListTasksMethod) == null) {
+ CloudTasksGrpc.getListTasksMethod = getListTasksMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(
+ "google.cloud.tasks.v2beta2.CloudTasks", "ListTasks"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.tasks.v2beta2.ListTasksRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.tasks.v2beta2.ListTasksResponse.getDefaultInstance()))
+ .setSchemaDescriptor(new CloudTasksMethodDescriptorSupplier("ListTasks"))
+ .build();
+ }
+ }
+ }
+ return getListTasksMethod;
+ }
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ @java.lang.Deprecated // Use {@link #getGetTaskMethod()} instead.
+ public static final io.grpc.MethodDescriptor METHOD_GET_TASK = getGetTaskMethodHelper();
+
+ private static volatile io.grpc.MethodDescriptor getGetTaskMethod;
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ public static io.grpc.MethodDescriptor getGetTaskMethod() {
+ return getGetTaskMethodHelper();
+ }
+
+ private static io.grpc.MethodDescriptor getGetTaskMethodHelper() {
+ io.grpc.MethodDescriptor getGetTaskMethod;
+ if ((getGetTaskMethod = CloudTasksGrpc.getGetTaskMethod) == null) {
+ synchronized (CloudTasksGrpc.class) {
+ if ((getGetTaskMethod = CloudTasksGrpc.getGetTaskMethod) == null) {
+ CloudTasksGrpc.getGetTaskMethod = getGetTaskMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(
+ "google.cloud.tasks.v2beta2.CloudTasks", "GetTask"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.tasks.v2beta2.GetTaskRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.tasks.v2beta2.Task.getDefaultInstance()))
+ .setSchemaDescriptor(new CloudTasksMethodDescriptorSupplier("GetTask"))
+ .build();
+ }
+ }
+ }
+ return getGetTaskMethod;
+ }
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ @java.lang.Deprecated // Use {@link #getCreateTaskMethod()} instead.
+ public static final io.grpc.MethodDescriptor METHOD_CREATE_TASK = getCreateTaskMethodHelper();
+
+ private static volatile io.grpc.MethodDescriptor getCreateTaskMethod;
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ public static io.grpc.MethodDescriptor getCreateTaskMethod() {
+ return getCreateTaskMethodHelper();
+ }
+
+ private static io.grpc.MethodDescriptor getCreateTaskMethodHelper() {
+ io.grpc.MethodDescriptor getCreateTaskMethod;
+ if ((getCreateTaskMethod = CloudTasksGrpc.getCreateTaskMethod) == null) {
+ synchronized (CloudTasksGrpc.class) {
+ if ((getCreateTaskMethod = CloudTasksGrpc.getCreateTaskMethod) == null) {
+ CloudTasksGrpc.getCreateTaskMethod = getCreateTaskMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(
+ "google.cloud.tasks.v2beta2.CloudTasks", "CreateTask"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.tasks.v2beta2.CreateTaskRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.tasks.v2beta2.Task.getDefaultInstance()))
+ .setSchemaDescriptor(new CloudTasksMethodDescriptorSupplier("CreateTask"))
+ .build();
+ }
+ }
+ }
+ return getCreateTaskMethod;
+ }
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ @java.lang.Deprecated // Use {@link #getDeleteTaskMethod()} instead.
+ public static final io.grpc.MethodDescriptor METHOD_DELETE_TASK = getDeleteTaskMethodHelper();
+
+ private static volatile io.grpc.MethodDescriptor getDeleteTaskMethod;
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ public static io.grpc.MethodDescriptor getDeleteTaskMethod() {
+ return getDeleteTaskMethodHelper();
+ }
+
+ private static io.grpc.MethodDescriptor getDeleteTaskMethodHelper() {
+ io.grpc.MethodDescriptor getDeleteTaskMethod;
+ if ((getDeleteTaskMethod = CloudTasksGrpc.getDeleteTaskMethod) == null) {
+ synchronized (CloudTasksGrpc.class) {
+ if ((getDeleteTaskMethod = CloudTasksGrpc.getDeleteTaskMethod) == null) {
+ CloudTasksGrpc.getDeleteTaskMethod = getDeleteTaskMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(
+ "google.cloud.tasks.v2beta2.CloudTasks", "DeleteTask"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.tasks.v2beta2.DeleteTaskRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.protobuf.Empty.getDefaultInstance()))
+ .setSchemaDescriptor(new CloudTasksMethodDescriptorSupplier("DeleteTask"))
+ .build();
+ }
+ }
+ }
+ return getDeleteTaskMethod;
+ }
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ @java.lang.Deprecated // Use {@link #getLeaseTasksMethod()} instead.
+ public static final io.grpc.MethodDescriptor METHOD_LEASE_TASKS = getLeaseTasksMethodHelper();
+
+ private static volatile io.grpc.MethodDescriptor getLeaseTasksMethod;
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ public static io.grpc.MethodDescriptor getLeaseTasksMethod() {
+ return getLeaseTasksMethodHelper();
+ }
+
+ private static io.grpc.MethodDescriptor getLeaseTasksMethodHelper() {
+ io.grpc.MethodDescriptor getLeaseTasksMethod;
+ if ((getLeaseTasksMethod = CloudTasksGrpc.getLeaseTasksMethod) == null) {
+ synchronized (CloudTasksGrpc.class) {
+ if ((getLeaseTasksMethod = CloudTasksGrpc.getLeaseTasksMethod) == null) {
+ CloudTasksGrpc.getLeaseTasksMethod = getLeaseTasksMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(
+ "google.cloud.tasks.v2beta2.CloudTasks", "LeaseTasks"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.tasks.v2beta2.LeaseTasksRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.tasks.v2beta2.LeaseTasksResponse.getDefaultInstance()))
+ .setSchemaDescriptor(new CloudTasksMethodDescriptorSupplier("LeaseTasks"))
+ .build();
+ }
+ }
+ }
+ return getLeaseTasksMethod;
+ }
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ @java.lang.Deprecated // Use {@link #getAcknowledgeTaskMethod()} instead.
+ public static final io.grpc.MethodDescriptor METHOD_ACKNOWLEDGE_TASK = getAcknowledgeTaskMethodHelper();
+
+ private static volatile io.grpc.MethodDescriptor getAcknowledgeTaskMethod;
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ public static io.grpc.MethodDescriptor getAcknowledgeTaskMethod() {
+ return getAcknowledgeTaskMethodHelper();
+ }
+
+ private static io.grpc.MethodDescriptor getAcknowledgeTaskMethodHelper() {
+ io.grpc.MethodDescriptor getAcknowledgeTaskMethod;
+ if ((getAcknowledgeTaskMethod = CloudTasksGrpc.getAcknowledgeTaskMethod) == null) {
+ synchronized (CloudTasksGrpc.class) {
+ if ((getAcknowledgeTaskMethod = CloudTasksGrpc.getAcknowledgeTaskMethod) == null) {
+ CloudTasksGrpc.getAcknowledgeTaskMethod = getAcknowledgeTaskMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(
+ "google.cloud.tasks.v2beta2.CloudTasks", "AcknowledgeTask"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.tasks.v2beta2.AcknowledgeTaskRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.protobuf.Empty.getDefaultInstance()))
+ .setSchemaDescriptor(new CloudTasksMethodDescriptorSupplier("AcknowledgeTask"))
+ .build();
+ }
+ }
+ }
+ return getAcknowledgeTaskMethod;
+ }
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ @java.lang.Deprecated // Use {@link #getRenewLeaseMethod()} instead.
+ public static final io.grpc.MethodDescriptor METHOD_RENEW_LEASE = getRenewLeaseMethodHelper();
+
+ private static volatile io.grpc.MethodDescriptor getRenewLeaseMethod;
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ public static io.grpc.MethodDescriptor getRenewLeaseMethod() {
+ return getRenewLeaseMethodHelper();
+ }
+
+ private static io.grpc.MethodDescriptor getRenewLeaseMethodHelper() {
+ io.grpc.MethodDescriptor getRenewLeaseMethod;
+ if ((getRenewLeaseMethod = CloudTasksGrpc.getRenewLeaseMethod) == null) {
+ synchronized (CloudTasksGrpc.class) {
+ if ((getRenewLeaseMethod = CloudTasksGrpc.getRenewLeaseMethod) == null) {
+ CloudTasksGrpc.getRenewLeaseMethod = getRenewLeaseMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(
+ "google.cloud.tasks.v2beta2.CloudTasks", "RenewLease"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.tasks.v2beta2.RenewLeaseRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.tasks.v2beta2.Task.getDefaultInstance()))
+ .setSchemaDescriptor(new CloudTasksMethodDescriptorSupplier("RenewLease"))
+ .build();
+ }
+ }
+ }
+ return getRenewLeaseMethod;
+ }
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ @java.lang.Deprecated // Use {@link #getCancelLeaseMethod()} instead.
+ public static final io.grpc.MethodDescriptor METHOD_CANCEL_LEASE = getCancelLeaseMethodHelper();
+
+ private static volatile io.grpc.MethodDescriptor getCancelLeaseMethod;
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ public static io.grpc.MethodDescriptor getCancelLeaseMethod() {
+ return getCancelLeaseMethodHelper();
+ }
+
+ private static io.grpc.MethodDescriptor getCancelLeaseMethodHelper() {
+ io.grpc.MethodDescriptor getCancelLeaseMethod;
+ if ((getCancelLeaseMethod = CloudTasksGrpc.getCancelLeaseMethod) == null) {
+ synchronized (CloudTasksGrpc.class) {
+ if ((getCancelLeaseMethod = CloudTasksGrpc.getCancelLeaseMethod) == null) {
+ CloudTasksGrpc.getCancelLeaseMethod = getCancelLeaseMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(
+ "google.cloud.tasks.v2beta2.CloudTasks", "CancelLease"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.tasks.v2beta2.CancelLeaseRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.tasks.v2beta2.Task.getDefaultInstance()))
+ .setSchemaDescriptor(new CloudTasksMethodDescriptorSupplier("CancelLease"))
+ .build();
+ }
+ }
+ }
+ return getCancelLeaseMethod;
+ }
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ @java.lang.Deprecated // Use {@link #getRunTaskMethod()} instead.
+ public static final io.grpc.MethodDescriptor METHOD_RUN_TASK = getRunTaskMethodHelper();
+
+ private static volatile io.grpc.MethodDescriptor getRunTaskMethod;
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ public static io.grpc.MethodDescriptor getRunTaskMethod() {
+ return getRunTaskMethodHelper();
+ }
+
+ private static io.grpc.MethodDescriptor getRunTaskMethodHelper() {
+ io.grpc.MethodDescriptor getRunTaskMethod;
+ if ((getRunTaskMethod = CloudTasksGrpc.getRunTaskMethod) == null) {
+ synchronized (CloudTasksGrpc.class) {
+ if ((getRunTaskMethod = CloudTasksGrpc.getRunTaskMethod) == null) {
+ CloudTasksGrpc.getRunTaskMethod = getRunTaskMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(
+ "google.cloud.tasks.v2beta2.CloudTasks", "RunTask"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.tasks.v2beta2.RunTaskRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.tasks.v2beta2.Task.getDefaultInstance()))
+ .setSchemaDescriptor(new CloudTasksMethodDescriptorSupplier("RunTask"))
+ .build();
+ }
+ }
+ }
+ return getRunTaskMethod;
+ }
+
+ /**
+ * Creates a new async stub that supports all call types for the service
+ */
+ public static CloudTasksStub newStub(io.grpc.Channel channel) {
+ return new CloudTasksStub(channel);
+ }
+
+ /**
+ * Creates a new blocking-style stub that supports unary and streaming output calls on the service
+ */
+ public static CloudTasksBlockingStub newBlockingStub(
+ io.grpc.Channel channel) {
+ return new CloudTasksBlockingStub(channel);
+ }
+
+ /**
+ * Creates a new ListenableFuture-style stub that supports unary calls on the service
+ */
+ public static CloudTasksFutureStub newFutureStub(
+ io.grpc.Channel channel) {
+ return new CloudTasksFutureStub(channel);
+ }
+
+ /**
+ *
+ * Cloud Tasks allows developers to manage the execution of background
+ * work in their applications.
+ *
+ */
+ public static abstract class CloudTasksImplBase implements io.grpc.BindableService {
+
+ /**
+ *
+ * Lists queues.
+ * Queues are returned in lexicographical order.
+ *
+ */
+ public void listQueues(com.google.cloud.tasks.v2beta2.ListQueuesRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnimplementedUnaryCall(getListQueuesMethodHelper(), responseObserver);
+ }
+
+ /**
+ *
+ * Gets a queue.
+ *
+ */
+ public void getQueue(com.google.cloud.tasks.v2beta2.GetQueueRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnimplementedUnaryCall(getGetQueueMethodHelper(), responseObserver);
+ }
+
+ /**
+ *
+ * Creates a queue.
+ * Queues created with this method allow tasks to live for a maximum of 31
+ * days. After a task is 31 days old, the task will be deleted regardless of whether
+ * it was dispatched or not.
+ * WARNING: Using this method may have unintended side effects if you are
+ * using an App Engine `queue.yaml` or `queue.xml` file to manage your queues.
+ * Read
+ * [Overview of Queue Management and queue.yaml](/cloud-tasks/docs/queue-yaml)
+ * before using this method.
+ *
+ */
+ public void createQueue(com.google.cloud.tasks.v2beta2.CreateQueueRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnimplementedUnaryCall(getCreateQueueMethodHelper(), responseObserver);
+ }
+
+ /**
+ *
+ * Updates a queue.
+ * This method creates the queue if it does not exist and updates
+ * the queue if it does exist.
+ * Queues created with this method allow tasks to live for a maximum of 31
+ * days. After a task is 31 days old, the task will be deleted regardless of whether
+ * it was dispatched or not.
+ * WARNING: Using this method may have unintended side effects if you are
+ * using an App Engine `queue.yaml` or `queue.xml` file to manage your queues.
+ * Read
+ * [Overview of Queue Management and queue.yaml](/cloud-tasks/docs/queue-yaml)
+ * before using this method.
+ *
+ */
+ public void updateQueue(com.google.cloud.tasks.v2beta2.UpdateQueueRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnimplementedUnaryCall(getUpdateQueueMethodHelper(), responseObserver);
+ }
+
+ /**
+ *
+ * Deletes a queue.
+ * This command will delete the queue even if it has tasks in it.
+ * Note: If you delete a queue, a queue with the same name can't be created
+ * for 7 days.
+ * WARNING: Using this method may have unintended side effects if you are
+ * using an App Engine `queue.yaml` or `queue.xml` file to manage your queues.
+ * Read
+ * [Overview of Queue Management and queue.yaml](/cloud-tasks/docs/queue-yaml)
+ * before using this method.
+ *
+ */
+ public void deleteQueue(com.google.cloud.tasks.v2beta2.DeleteQueueRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnimplementedUnaryCall(getDeleteQueueMethodHelper(), responseObserver);
+ }
+
+ /**
+ *
+ * Purges a queue by deleting all of its tasks.
+ * All tasks created before this method is called are permanently deleted.
+ * Purge operations can take up to one minute to take effect. Tasks
+ * might be dispatched before the purge takes effect. A purge is irreversible.
+ *
+ */
+ public void purgeQueue(com.google.cloud.tasks.v2beta2.PurgeQueueRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnimplementedUnaryCall(getPurgeQueueMethodHelper(), responseObserver);
+ }
+
+ /**
+ *
+ * Pauses the queue.
+ * If a queue is paused then the system will stop dispatching tasks
+ * until the queue is resumed via
+ * [ResumeQueue][google.cloud.tasks.v2beta2.CloudTasks.ResumeQueue]. Tasks can still be added
+ * when the queue is paused. A queue is paused if its
+ * [state][google.cloud.tasks.v2beta2.Queue.state] is [PAUSED][google.cloud.tasks.v2beta2.Queue.State.PAUSED].
+ *
+ */
+ public void pauseQueue(com.google.cloud.tasks.v2beta2.PauseQueueRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnimplementedUnaryCall(getPauseQueueMethodHelper(), responseObserver);
+ }
+
+ /**
+ *
+ * Resume a queue.
+ * This method resumes a queue after it has been
+ * [PAUSED][google.cloud.tasks.v2beta2.Queue.State.PAUSED] or
+ * [DISABLED][google.cloud.tasks.v2beta2.Queue.State.DISABLED]. The state of a queue is stored
+ * in the queue's [state][google.cloud.tasks.v2beta2.Queue.state]; after calling this method it
+ * will be set to [RUNNING][google.cloud.tasks.v2beta2.Queue.State.RUNNING].
+ * WARNING: Resuming many high-QPS queues at the same time can
+ * lead to target overloading. If you are resuming high-QPS
+ * queues, follow the 500/50/5 pattern described in
+ * [Managing Cloud Tasks Scaling Risks](/cloud-tasks/pdfs/managing-cloud-tasks-scaling-risks-2017-06-05.pdf).
+ *
+ */
+ public void resumeQueue(com.google.cloud.tasks.v2beta2.ResumeQueueRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnimplementedUnaryCall(getResumeQueueMethodHelper(), responseObserver);
+ }
+
+ /**
+ *
+ * Gets the access control policy for a [Queue][google.cloud.tasks.v2beta2.Queue].
+ * Returns an empty policy if the resource exists and does not have a policy
+ * set.
+ * Authorization requires the following [Google IAM](/iam) permission on the
+ * specified resource parent:
+ * * `cloudtasks.queues.getIamPolicy`
+ *
+ */
+ public void getIamPolicy(com.google.iam.v1.GetIamPolicyRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnimplementedUnaryCall(getGetIamPolicyMethodHelper(), responseObserver);
+ }
+
+ /**
+ *
+ * Sets the access control policy for a [Queue][google.cloud.tasks.v2beta2.Queue]. Replaces any existing
+ * policy.
+ * Note: The Cloud Console does not check queue-level IAM permissions yet.
+ * Project-level permissions are required to use the Cloud Console.
+ * Authorization requires the following [Google IAM](/iam) permission on the
+ * specified resource parent:
+ * * `cloudtasks.queues.setIamPolicy`
+ *
+ */
+ public void setIamPolicy(com.google.iam.v1.SetIamPolicyRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnimplementedUnaryCall(getSetIamPolicyMethodHelper(), responseObserver);
+ }
+
+ /**
+ *
+ * Returns permissions that a caller has on a [Queue][google.cloud.tasks.v2beta2.Queue].
+ * If the resource does not exist, this will return an empty set of
+ * permissions, not a [NOT_FOUND][google.rpc.Code.NOT_FOUND] error.
+ * Note: This operation is designed to be used for building permission-aware
+ * UIs and command-line tools, not for authorization checking. This operation
+ * may "fail open" without warning.
+ *
+ */
+ public void testIamPermissions(com.google.iam.v1.TestIamPermissionsRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnimplementedUnaryCall(getTestIamPermissionsMethodHelper(), responseObserver);
+ }
+
+ /**
+ *
+ * Lists the tasks in a queue.
+ * By default, only the [BASIC][google.cloud.tasks.v2beta2.Task.View.BASIC] view is retrieved
+ * due to performance considerations;
+ * [response_view][google.cloud.tasks.v2beta2.ListTasksRequest.response_view] controls the
+ * subset of information which is returned.
+ *
+ */
+ public void listTasks(com.google.cloud.tasks.v2beta2.ListTasksRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnimplementedUnaryCall(getListTasksMethodHelper(), responseObserver);
+ }
+
+ /**
+ *
+ * Gets a task.
+ *
+ */
+ public void getTask(com.google.cloud.tasks.v2beta2.GetTaskRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnimplementedUnaryCall(getGetTaskMethodHelper(), responseObserver);
+ }
+
+ /**
+ *
+ * Creates a task and adds it to a queue.
+ * Tasks cannot be updated after creation; there is no UpdateTask command.
+ * * For [App Engine queues](google.cloud.tasks.v2beta2.AppEngineHttpTarget),
+ * the maximum task size is 100KB.
+ * * For [pull queues](google.cloud.tasks.v2beta2.PullTarget), this
+ * the maximum task size is 1MB.
+ *
+ */
+ public void createTask(com.google.cloud.tasks.v2beta2.CreateTaskRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnimplementedUnaryCall(getCreateTaskMethodHelper(), responseObserver);
+ }
+
+ /**
+ *
+ * Deletes a task.
+ * A task can be deleted if it is scheduled or dispatched. A task
+ * cannot be deleted if it has completed successfully or permanently
+ * failed.
+ *
+ */
+ public void deleteTask(com.google.cloud.tasks.v2beta2.DeleteTaskRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnimplementedUnaryCall(getDeleteTaskMethodHelper(), responseObserver);
+ }
+
+ /**
+ *
+ * Leases tasks from a pull queue for
+ * [lease_duration][google.cloud.tasks.v2beta2.LeaseTasksRequest.lease_duration].
+ * This method is invoked by the worker to obtain a lease. The
+ * worker must acknowledge the task via
+ * [AcknowledgeTask][google.cloud.tasks.v2beta2.CloudTasks.AcknowledgeTask] after they have
+ * performed the work associated with the task.
+ * The [payload][google.cloud.tasks.v2beta2.PullMessage.payload] is intended to store data that
+ * the worker needs to perform the work associated with the task. To
+ * return the payloads in the [response][google.cloud.tasks.v2beta2.LeaseTasksResponse], set
+ * [response_view][google.cloud.tasks.v2beta2.LeaseTasksRequest.response_view] to
+ * [FULL][google.cloud.tasks.v2beta2.Task.View.FULL].
+ * A maximum of 10 qps of [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks]
+ * requests are allowed per
+ * queue. [RESOURCE_EXHAUSTED][google.rpc.Code.RESOURCE_EXHAUSTED]
+ * is returned when this limit is
+ * exceeded. [RESOURCE_EXHAUSTED][google.rpc.Code.RESOURCE_EXHAUSTED]
+ * is also returned when
+ * [max_tasks_dispatched_per_second][google.cloud.tasks.v2beta2.RateLimits.max_tasks_dispatched_per_second]
+ * is exceeded.
+ *
+ */
+ public void leaseTasks(com.google.cloud.tasks.v2beta2.LeaseTasksRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnimplementedUnaryCall(getLeaseTasksMethodHelper(), responseObserver);
+ }
+
+ /**
+ *
+ * Acknowledges a pull task.
+ * The worker, that is, the entity that
+ * [leased][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks] this task must call this method
+ * to indicate that the work associated with the task has finished.
+ * The worker must acknowledge a task within the
+ * [lease_duration][google.cloud.tasks.v2beta2.LeaseTasksRequest.lease_duration] or the lease
+ * will expire and the task will become available to be leased
+ * again. After the task is acknowledged, it will not be returned
+ * by a later [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks],
+ * [GetTask][google.cloud.tasks.v2beta2.CloudTasks.GetTask], or
+ * [ListTasks][google.cloud.tasks.v2beta2.CloudTasks.ListTasks].
+ *
+ */
+ public void acknowledgeTask(com.google.cloud.tasks.v2beta2.AcknowledgeTaskRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnimplementedUnaryCall(getAcknowledgeTaskMethodHelper(), responseObserver);
+ }
+
+ /**
+ *
+ * Renew the current lease of a pull task.
+ * The worker can use this method to extend the lease by a new
+ * duration, starting from now. The new task lease will be
+ * returned in the task's [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time].
+ *
+ */
+ public void renewLease(com.google.cloud.tasks.v2beta2.RenewLeaseRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnimplementedUnaryCall(getRenewLeaseMethodHelper(), responseObserver);
+ }
+
+ /**
+ *
+ * Cancel a pull task's lease.
+ * The worker can use this method to cancel a task's lease by
+ * setting its [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time] to now. This will
+ * make the task available to be leased to the next caller of
+ * [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks].
+ *
+ */
+ public void cancelLease(com.google.cloud.tasks.v2beta2.CancelLeaseRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnimplementedUnaryCall(getCancelLeaseMethodHelper(), responseObserver);
+ }
+
+ /**
+ *
+ * Forces a task to run now.
+ * When this method is called, Cloud Tasks will dispatch the task, even if
+ * the task is already running, the queue has reached its [RateLimits][google.cloud.tasks.v2beta2.RateLimits] or
+ * is [PAUSED][google.cloud.tasks.v2beta2.Queue.State.PAUSED].
+ * This command is meant to be used for manual debugging. For
+ * example, [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] can be used to retry a failed
+ * task after a fix has been made or to manually force a task to be
+ * dispatched now.
+ * The dispatched task is returned. That is, the task that is returned
+ * contains the [status][google.cloud.tasks.v2beta2.Task.status] after the task is dispatched but
+ * before the task is received by its target.
+ * If Cloud Tasks receives a successful response from the task's
+ * target, then the task will be deleted; otherwise the task's
+ * [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time] will be reset to the time that
+ * [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] was called plus the retry delay specified
+ * in the queue's [RetryConfig][google.cloud.tasks.v2beta2.RetryConfig].
+ * [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] returns
+ * [NOT_FOUND][google.rpc.Code.NOT_FOUND] when it is called on a
+ * task that has already succeeded or permanently failed.
+ * [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] cannot be called on a
+ * [pull task][google.cloud.tasks.v2beta2.PullMessage].
+ *
+ */
+ public void runTask(com.google.cloud.tasks.v2beta2.RunTaskRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnimplementedUnaryCall(getRunTaskMethodHelper(), responseObserver);
+ }
+
+ @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() {
+ return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
+ .addMethod(
+ getListQueuesMethodHelper(),
+ asyncUnaryCall(
+ new MethodHandlers<
+ com.google.cloud.tasks.v2beta2.ListQueuesRequest,
+ com.google.cloud.tasks.v2beta2.ListQueuesResponse>(
+ this, METHODID_LIST_QUEUES)))
+ .addMethod(
+ getGetQueueMethodHelper(),
+ asyncUnaryCall(
+ new MethodHandlers<
+ com.google.cloud.tasks.v2beta2.GetQueueRequest,
+ com.google.cloud.tasks.v2beta2.Queue>(
+ this, METHODID_GET_QUEUE)))
+ .addMethod(
+ getCreateQueueMethodHelper(),
+ asyncUnaryCall(
+ new MethodHandlers<
+ com.google.cloud.tasks.v2beta2.CreateQueueRequest,
+ com.google.cloud.tasks.v2beta2.Queue>(
+ this, METHODID_CREATE_QUEUE)))
+ .addMethod(
+ getUpdateQueueMethodHelper(),
+ asyncUnaryCall(
+ new MethodHandlers<
+ com.google.cloud.tasks.v2beta2.UpdateQueueRequest,
+ com.google.cloud.tasks.v2beta2.Queue>(
+ this, METHODID_UPDATE_QUEUE)))
+ .addMethod(
+ getDeleteQueueMethodHelper(),
+ asyncUnaryCall(
+ new MethodHandlers<
+ com.google.cloud.tasks.v2beta2.DeleteQueueRequest,
+ com.google.protobuf.Empty>(
+ this, METHODID_DELETE_QUEUE)))
+ .addMethod(
+ getPurgeQueueMethodHelper(),
+ asyncUnaryCall(
+ new MethodHandlers<
+ com.google.cloud.tasks.v2beta2.PurgeQueueRequest,
+ com.google.cloud.tasks.v2beta2.Queue>(
+ this, METHODID_PURGE_QUEUE)))
+ .addMethod(
+ getPauseQueueMethodHelper(),
+ asyncUnaryCall(
+ new MethodHandlers<
+ com.google.cloud.tasks.v2beta2.PauseQueueRequest,
+ com.google.cloud.tasks.v2beta2.Queue>(
+ this, METHODID_PAUSE_QUEUE)))
+ .addMethod(
+ getResumeQueueMethodHelper(),
+ asyncUnaryCall(
+ new MethodHandlers<
+ com.google.cloud.tasks.v2beta2.ResumeQueueRequest,
+ com.google.cloud.tasks.v2beta2.Queue>(
+ this, METHODID_RESUME_QUEUE)))
+ .addMethod(
+ getGetIamPolicyMethodHelper(),
+ asyncUnaryCall(
+ new MethodHandlers<
+ com.google.iam.v1.GetIamPolicyRequest,
+ com.google.iam.v1.Policy>(
+ this, METHODID_GET_IAM_POLICY)))
+ .addMethod(
+ getSetIamPolicyMethodHelper(),
+ asyncUnaryCall(
+ new MethodHandlers<
+ com.google.iam.v1.SetIamPolicyRequest,
+ com.google.iam.v1.Policy>(
+ this, METHODID_SET_IAM_POLICY)))
+ .addMethod(
+ getTestIamPermissionsMethodHelper(),
+ asyncUnaryCall(
+ new MethodHandlers<
+ com.google.iam.v1.TestIamPermissionsRequest,
+ com.google.iam.v1.TestIamPermissionsResponse>(
+ this, METHODID_TEST_IAM_PERMISSIONS)))
+ .addMethod(
+ getListTasksMethodHelper(),
+ asyncUnaryCall(
+ new MethodHandlers<
+ com.google.cloud.tasks.v2beta2.ListTasksRequest,
+ com.google.cloud.tasks.v2beta2.ListTasksResponse>(
+ this, METHODID_LIST_TASKS)))
+ .addMethod(
+ getGetTaskMethodHelper(),
+ asyncUnaryCall(
+ new MethodHandlers<
+ com.google.cloud.tasks.v2beta2.GetTaskRequest,
+ com.google.cloud.tasks.v2beta2.Task>(
+ this, METHODID_GET_TASK)))
+ .addMethod(
+ getCreateTaskMethodHelper(),
+ asyncUnaryCall(
+ new MethodHandlers<
+ com.google.cloud.tasks.v2beta2.CreateTaskRequest,
+ com.google.cloud.tasks.v2beta2.Task>(
+ this, METHODID_CREATE_TASK)))
+ .addMethod(
+ getDeleteTaskMethodHelper(),
+ asyncUnaryCall(
+ new MethodHandlers<
+ com.google.cloud.tasks.v2beta2.DeleteTaskRequest,
+ com.google.protobuf.Empty>(
+ this, METHODID_DELETE_TASK)))
+ .addMethod(
+ getLeaseTasksMethodHelper(),
+ asyncUnaryCall(
+ new MethodHandlers<
+ com.google.cloud.tasks.v2beta2.LeaseTasksRequest,
+ com.google.cloud.tasks.v2beta2.LeaseTasksResponse>(
+ this, METHODID_LEASE_TASKS)))
+ .addMethod(
+ getAcknowledgeTaskMethodHelper(),
+ asyncUnaryCall(
+ new MethodHandlers<
+ com.google.cloud.tasks.v2beta2.AcknowledgeTaskRequest,
+ com.google.protobuf.Empty>(
+ this, METHODID_ACKNOWLEDGE_TASK)))
+ .addMethod(
+ getRenewLeaseMethodHelper(),
+ asyncUnaryCall(
+ new MethodHandlers<
+ com.google.cloud.tasks.v2beta2.RenewLeaseRequest,
+ com.google.cloud.tasks.v2beta2.Task>(
+ this, METHODID_RENEW_LEASE)))
+ .addMethod(
+ getCancelLeaseMethodHelper(),
+ asyncUnaryCall(
+ new MethodHandlers<
+ com.google.cloud.tasks.v2beta2.CancelLeaseRequest,
+ com.google.cloud.tasks.v2beta2.Task>(
+ this, METHODID_CANCEL_LEASE)))
+ .addMethod(
+ getRunTaskMethodHelper(),
+ asyncUnaryCall(
+ new MethodHandlers<
+ com.google.cloud.tasks.v2beta2.RunTaskRequest,
+ com.google.cloud.tasks.v2beta2.Task>(
+ this, METHODID_RUN_TASK)))
+ .build();
+ }
+ }
+
+ /**
+ *
+ * Cloud Tasks allows developers to manage the execution of background
+ * work in their applications.
+ *
+ */
+ public static final class CloudTasksStub extends io.grpc.stub.AbstractStub {
+ private CloudTasksStub(io.grpc.Channel channel) {
+ super(channel);
+ }
+
+ private CloudTasksStub(io.grpc.Channel channel,
+ io.grpc.CallOptions callOptions) {
+ super(channel, callOptions);
+ }
+
+ @java.lang.Override
+ protected CloudTasksStub build(io.grpc.Channel channel,
+ io.grpc.CallOptions callOptions) {
+ return new CloudTasksStub(channel, callOptions);
+ }
+
+ /**
+ *
+ * Lists queues.
+ * Queues are returned in lexicographical order.
+ *
+ */
+ public void listQueues(com.google.cloud.tasks.v2beta2.ListQueuesRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnaryCall(
+ getChannel().newCall(getListQueuesMethodHelper(), getCallOptions()), request, responseObserver);
+ }
+
+ /**
+ *
+ * Gets a queue.
+ *
+ */
+ public void getQueue(com.google.cloud.tasks.v2beta2.GetQueueRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnaryCall(
+ getChannel().newCall(getGetQueueMethodHelper(), getCallOptions()), request, responseObserver);
+ }
+
+ /**
+ *
+ * Creates a queue.
+ * Queues created with this method allow tasks to live for a maximum of 31
+ * days. After a task is 31 days old, the task will be deleted regardless of whether
+ * it was dispatched or not.
+ * WARNING: Using this method may have unintended side effects if you are
+ * using an App Engine `queue.yaml` or `queue.xml` file to manage your queues.
+ * Read
+ * [Overview of Queue Management and queue.yaml](/cloud-tasks/docs/queue-yaml)
+ * before using this method.
+ *
+ */
+ public void createQueue(com.google.cloud.tasks.v2beta2.CreateQueueRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnaryCall(
+ getChannel().newCall(getCreateQueueMethodHelper(), getCallOptions()), request, responseObserver);
+ }
+
+ /**
+ *
+ * Updates a queue.
+ * This method creates the queue if it does not exist and updates
+ * the queue if it does exist.
+ * Queues created with this method allow tasks to live for a maximum of 31
+ * days. After a task is 31 days old, the task will be deleted regardless of whether
+ * it was dispatched or not.
+ * WARNING: Using this method may have unintended side effects if you are
+ * using an App Engine `queue.yaml` or `queue.xml` file to manage your queues.
+ * Read
+ * [Overview of Queue Management and queue.yaml](/cloud-tasks/docs/queue-yaml)
+ * before using this method.
+ *
+ */
+ public void updateQueue(com.google.cloud.tasks.v2beta2.UpdateQueueRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnaryCall(
+ getChannel().newCall(getUpdateQueueMethodHelper(), getCallOptions()), request, responseObserver);
+ }
+
+ /**
+ *
+ * Deletes a queue.
+ * This command will delete the queue even if it has tasks in it.
+ * Note: If you delete a queue, a queue with the same name can't be created
+ * for 7 days.
+ * WARNING: Using this method may have unintended side effects if you are
+ * using an App Engine `queue.yaml` or `queue.xml` file to manage your queues.
+ * Read
+ * [Overview of Queue Management and queue.yaml](/cloud-tasks/docs/queue-yaml)
+ * before using this method.
+ *
+ */
+ public void deleteQueue(com.google.cloud.tasks.v2beta2.DeleteQueueRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnaryCall(
+ getChannel().newCall(getDeleteQueueMethodHelper(), getCallOptions()), request, responseObserver);
+ }
+
+ /**
+ *
+ * Purges a queue by deleting all of its tasks.
+ * All tasks created before this method is called are permanently deleted.
+ * Purge operations can take up to one minute to take effect. Tasks
+ * might be dispatched before the purge takes effect. A purge is irreversible.
+ *
+ */
+ public void purgeQueue(com.google.cloud.tasks.v2beta2.PurgeQueueRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnaryCall(
+ getChannel().newCall(getPurgeQueueMethodHelper(), getCallOptions()), request, responseObserver);
+ }
+
+ /**
+ *
+ * Pauses the queue.
+ * If a queue is paused then the system will stop dispatching tasks
+ * until the queue is resumed via
+ * [ResumeQueue][google.cloud.tasks.v2beta2.CloudTasks.ResumeQueue]. Tasks can still be added
+ * when the queue is paused. A queue is paused if its
+ * [state][google.cloud.tasks.v2beta2.Queue.state] is [PAUSED][google.cloud.tasks.v2beta2.Queue.State.PAUSED].
+ *
+ */
+ public void pauseQueue(com.google.cloud.tasks.v2beta2.PauseQueueRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnaryCall(
+ getChannel().newCall(getPauseQueueMethodHelper(), getCallOptions()), request, responseObserver);
+ }
+
+ /**
+ *
+ * Resume a queue.
+ * This method resumes a queue after it has been
+ * [PAUSED][google.cloud.tasks.v2beta2.Queue.State.PAUSED] or
+ * [DISABLED][google.cloud.tasks.v2beta2.Queue.State.DISABLED]. The state of a queue is stored
+ * in the queue's [state][google.cloud.tasks.v2beta2.Queue.state]; after calling this method it
+ * will be set to [RUNNING][google.cloud.tasks.v2beta2.Queue.State.RUNNING].
+ * WARNING: Resuming many high-QPS queues at the same time can
+ * lead to target overloading. If you are resuming high-QPS
+ * queues, follow the 500/50/5 pattern described in
+ * [Managing Cloud Tasks Scaling Risks](/cloud-tasks/pdfs/managing-cloud-tasks-scaling-risks-2017-06-05.pdf).
+ *
+ */
+ public void resumeQueue(com.google.cloud.tasks.v2beta2.ResumeQueueRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnaryCall(
+ getChannel().newCall(getResumeQueueMethodHelper(), getCallOptions()), request, responseObserver);
+ }
+
+ /**
+ *
+ * Gets the access control policy for a [Queue][google.cloud.tasks.v2beta2.Queue].
+ * Returns an empty policy if the resource exists and does not have a policy
+ * set.
+ * Authorization requires the following [Google IAM](/iam) permission on the
+ * specified resource parent:
+ * * `cloudtasks.queues.getIamPolicy`
+ *
+ */
+ public void getIamPolicy(com.google.iam.v1.GetIamPolicyRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnaryCall(
+ getChannel().newCall(getGetIamPolicyMethodHelper(), getCallOptions()), request, responseObserver);
+ }
+
+ /**
+ *
+ * Sets the access control policy for a [Queue][google.cloud.tasks.v2beta2.Queue]. Replaces any existing
+ * policy.
+ * Note: The Cloud Console does not check queue-level IAM permissions yet.
+ * Project-level permissions are required to use the Cloud Console.
+ * Authorization requires the following [Google IAM](/iam) permission on the
+ * specified resource parent:
+ * * `cloudtasks.queues.setIamPolicy`
+ *
+ */
+ public void setIamPolicy(com.google.iam.v1.SetIamPolicyRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnaryCall(
+ getChannel().newCall(getSetIamPolicyMethodHelper(), getCallOptions()), request, responseObserver);
+ }
+
+ /**
+ *
+ * Returns permissions that a caller has on a [Queue][google.cloud.tasks.v2beta2.Queue].
+ * If the resource does not exist, this will return an empty set of
+ * permissions, not a [NOT_FOUND][google.rpc.Code.NOT_FOUND] error.
+ * Note: This operation is designed to be used for building permission-aware
+ * UIs and command-line tools, not for authorization checking. This operation
+ * may "fail open" without warning.
+ *
+ */
+ public void testIamPermissions(com.google.iam.v1.TestIamPermissionsRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnaryCall(
+ getChannel().newCall(getTestIamPermissionsMethodHelper(), getCallOptions()), request, responseObserver);
+ }
+
+ /**
+ *
+ * Lists the tasks in a queue.
+ * By default, only the [BASIC][google.cloud.tasks.v2beta2.Task.View.BASIC] view is retrieved
+ * due to performance considerations;
+ * [response_view][google.cloud.tasks.v2beta2.ListTasksRequest.response_view] controls the
+ * subset of information which is returned.
+ *
+ */
+ public void listTasks(com.google.cloud.tasks.v2beta2.ListTasksRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnaryCall(
+ getChannel().newCall(getListTasksMethodHelper(), getCallOptions()), request, responseObserver);
+ }
+
+ /**
+ *
+ * Gets a task.
+ *
+ */
+ public void getTask(com.google.cloud.tasks.v2beta2.GetTaskRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnaryCall(
+ getChannel().newCall(getGetTaskMethodHelper(), getCallOptions()), request, responseObserver);
+ }
+
+ /**
+ *
+ * Creates a task and adds it to a queue.
+ * Tasks cannot be updated after creation; there is no UpdateTask command.
+ * * For [App Engine queues](google.cloud.tasks.v2beta2.AppEngineHttpTarget),
+ * the maximum task size is 100KB.
+ * * For [pull queues](google.cloud.tasks.v2beta2.PullTarget), this
+ * the maximum task size is 1MB.
+ *
+ */
+ public void createTask(com.google.cloud.tasks.v2beta2.CreateTaskRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnaryCall(
+ getChannel().newCall(getCreateTaskMethodHelper(), getCallOptions()), request, responseObserver);
+ }
+
+ /**
+ *
+ * Deletes a task.
+ * A task can be deleted if it is scheduled or dispatched. A task
+ * cannot be deleted if it has completed successfully or permanently
+ * failed.
+ *
+ */
+ public void deleteTask(com.google.cloud.tasks.v2beta2.DeleteTaskRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnaryCall(
+ getChannel().newCall(getDeleteTaskMethodHelper(), getCallOptions()), request, responseObserver);
+ }
+
+ /**
+ *
+ * Leases tasks from a pull queue for
+ * [lease_duration][google.cloud.tasks.v2beta2.LeaseTasksRequest.lease_duration].
+ * This method is invoked by the worker to obtain a lease. The
+ * worker must acknowledge the task via
+ * [AcknowledgeTask][google.cloud.tasks.v2beta2.CloudTasks.AcknowledgeTask] after they have
+ * performed the work associated with the task.
+ * The [payload][google.cloud.tasks.v2beta2.PullMessage.payload] is intended to store data that
+ * the worker needs to perform the work associated with the task. To
+ * return the payloads in the [response][google.cloud.tasks.v2beta2.LeaseTasksResponse], set
+ * [response_view][google.cloud.tasks.v2beta2.LeaseTasksRequest.response_view] to
+ * [FULL][google.cloud.tasks.v2beta2.Task.View.FULL].
+ * A maximum of 10 qps of [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks]
+ * requests are allowed per
+ * queue. [RESOURCE_EXHAUSTED][google.rpc.Code.RESOURCE_EXHAUSTED]
+ * is returned when this limit is
+ * exceeded. [RESOURCE_EXHAUSTED][google.rpc.Code.RESOURCE_EXHAUSTED]
+ * is also returned when
+ * [max_tasks_dispatched_per_second][google.cloud.tasks.v2beta2.RateLimits.max_tasks_dispatched_per_second]
+ * is exceeded.
+ *
+ */
+ public void leaseTasks(com.google.cloud.tasks.v2beta2.LeaseTasksRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnaryCall(
+ getChannel().newCall(getLeaseTasksMethodHelper(), getCallOptions()), request, responseObserver);
+ }
+
+ /**
+ *
+ * Acknowledges a pull task.
+ * The worker, that is, the entity that
+ * [leased][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks] this task must call this method
+ * to indicate that the work associated with the task has finished.
+ * The worker must acknowledge a task within the
+ * [lease_duration][google.cloud.tasks.v2beta2.LeaseTasksRequest.lease_duration] or the lease
+ * will expire and the task will become available to be leased
+ * again. After the task is acknowledged, it will not be returned
+ * by a later [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks],
+ * [GetTask][google.cloud.tasks.v2beta2.CloudTasks.GetTask], or
+ * [ListTasks][google.cloud.tasks.v2beta2.CloudTasks.ListTasks].
+ *
+ */
+ public void acknowledgeTask(com.google.cloud.tasks.v2beta2.AcknowledgeTaskRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnaryCall(
+ getChannel().newCall(getAcknowledgeTaskMethodHelper(), getCallOptions()), request, responseObserver);
+ }
+
+ /**
+ *
+ * Renew the current lease of a pull task.
+ * The worker can use this method to extend the lease by a new
+ * duration, starting from now. The new task lease will be
+ * returned in the task's [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time].
+ *
+ */
+ public void renewLease(com.google.cloud.tasks.v2beta2.RenewLeaseRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnaryCall(
+ getChannel().newCall(getRenewLeaseMethodHelper(), getCallOptions()), request, responseObserver);
+ }
+
+ /**
+ *
+ * Cancel a pull task's lease.
+ * The worker can use this method to cancel a task's lease by
+ * setting its [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time] to now. This will
+ * make the task available to be leased to the next caller of
+ * [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks].
+ *
+ */
+ public void cancelLease(com.google.cloud.tasks.v2beta2.CancelLeaseRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnaryCall(
+ getChannel().newCall(getCancelLeaseMethodHelper(), getCallOptions()), request, responseObserver);
+ }
+
+ /**
+ *
+ * Forces a task to run now.
+ * When this method is called, Cloud Tasks will dispatch the task, even if
+ * the task is already running, the queue has reached its [RateLimits][google.cloud.tasks.v2beta2.RateLimits] or
+ * is [PAUSED][google.cloud.tasks.v2beta2.Queue.State.PAUSED].
+ * This command is meant to be used for manual debugging. For
+ * example, [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] can be used to retry a failed
+ * task after a fix has been made or to manually force a task to be
+ * dispatched now.
+ * The dispatched task is returned. That is, the task that is returned
+ * contains the [status][google.cloud.tasks.v2beta2.Task.status] after the task is dispatched but
+ * before the task is received by its target.
+ * If Cloud Tasks receives a successful response from the task's
+ * target, then the task will be deleted; otherwise the task's
+ * [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time] will be reset to the time that
+ * [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] was called plus the retry delay specified
+ * in the queue's [RetryConfig][google.cloud.tasks.v2beta2.RetryConfig].
+ * [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] returns
+ * [NOT_FOUND][google.rpc.Code.NOT_FOUND] when it is called on a
+ * task that has already succeeded or permanently failed.
+ * [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] cannot be called on a
+ * [pull task][google.cloud.tasks.v2beta2.PullMessage].
+ *
+ */
+ public void runTask(com.google.cloud.tasks.v2beta2.RunTaskRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnaryCall(
+ getChannel().newCall(getRunTaskMethodHelper(), getCallOptions()), request, responseObserver);
+ }
+ }
+
+ /**
+ *
+ * Cloud Tasks allows developers to manage the execution of background
+ * work in their applications.
+ *
+ */
+ public static final class CloudTasksBlockingStub extends io.grpc.stub.AbstractStub {
+ private CloudTasksBlockingStub(io.grpc.Channel channel) {
+ super(channel);
+ }
+
+ private CloudTasksBlockingStub(io.grpc.Channel channel,
+ io.grpc.CallOptions callOptions) {
+ super(channel, callOptions);
+ }
+
+ @java.lang.Override
+ protected CloudTasksBlockingStub build(io.grpc.Channel channel,
+ io.grpc.CallOptions callOptions) {
+ return new CloudTasksBlockingStub(channel, callOptions);
+ }
+
+ /**
+ *
+ * Lists queues.
+ * Queues are returned in lexicographical order.
+ *
+ */
+ public com.google.cloud.tasks.v2beta2.ListQueuesResponse listQueues(com.google.cloud.tasks.v2beta2.ListQueuesRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getListQueuesMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Gets a queue.
+ *
+ */
+ public com.google.cloud.tasks.v2beta2.Queue getQueue(com.google.cloud.tasks.v2beta2.GetQueueRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getGetQueueMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Creates a queue.
+ * Queues created with this method allow tasks to live for a maximum of 31
+ * days. After a task is 31 days old, the task will be deleted regardless of whether
+ * it was dispatched or not.
+ * WARNING: Using this method may have unintended side effects if you are
+ * using an App Engine `queue.yaml` or `queue.xml` file to manage your queues.
+ * Read
+ * [Overview of Queue Management and queue.yaml](/cloud-tasks/docs/queue-yaml)
+ * before using this method.
+ *
+ */
+ public com.google.cloud.tasks.v2beta2.Queue createQueue(com.google.cloud.tasks.v2beta2.CreateQueueRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getCreateQueueMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Updates a queue.
+ * This method creates the queue if it does not exist and updates
+ * the queue if it does exist.
+ * Queues created with this method allow tasks to live for a maximum of 31
+ * days. After a task is 31 days old, the task will be deleted regardless of whether
+ * it was dispatched or not.
+ * WARNING: Using this method may have unintended side effects if you are
+ * using an App Engine `queue.yaml` or `queue.xml` file to manage your queues.
+ * Read
+ * [Overview of Queue Management and queue.yaml](/cloud-tasks/docs/queue-yaml)
+ * before using this method.
+ *
+ */
+ public com.google.cloud.tasks.v2beta2.Queue updateQueue(com.google.cloud.tasks.v2beta2.UpdateQueueRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getUpdateQueueMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Deletes a queue.
+ * This command will delete the queue even if it has tasks in it.
+ * Note: If you delete a queue, a queue with the same name can't be created
+ * for 7 days.
+ * WARNING: Using this method may have unintended side effects if you are
+ * using an App Engine `queue.yaml` or `queue.xml` file to manage your queues.
+ * Read
+ * [Overview of Queue Management and queue.yaml](/cloud-tasks/docs/queue-yaml)
+ * before using this method.
+ *
+ */
+ public com.google.protobuf.Empty deleteQueue(com.google.cloud.tasks.v2beta2.DeleteQueueRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getDeleteQueueMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Purges a queue by deleting all of its tasks.
+ * All tasks created before this method is called are permanently deleted.
+ * Purge operations can take up to one minute to take effect. Tasks
+ * might be dispatched before the purge takes effect. A purge is irreversible.
+ *
+ */
+ public com.google.cloud.tasks.v2beta2.Queue purgeQueue(com.google.cloud.tasks.v2beta2.PurgeQueueRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getPurgeQueueMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Pauses the queue.
+ * If a queue is paused then the system will stop dispatching tasks
+ * until the queue is resumed via
+ * [ResumeQueue][google.cloud.tasks.v2beta2.CloudTasks.ResumeQueue]. Tasks can still be added
+ * when the queue is paused. A queue is paused if its
+ * [state][google.cloud.tasks.v2beta2.Queue.state] is [PAUSED][google.cloud.tasks.v2beta2.Queue.State.PAUSED].
+ *
+ */
+ public com.google.cloud.tasks.v2beta2.Queue pauseQueue(com.google.cloud.tasks.v2beta2.PauseQueueRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getPauseQueueMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Resume a queue.
+ * This method resumes a queue after it has been
+ * [PAUSED][google.cloud.tasks.v2beta2.Queue.State.PAUSED] or
+ * [DISABLED][google.cloud.tasks.v2beta2.Queue.State.DISABLED]. The state of a queue is stored
+ * in the queue's [state][google.cloud.tasks.v2beta2.Queue.state]; after calling this method it
+ * will be set to [RUNNING][google.cloud.tasks.v2beta2.Queue.State.RUNNING].
+ * WARNING: Resuming many high-QPS queues at the same time can
+ * lead to target overloading. If you are resuming high-QPS
+ * queues, follow the 500/50/5 pattern described in
+ * [Managing Cloud Tasks Scaling Risks](/cloud-tasks/pdfs/managing-cloud-tasks-scaling-risks-2017-06-05.pdf).
+ *
+ */
+ public com.google.cloud.tasks.v2beta2.Queue resumeQueue(com.google.cloud.tasks.v2beta2.ResumeQueueRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getResumeQueueMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Gets the access control policy for a [Queue][google.cloud.tasks.v2beta2.Queue].
+ * Returns an empty policy if the resource exists and does not have a policy
+ * set.
+ * Authorization requires the following [Google IAM](/iam) permission on the
+ * specified resource parent:
+ * * `cloudtasks.queues.getIamPolicy`
+ *
+ */
+ public com.google.iam.v1.Policy getIamPolicy(com.google.iam.v1.GetIamPolicyRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getGetIamPolicyMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Sets the access control policy for a [Queue][google.cloud.tasks.v2beta2.Queue]. Replaces any existing
+ * policy.
+ * Note: The Cloud Console does not check queue-level IAM permissions yet.
+ * Project-level permissions are required to use the Cloud Console.
+ * Authorization requires the following [Google IAM](/iam) permission on the
+ * specified resource parent:
+ * * `cloudtasks.queues.setIamPolicy`
+ *
+ */
+ public com.google.iam.v1.Policy setIamPolicy(com.google.iam.v1.SetIamPolicyRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getSetIamPolicyMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Returns permissions that a caller has on a [Queue][google.cloud.tasks.v2beta2.Queue].
+ * If the resource does not exist, this will return an empty set of
+ * permissions, not a [NOT_FOUND][google.rpc.Code.NOT_FOUND] error.
+ * Note: This operation is designed to be used for building permission-aware
+ * UIs and command-line tools, not for authorization checking. This operation
+ * may "fail open" without warning.
+ *
+ */
+ public com.google.iam.v1.TestIamPermissionsResponse testIamPermissions(com.google.iam.v1.TestIamPermissionsRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getTestIamPermissionsMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Lists the tasks in a queue.
+ * By default, only the [BASIC][google.cloud.tasks.v2beta2.Task.View.BASIC] view is retrieved
+ * due to performance considerations;
+ * [response_view][google.cloud.tasks.v2beta2.ListTasksRequest.response_view] controls the
+ * subset of information which is returned.
+ *
+ */
+ public com.google.cloud.tasks.v2beta2.ListTasksResponse listTasks(com.google.cloud.tasks.v2beta2.ListTasksRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getListTasksMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Gets a task.
+ *
+ */
+ public com.google.cloud.tasks.v2beta2.Task getTask(com.google.cloud.tasks.v2beta2.GetTaskRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getGetTaskMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Creates a task and adds it to a queue.
+ * Tasks cannot be updated after creation; there is no UpdateTask command.
+ * * For [App Engine queues](google.cloud.tasks.v2beta2.AppEngineHttpTarget),
+ * the maximum task size is 100KB.
+ * * For [pull queues](google.cloud.tasks.v2beta2.PullTarget), this
+ * the maximum task size is 1MB.
+ *
+ */
+ public com.google.cloud.tasks.v2beta2.Task createTask(com.google.cloud.tasks.v2beta2.CreateTaskRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getCreateTaskMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Deletes a task.
+ * A task can be deleted if it is scheduled or dispatched. A task
+ * cannot be deleted if it has completed successfully or permanently
+ * failed.
+ *
+ */
+ public com.google.protobuf.Empty deleteTask(com.google.cloud.tasks.v2beta2.DeleteTaskRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getDeleteTaskMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Leases tasks from a pull queue for
+ * [lease_duration][google.cloud.tasks.v2beta2.LeaseTasksRequest.lease_duration].
+ * This method is invoked by the worker to obtain a lease. The
+ * worker must acknowledge the task via
+ * [AcknowledgeTask][google.cloud.tasks.v2beta2.CloudTasks.AcknowledgeTask] after they have
+ * performed the work associated with the task.
+ * The [payload][google.cloud.tasks.v2beta2.PullMessage.payload] is intended to store data that
+ * the worker needs to perform the work associated with the task. To
+ * return the payloads in the [response][google.cloud.tasks.v2beta2.LeaseTasksResponse], set
+ * [response_view][google.cloud.tasks.v2beta2.LeaseTasksRequest.response_view] to
+ * [FULL][google.cloud.tasks.v2beta2.Task.View.FULL].
+ * A maximum of 10 qps of [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks]
+ * requests are allowed per
+ * queue. [RESOURCE_EXHAUSTED][google.rpc.Code.RESOURCE_EXHAUSTED]
+ * is returned when this limit is
+ * exceeded. [RESOURCE_EXHAUSTED][google.rpc.Code.RESOURCE_EXHAUSTED]
+ * is also returned when
+ * [max_tasks_dispatched_per_second][google.cloud.tasks.v2beta2.RateLimits.max_tasks_dispatched_per_second]
+ * is exceeded.
+ *
+ */
+ public com.google.cloud.tasks.v2beta2.LeaseTasksResponse leaseTasks(com.google.cloud.tasks.v2beta2.LeaseTasksRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getLeaseTasksMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Acknowledges a pull task.
+ * The worker, that is, the entity that
+ * [leased][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks] this task must call this method
+ * to indicate that the work associated with the task has finished.
+ * The worker must acknowledge a task within the
+ * [lease_duration][google.cloud.tasks.v2beta2.LeaseTasksRequest.lease_duration] or the lease
+ * will expire and the task will become available to be leased
+ * again. After the task is acknowledged, it will not be returned
+ * by a later [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks],
+ * [GetTask][google.cloud.tasks.v2beta2.CloudTasks.GetTask], or
+ * [ListTasks][google.cloud.tasks.v2beta2.CloudTasks.ListTasks].
+ *
+ */
+ public com.google.protobuf.Empty acknowledgeTask(com.google.cloud.tasks.v2beta2.AcknowledgeTaskRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getAcknowledgeTaskMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Renew the current lease of a pull task.
+ * The worker can use this method to extend the lease by a new
+ * duration, starting from now. The new task lease will be
+ * returned in the task's [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time].
+ *
+ */
+ public com.google.cloud.tasks.v2beta2.Task renewLease(com.google.cloud.tasks.v2beta2.RenewLeaseRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getRenewLeaseMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Cancel a pull task's lease.
+ * The worker can use this method to cancel a task's lease by
+ * setting its [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time] to now. This will
+ * make the task available to be leased to the next caller of
+ * [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks].
+ *
+ */
+ public com.google.cloud.tasks.v2beta2.Task cancelLease(com.google.cloud.tasks.v2beta2.CancelLeaseRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getCancelLeaseMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Forces a task to run now.
+ * When this method is called, Cloud Tasks will dispatch the task, even if
+ * the task is already running, the queue has reached its [RateLimits][google.cloud.tasks.v2beta2.RateLimits] or
+ * is [PAUSED][google.cloud.tasks.v2beta2.Queue.State.PAUSED].
+ * This command is meant to be used for manual debugging. For
+ * example, [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] can be used to retry a failed
+ * task after a fix has been made or to manually force a task to be
+ * dispatched now.
+ * The dispatched task is returned. That is, the task that is returned
+ * contains the [status][google.cloud.tasks.v2beta2.Task.status] after the task is dispatched but
+ * before the task is received by its target.
+ * If Cloud Tasks receives a successful response from the task's
+ * target, then the task will be deleted; otherwise the task's
+ * [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time] will be reset to the time that
+ * [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] was called plus the retry delay specified
+ * in the queue's [RetryConfig][google.cloud.tasks.v2beta2.RetryConfig].
+ * [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] returns
+ * [NOT_FOUND][google.rpc.Code.NOT_FOUND] when it is called on a
+ * task that has already succeeded or permanently failed.
+ * [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] cannot be called on a
+ * [pull task][google.cloud.tasks.v2beta2.PullMessage].
+ *
+ */
+ public com.google.cloud.tasks.v2beta2.Task runTask(com.google.cloud.tasks.v2beta2.RunTaskRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getRunTaskMethodHelper(), getCallOptions(), request);
+ }
+ }
+
+ /**
+ *
+ * Cloud Tasks allows developers to manage the execution of background
+ * work in their applications.
+ *
+ */
+ public static final class CloudTasksFutureStub extends io.grpc.stub.AbstractStub {
+ private CloudTasksFutureStub(io.grpc.Channel channel) {
+ super(channel);
+ }
+
+ private CloudTasksFutureStub(io.grpc.Channel channel,
+ io.grpc.CallOptions callOptions) {
+ super(channel, callOptions);
+ }
+
+ @java.lang.Override
+ protected CloudTasksFutureStub build(io.grpc.Channel channel,
+ io.grpc.CallOptions callOptions) {
+ return new CloudTasksFutureStub(channel, callOptions);
+ }
+
+ /**
+ *
+ * Lists queues.
+ * Queues are returned in lexicographical order.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture listQueues(
+ com.google.cloud.tasks.v2beta2.ListQueuesRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getListQueuesMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Gets a queue.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture getQueue(
+ com.google.cloud.tasks.v2beta2.GetQueueRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getGetQueueMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Creates a queue.
+ * Queues created with this method allow tasks to live for a maximum of 31
+ * days. After a task is 31 days old, the task will be deleted regardless of whether
+ * it was dispatched or not.
+ * WARNING: Using this method may have unintended side effects if you are
+ * using an App Engine `queue.yaml` or `queue.xml` file to manage your queues.
+ * Read
+ * [Overview of Queue Management and queue.yaml](/cloud-tasks/docs/queue-yaml)
+ * before using this method.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture createQueue(
+ com.google.cloud.tasks.v2beta2.CreateQueueRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getCreateQueueMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Updates a queue.
+ * This method creates the queue if it does not exist and updates
+ * the queue if it does exist.
+ * Queues created with this method allow tasks to live for a maximum of 31
+ * days. After a task is 31 days old, the task will be deleted regardless of whether
+ * it was dispatched or not.
+ * WARNING: Using this method may have unintended side effects if you are
+ * using an App Engine `queue.yaml` or `queue.xml` file to manage your queues.
+ * Read
+ * [Overview of Queue Management and queue.yaml](/cloud-tasks/docs/queue-yaml)
+ * before using this method.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture updateQueue(
+ com.google.cloud.tasks.v2beta2.UpdateQueueRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getUpdateQueueMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Deletes a queue.
+ * This command will delete the queue even if it has tasks in it.
+ * Note: If you delete a queue, a queue with the same name can't be created
+ * for 7 days.
+ * WARNING: Using this method may have unintended side effects if you are
+ * using an App Engine `queue.yaml` or `queue.xml` file to manage your queues.
+ * Read
+ * [Overview of Queue Management and queue.yaml](/cloud-tasks/docs/queue-yaml)
+ * before using this method.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture deleteQueue(
+ com.google.cloud.tasks.v2beta2.DeleteQueueRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getDeleteQueueMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Purges a queue by deleting all of its tasks.
+ * All tasks created before this method is called are permanently deleted.
+ * Purge operations can take up to one minute to take effect. Tasks
+ * might be dispatched before the purge takes effect. A purge is irreversible.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture purgeQueue(
+ com.google.cloud.tasks.v2beta2.PurgeQueueRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getPurgeQueueMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Pauses the queue.
+ * If a queue is paused then the system will stop dispatching tasks
+ * until the queue is resumed via
+ * [ResumeQueue][google.cloud.tasks.v2beta2.CloudTasks.ResumeQueue]. Tasks can still be added
+ * when the queue is paused. A queue is paused if its
+ * [state][google.cloud.tasks.v2beta2.Queue.state] is [PAUSED][google.cloud.tasks.v2beta2.Queue.State.PAUSED].
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture pauseQueue(
+ com.google.cloud.tasks.v2beta2.PauseQueueRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getPauseQueueMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Resume a queue.
+ * This method resumes a queue after it has been
+ * [PAUSED][google.cloud.tasks.v2beta2.Queue.State.PAUSED] or
+ * [DISABLED][google.cloud.tasks.v2beta2.Queue.State.DISABLED]. The state of a queue is stored
+ * in the queue's [state][google.cloud.tasks.v2beta2.Queue.state]; after calling this method it
+ * will be set to [RUNNING][google.cloud.tasks.v2beta2.Queue.State.RUNNING].
+ * WARNING: Resuming many high-QPS queues at the same time can
+ * lead to target overloading. If you are resuming high-QPS
+ * queues, follow the 500/50/5 pattern described in
+ * [Managing Cloud Tasks Scaling Risks](/cloud-tasks/pdfs/managing-cloud-tasks-scaling-risks-2017-06-05.pdf).
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture resumeQueue(
+ com.google.cloud.tasks.v2beta2.ResumeQueueRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getResumeQueueMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Gets the access control policy for a [Queue][google.cloud.tasks.v2beta2.Queue].
+ * Returns an empty policy if the resource exists and does not have a policy
+ * set.
+ * Authorization requires the following [Google IAM](/iam) permission on the
+ * specified resource parent:
+ * * `cloudtasks.queues.getIamPolicy`
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture getIamPolicy(
+ com.google.iam.v1.GetIamPolicyRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getGetIamPolicyMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Sets the access control policy for a [Queue][google.cloud.tasks.v2beta2.Queue]. Replaces any existing
+ * policy.
+ * Note: The Cloud Console does not check queue-level IAM permissions yet.
+ * Project-level permissions are required to use the Cloud Console.
+ * Authorization requires the following [Google IAM](/iam) permission on the
+ * specified resource parent:
+ * * `cloudtasks.queues.setIamPolicy`
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture setIamPolicy(
+ com.google.iam.v1.SetIamPolicyRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getSetIamPolicyMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Returns permissions that a caller has on a [Queue][google.cloud.tasks.v2beta2.Queue].
+ * If the resource does not exist, this will return an empty set of
+ * permissions, not a [NOT_FOUND][google.rpc.Code.NOT_FOUND] error.
+ * Note: This operation is designed to be used for building permission-aware
+ * UIs and command-line tools, not for authorization checking. This operation
+ * may "fail open" without warning.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture testIamPermissions(
+ com.google.iam.v1.TestIamPermissionsRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getTestIamPermissionsMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Lists the tasks in a queue.
+ * By default, only the [BASIC][google.cloud.tasks.v2beta2.Task.View.BASIC] view is retrieved
+ * due to performance considerations;
+ * [response_view][google.cloud.tasks.v2beta2.ListTasksRequest.response_view] controls the
+ * subset of information which is returned.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture listTasks(
+ com.google.cloud.tasks.v2beta2.ListTasksRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getListTasksMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Gets a task.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture getTask(
+ com.google.cloud.tasks.v2beta2.GetTaskRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getGetTaskMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Creates a task and adds it to a queue.
+ * Tasks cannot be updated after creation; there is no UpdateTask command.
+ * * For [App Engine queues](google.cloud.tasks.v2beta2.AppEngineHttpTarget),
+ * the maximum task size is 100KB.
+ * * For [pull queues](google.cloud.tasks.v2beta2.PullTarget), this
+ * the maximum task size is 1MB.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture createTask(
+ com.google.cloud.tasks.v2beta2.CreateTaskRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getCreateTaskMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Deletes a task.
+ * A task can be deleted if it is scheduled or dispatched. A task
+ * cannot be deleted if it has completed successfully or permanently
+ * failed.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture deleteTask(
+ com.google.cloud.tasks.v2beta2.DeleteTaskRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getDeleteTaskMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Leases tasks from a pull queue for
+ * [lease_duration][google.cloud.tasks.v2beta2.LeaseTasksRequest.lease_duration].
+ * This method is invoked by the worker to obtain a lease. The
+ * worker must acknowledge the task via
+ * [AcknowledgeTask][google.cloud.tasks.v2beta2.CloudTasks.AcknowledgeTask] after they have
+ * performed the work associated with the task.
+ * The [payload][google.cloud.tasks.v2beta2.PullMessage.payload] is intended to store data that
+ * the worker needs to perform the work associated with the task. To
+ * return the payloads in the [response][google.cloud.tasks.v2beta2.LeaseTasksResponse], set
+ * [response_view][google.cloud.tasks.v2beta2.LeaseTasksRequest.response_view] to
+ * [FULL][google.cloud.tasks.v2beta2.Task.View.FULL].
+ * A maximum of 10 qps of [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks]
+ * requests are allowed per
+ * queue. [RESOURCE_EXHAUSTED][google.rpc.Code.RESOURCE_EXHAUSTED]
+ * is returned when this limit is
+ * exceeded. [RESOURCE_EXHAUSTED][google.rpc.Code.RESOURCE_EXHAUSTED]
+ * is also returned when
+ * [max_tasks_dispatched_per_second][google.cloud.tasks.v2beta2.RateLimits.max_tasks_dispatched_per_second]
+ * is exceeded.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture leaseTasks(
+ com.google.cloud.tasks.v2beta2.LeaseTasksRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getLeaseTasksMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Acknowledges a pull task.
+ * The worker, that is, the entity that
+ * [leased][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks] this task must call this method
+ * to indicate that the work associated with the task has finished.
+ * The worker must acknowledge a task within the
+ * [lease_duration][google.cloud.tasks.v2beta2.LeaseTasksRequest.lease_duration] or the lease
+ * will expire and the task will become available to be leased
+ * again. After the task is acknowledged, it will not be returned
+ * by a later [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks],
+ * [GetTask][google.cloud.tasks.v2beta2.CloudTasks.GetTask], or
+ * [ListTasks][google.cloud.tasks.v2beta2.CloudTasks.ListTasks].
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture acknowledgeTask(
+ com.google.cloud.tasks.v2beta2.AcknowledgeTaskRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getAcknowledgeTaskMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Renew the current lease of a pull task.
+ * The worker can use this method to extend the lease by a new
+ * duration, starting from now. The new task lease will be
+ * returned in the task's [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time].
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture renewLease(
+ com.google.cloud.tasks.v2beta2.RenewLeaseRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getRenewLeaseMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Cancel a pull task's lease.
+ * The worker can use this method to cancel a task's lease by
+ * setting its [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time] to now. This will
+ * make the task available to be leased to the next caller of
+ * [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks].
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture cancelLease(
+ com.google.cloud.tasks.v2beta2.CancelLeaseRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getCancelLeaseMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Forces a task to run now.
+ * When this method is called, Cloud Tasks will dispatch the task, even if
+ * the task is already running, the queue has reached its [RateLimits][google.cloud.tasks.v2beta2.RateLimits] or
+ * is [PAUSED][google.cloud.tasks.v2beta2.Queue.State.PAUSED].
+ * This command is meant to be used for manual debugging. For
+ * example, [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] can be used to retry a failed
+ * task after a fix has been made or to manually force a task to be
+ * dispatched now.
+ * The dispatched task is returned. That is, the task that is returned
+ * contains the [status][google.cloud.tasks.v2beta2.Task.status] after the task is dispatched but
+ * before the task is received by its target.
+ * If Cloud Tasks receives a successful response from the task's
+ * target, then the task will be deleted; otherwise the task's
+ * [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time] will be reset to the time that
+ * [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] was called plus the retry delay specified
+ * in the queue's [RetryConfig][google.cloud.tasks.v2beta2.RetryConfig].
+ * [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] returns
+ * [NOT_FOUND][google.rpc.Code.NOT_FOUND] when it is called on a
+ * task that has already succeeded or permanently failed.
+ * [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] cannot be called on a
+ * [pull task][google.cloud.tasks.v2beta2.PullMessage].
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture runTask(
+ com.google.cloud.tasks.v2beta2.RunTaskRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getRunTaskMethodHelper(), getCallOptions()), request);
+ }
+ }
+
+ private static final int METHODID_LIST_QUEUES = 0;
+ private static final int METHODID_GET_QUEUE = 1;
+ private static final int METHODID_CREATE_QUEUE = 2;
+ private static final int METHODID_UPDATE_QUEUE = 3;
+ private static final int METHODID_DELETE_QUEUE = 4;
+ private static final int METHODID_PURGE_QUEUE = 5;
+ private static final int METHODID_PAUSE_QUEUE = 6;
+ private static final int METHODID_RESUME_QUEUE = 7;
+ private static final int METHODID_GET_IAM_POLICY = 8;
+ private static final int METHODID_SET_IAM_POLICY = 9;
+ private static final int METHODID_TEST_IAM_PERMISSIONS = 10;
+ private static final int METHODID_LIST_TASKS = 11;
+ private static final int METHODID_GET_TASK = 12;
+ private static final int METHODID_CREATE_TASK = 13;
+ private static final int METHODID_DELETE_TASK = 14;
+ private static final int METHODID_LEASE_TASKS = 15;
+ private static final int METHODID_ACKNOWLEDGE_TASK = 16;
+ private static final int METHODID_RENEW_LEASE = 17;
+ private static final int METHODID_CANCEL_LEASE = 18;
+ private static final int METHODID_RUN_TASK = 19;
+
+ 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 CloudTasksImplBase serviceImpl;
+ private final int methodId;
+
+ MethodHandlers(CloudTasksImplBase 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_LIST_QUEUES:
+ serviceImpl.listQueues((com.google.cloud.tasks.v2beta2.ListQueuesRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_GET_QUEUE:
+ serviceImpl.getQueue((com.google.cloud.tasks.v2beta2.GetQueueRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_CREATE_QUEUE:
+ serviceImpl.createQueue((com.google.cloud.tasks.v2beta2.CreateQueueRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_UPDATE_QUEUE:
+ serviceImpl.updateQueue((com.google.cloud.tasks.v2beta2.UpdateQueueRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_DELETE_QUEUE:
+ serviceImpl.deleteQueue((com.google.cloud.tasks.v2beta2.DeleteQueueRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_PURGE_QUEUE:
+ serviceImpl.purgeQueue((com.google.cloud.tasks.v2beta2.PurgeQueueRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_PAUSE_QUEUE:
+ serviceImpl.pauseQueue((com.google.cloud.tasks.v2beta2.PauseQueueRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_RESUME_QUEUE:
+ serviceImpl.resumeQueue((com.google.cloud.tasks.v2beta2.ResumeQueueRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_GET_IAM_POLICY:
+ serviceImpl.getIamPolicy((com.google.iam.v1.GetIamPolicyRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_SET_IAM_POLICY:
+ serviceImpl.setIamPolicy((com.google.iam.v1.SetIamPolicyRequest) request,
+ (io.grpc.stub.StreamObserver